| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| replay.cpp | 49 rx::composite_subscription connection; variable
52 [connection, &ys](const rxsc::schedulable&){
53 ys.connect(connection);
56 [connection](const rxsc::schedulable&){
57 connection.unsubscribe();
62 rx::composite_subscription connection; variable
65 [connection, &ys](const rxsc::schedulable&){
66 ys.connect(connection);
69 [connection](const rxsc::schedulable&){
70 connection.unsubscribe()
75 rx::composite_subscription connection; variable
162 rx::composite_subscription connection; variable
175 rx::composite_subscription connection; variable
250 rx::composite_subscription connection; variable
380 rx::composite_subscription connection; variable
499 rx::composite_subscription connection; variable
618 rx::composite_subscription connection; variable
[all...] |
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| BaseRemoteTelecomTest.java | 26 import android.telecom.Connection;
62 // Setup the primary connection service first
72 // Generate a vanilla mock connection service, if not provided.
99 //Telecom doesn't unbind the remote connection service at the end of all calls today.
105 // Assuming only 1 connection present
113 fail("No outgoing call connection requested by Telecom");
119 assertThat("Telecom should create outgoing connection for remote outgoing call",
123 MockConnection connection = remoteConnectionService.outgoingConnections.get(connectionIndex); local
124 return connection;
128 // Assuming only 1 connection presen
146 MockConnection connection = remoteConnectionService.incomingConnections.get(connectionIndex); local
158 MockConnection connection = remoteConnectionService.outgoingConnections.get(connectionIndex); local
[all...] |
| SelfManagedConnectionServiceTest.java | 27 import android.telecom.Connection;
109 * It should be possible to register self-managed Connection Services which suppor the TEL, SIP,
185 * but is also registered as a connection manager is not permitted.
187 * A self-managed {@link android.telecom.PhoneAccount} cannot also be a connection manager.
214 "connection managers, or SIM accounts.", se.getMessage());
221 * Tests ability to add a new self-managed incoming connection.
242 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(address); local
247 connection.getOnShowIncomingUiInvokeCounter().waitForCount(1);
248 setActiveAndVerify(connection);
250 // Ensure that the connection defaulted to voip audio mode
273 Connection connection = verifyConnectionForIncomingCall(); local
378 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(address); local
417 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
478 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
507 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
530 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
559 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(TEST_ADDRESS_1); local
591 SelfManagedConnection connection = TestUtils.waitForAndGetConnection(address); local
[all...] |
| MissedCallTest.java | 21 import android.telecom.Connection;
62 final MockConnection connection = verifyConnectionForIncomingCall(); local
69 assertConnectionState(connection, Connection.STATE_RINGING);
71 connection.setDisconnected(new DisconnectCause(DisconnectCause.MISSED));
72 connection.destroy();
|
| /external/deqp/framework/platform/lnx/X11/ |
| tcuLnxX11Xcb.cpp | 40 xcb_connection_t *connection = xcb_connect(name, NULL); local
41 if (connection)
44 xcb_disconnect(connection);
79 xcb_connection_t* connection = m_display.getConnection(); local
81 m_window = xcb_generate_id(connection);
82 m_colormap = xcb_generate_id(connection);
91 connection, // Connection
106 connection,
113 xcb_alloc_color_reply_t* rep = xcb_alloc_color_reply(connection, xcb_alloc_color(connection, m_colormap, 65535, 0, 0), NULL)
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| p2ptransportchannel.cc | 43 int CompareConnectionCandidates(cricket::Connection* a,
44 cricket::Connection* b) {
45 // Compare connection priority. Lower values get sorted last.
58 int CompareConnectionStates(cricket::Connection* a, cricket::Connection* b) {
65 // We prefer a receiving connection to a non-receiving, higher-priority
66 // connection when sorting connections and choosing which connection to
74 // When a TCP connection fails because of a TCP socket disconnecting, the
75 // active side of the connection will attempt to reconnect for 5 seconds whil
611 Connection* connection = port->CreateConnection( local
770 Connection* connection = port->GetConnection(remote_candidate.address()); local
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| FramedStream.java | 52 * available bytes in {@code connection.bytesLeftInWriteWindow}.
58 private final FramedConnection connection; field in class:FramedStream
78 FramedStream(int id, FramedConnection connection, boolean outFinished, boolean inFinished,
80 if (connection == null) throw new NullPointerException("connection == null");
83 this.connection = connection;
85 connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE);
87 connection.okHttpSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE));
123 return connection.client == streamIsClient
[all...] |
| /external/curl/docs/cmdline-opts/ |
| insecure.d | 8 By default, every SSL connection curl makes is verified to be secure. This
12 The server connection is verified by making sure the server's certificate
|
| local-port.d | 7 for the connection(s). Note that port numbers by nature are a scarce resource
9 cause unnecessary connection setup failures.
|
| no-keepalive.d | 2 Help: Disable TCP keepalive on the connection
4 Disables the use of keepalive messages on the TCP connection. curl otherwise
|
| /external/mesa3d/src/vulkan/wsi/ |
| wsi_common_x11.h | 20 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
34 xcb_connection_t* connection,
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Interceptor.java | 31 Connection connection(); method in interface:Interceptor.Chain
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| Interceptor.java | 33 Connection connection(); method in interface:Interceptor.Chain
|
| /external/opencensus-java/contrib/monitored_resource_util/src/main/java/io/opencensus/contrib/monitoredresource/util/ |
| GcpMetadataConfig.java | 71 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
72 connection.setRequestProperty("Metadata-Flavor", "Google");
73 InputStream input = connection.getInputStream();
74 if (connection.getResponseCode() == 200) {
|
| /external/pdfium/fxjs/xfa/ |
| cjx_connect.h | 19 JS_PROP(connection);
|
| cjx_execute.h | 19 JS_PROP(connection);
|
| cjx_setproperty.cpp | 15 void CJX_SetProperty::connection(CFXJSE_Value* pValue, function in class:CJX_SetProperty
|
| /external/python/cpython3/Doc/includes/ |
| dbpickle.py | 28 def __init__(self, file, connection):
30 self.connection = connection
35 cursor = self.connection.cursor()
|
| /external/python/cpython3/Modules/_sqlite/ |
| util.h | 29 #include "connection.h"
31 int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection);
|
| /external/skia/tools/skiaserve/urlhandlers/ |
| CmdHandler.cpp | 21 int CmdHandler::handle(Request* request, MHD_Connection* connection,
41 return SendData(connection, data.get(), "application/json");
49 return SendOK(connection);
58 return SendOK(connection);
|
| QuitHandler.cpp | 22 int QuitHandler::handle(Request* request, MHD_Connection* connection,
|
| /external/skqp/tools/skiaserve/urlhandlers/ |
| CmdHandler.cpp | 21 int CmdHandler::handle(Request* request, MHD_Connection* connection,
41 return SendData(connection, data.get(), "application/json");
49 return SendOK(connection);
58 return SendOK(connection);
|
| QuitHandler.cpp | 22 int QuitHandler::handle(Request* request, MHD_Connection* connection,
|
| /external/libbrillo/brillo/http/ |
| http_transport_curl_unittest.cc | 69 auto connection = transport_->CreateConnection("http://foo.bar/get", local
75 EXPECT_NE(nullptr, connection.get());
78 connection.reset();
99 auto connection = proxy_transport->CreateConnection("http://foo.bar/get", local
105 EXPECT_NE(nullptr, connection.get());
108 connection.reset();
117 auto connection = transport_->CreateConnection( local
119 EXPECT_NE(nullptr, connection.get());
122 connection.reset();
131 auto connection = transport_->CreateConnection local
147 auto connection = transport_->CreateConnection( local
167 auto connection = transport_->CreateConnection( local
185 auto connection = transport_->CreateConnection( local
232 auto connection = transport_->CreateConnection( local
328 auto connection = transport_->CreateConnection( local
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| ExternalHttp2Example.java | 38 HttpsURLConnection connection = (HttpsURLConnection) new OkUrlFactory(client) local
41 connection.setHostnameVerifier(new HostnameVerifier() {
48 int responseCode = connection.getResponseCode();
50 List<String> protocolValues = connection.getHeaderFields().get(SELECTED_PROTOCOL);
57 new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
