| /frameworks/base/core/java/com/android/internal/os/ |
| ZygoteServer.java | 119 * Waits for and accepts a single command connection. Throws
203 ZygoteConnection connection = peers.get(i); local
204 final Runnable command = connection.processOneCommand(this);
223 if (connection.isClosedByPeer()) {
224 connection.closeSocket();
|
| /frameworks/base/media/java/android/media/ |
| MediaScannerConnection.java | 75 * when a connection to the MediaScanner service has been established
80 * Called to notify the client when a connection to the
97 * @param context the Context object, required for establishing a connection to
108 * Initiates a connection to the media scanner service.
110 * will be called when the connection is established.
126 * Releases the connection to the media scanner service.
224 * <var>path</var> and <var>mimeType</var> when the connection is
226 * @param context The caller's Context, required for establishing a connection to
241 MediaScannerConnection connection = new MediaScannerConnection(context, client); local
242 client.mConnection = connection;
[all...] |
| /frameworks/base/telecomm/java/android/telecom/ |
| ConnectionService.java | 82 * wherein it should provide a new instance of a {@link Connection} object. It is through this
83 * {@link Connection} object that telecom receives state updates and the {@link ConnectionService}
97 * being asked to create a new outgoing {@link Connection} is to perform a handover of an
187 private static Connection sNullConnection;
189 private final Map<String, Connection> mConnectionById = new ConcurrentHashMap<>();
190 private final Map<Connection, String> mIdByConnection = new ConcurrentHashMap<>();
609 args.arg2 = new Connection.RttTextStream(toInCall, fromInCall);
640 args.arg2 = new Connection.RttTextStream(toInCall, fromInCall);
1512 Connection connection = null; local
1536 addConnection(request.getAccountHandle(), callId, connection); local
1761 Connection connection = findConnectionForAction(callId, "splitFromConference"); local
1798 Connection connection = findConnectionForAction(callId, "pullExternalCall"); local
1815 Connection connection = findConnectionForAction(callId, "sendCallEvent"); local
1828 Connection connection = findConnectionForAction(callId, "notifyHandoverComplete"); local
2573 Connection connection = (Connection) c; local
[all...] |
| /packages/apps/Dialer/java/com/android/voicemail/impl/mail/store/ |
| ImapStore.java | 42 private ImapConnection connection; field in class:ImapStore
170 if (connection != null) {
171 connection.close();
172 connection = null;
177 if (connection == null) {
178 connection = new ImapConnection(this);
180 return connection;
|
| /packages/services/Telephony/src/com/android/services/telephony/ |
| CdmaConference.java | 22 import android.telecom.Connection;
44 mProperties = Connection.PROPERTY_GENERIC_CONFERENCE;
51 capabilities |= Connection.CAPABILITY_MUTE;
56 * Invoked when the Conference and all it's {@link Connection}s should be disconnected.
72 public void onSeparate(Connection connection) {
93 mCapabilities &= ~Connection.CAPABILITY_MERGE_CONFERENCE;
96 mCapabilities |= Connection.CAPABILITY_SWAP_CONFERENCE;
104 final CdmaConnection connection = getFirstConnection(); local
105 if (connection != null)
114 final CdmaConnection connection = getFirstConnection(); local
[all...] |
| PstnIncomingCallNotifier.java | 32 import com.android.internal.telephony.Connection;
51 /** New ringing connection event code. */
126 Connection connection = (Connection) asyncResult.result; local
127 if (connection != null) {
128 Call call = connection.getCall();
132 sendIncomingCallIntent(connection);
142 Connection connection = call.getLatestConnection() local
174 Connection connection = (Connection) asyncResult.result; local
[all...] |
| TelephonyConnectionService.java | 27 import android.telecom.Connection;
82 public Collection<Connection> getAllConnections() {
94 public void removeConnection(Connection connection) {
95 TelephonyConnectionService.this.removeConnection(connection);
99 Connection connection) {
101 .addExistingConnection(phoneAccountHandle, connection);
105 Connection connection, Conference conference)
651 final TelephonyConnection connection = local
713 TelephonyConnection connection = local
815 com.android.internal.telephony.Connection connection = local
866 TelephonyConnection connection = local
[all...] |
| /packages/apps/Email/provider_src/com/android/email/mail/store/ |
| ImapStore.java | 419 // TODO: There is nothing that ever closes this connection. Trouble is, it's not exactly
422 ImapConnection connection = getConnection(); local
425 // Establish a connection to the IMAP server; if necessary
427 connection.executeSimpleCommand(ImapConstants.NOOP);
432 List<ImapResponse> responses = connection.executeSimpleCommand(imapCommand);
469 connection.close();
472 // We do NOT want this connection pooled, or we will continue to send NOOP and SELECT
474 connection.destroyResponses();
475 connection = null;
478 if (connection != null)
493 ImapConnection connection = new ImapConnection(this); local
555 ImapConnection connection; local
690 ImapConnection connection; local
[all...] |
| /libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/https/ |
| HttpsURLConnectionTest.java | 88 // read/connection timeout value
138 // create url connection to be tested
140 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
141 connection.setSSLSocketFactory(ctx.getSocketFactory());
144 executeClientRequest(connection, false /* doOutput */);
146 checkConnectionStateParameters(connection, dispatcher.getLastRequest());
149 connection.connect();
155 * Tests the behaviour of HTTPS connection in case of unavailability of requested resource.
171 // create url connection to be tested
173 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection() local
218 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
258 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
291 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
334 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
370 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
409 HttpsURLConnection connection = (HttpsURLConnection) local
458 HttpsURLConnection connection = (HttpsURLConnection) local
492 HttpsURLConnection connection = (HttpsURLConnection) local
564 HttpsURLConnection connection = (HttpsURLConnection) local
600 HttpsURLConnection connection = (HttpsURLConnection) local
642 HttpsURLConnection connection = (HttpsURLConnection) local
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/usb/device/ |
| UsbDeviceTestActivity.java | 148 UsbDeviceConnection connection = mUsbManager.openDevice(device);
150 makeThisDeviceAnAccessory(connection);
152 connection.close();
197 * @param connection The connection to the USB device
199 private void makeThisDeviceAnAccessory(@NonNull UsbDeviceConnection connection) {
200 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MANUFACTURER,
202 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_MODEL,
204 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_DESCRIPTION,
206 AoapInterface.sendString(connection, AoapInterface.ACCESSORY_STRING_VERSION, "2")
2061 UsbDeviceConnection connection = mUsbManager.openDevice(device); local
[all...] |
| /cts/tests/inputmethod/src/android/view/inputmethod/cts/util/ |
| WindowFocusStealer.java | 95 * Establishes a connection to the service.
99 * @throws TimeoutException when failed to establish the connection within {@code timeout}
105 final ServiceConnection connection = new ServiceConnection() { local
116 context.bindService(intent, connection, Context.BIND_AUTO_CREATE);
132 context.unbindService(connection);
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| VideoCallTest.java | 22 import android.telecom.Connection;
23 import android.telecom.Connection.VideoProvider;
40 * The handler of the {@link Connection.VideoProvider} is, however, not public. As a workaround
66 final MockConnection connection = verifyConnectionForOutgoingCall(); local
72 connection.setActive();
130 final MockConnection connection = verifyConnectionForOutgoingCall(); local
144 connection.sendMockSessionModifyRequest(
159 final MockConnection connection = verifyConnectionForOutgoingCall(); local
163 final MockVideoProvider mockVideoProvider = connection.getMockVideoProvider();
184 final MockConnection connection = verifyConnectionForOutgoingCall() local
240 final MockConnection connection = verifyConnectionForOutgoingCall(); local
346 final MockConnection connection = verifyConnectionForOutgoingCall(); local
382 final MockConnection connection = verifyConnectionForOutgoingCall(); local
468 final MockConnection connection = verifyConnectionForOutgoingCall(); local
493 final MockConnection connection = verifyConnectionForOutgoingCall(); local
515 final MockConnection connection = verifyConnectionForOutgoingCall(); local
542 final MockConnection connection = verifyConnectionForOutgoingCall(); local
569 final MockConnection connection = verifyConnectionForOutgoingCall(); local
592 final MockConnection connection = verifyConnectionForOutgoingCall(); local
[all...] |
| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| TestHelper_Driver4.java | 20 import java.sql.Connection;
74 public Connection connect(String url, Properties info) throws SQLException {
104 // It all checks out - so return a connection
105 Connection connection = new TestHelper_Connection1(); local
106 return connection;
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
| MockServerSocket.java | 33 private Socket connection; field in class:MockServerSocket
44 * Establishes a new mock connection. This method blocks until the other end
45 * of the connection has been accepted.
47 * @return remote end of the mock connection
52 connection = c.getSocketA();
54 while (connection != null) {
92 while (connection == null) {
98 return connection;
102 connection = null;
|
| /external/libmicrohttpd/src/microhttpd/ |
| test_postprocessor.c | 124 struct MHD_Connection connection; local
132 memset (&connection, 0, sizeof (struct MHD_Connection));
134 connection.headers_received = &header;
138 pp = MHD_create_post_processor (&connection,
158 struct MHD_Connection connection; local
177 memset (&connection, 0, sizeof (struct MHD_Connection));
179 connection.headers_received = &header;
184 pp = MHD_create_post_processor (&connection,
199 struct MHD_Connection connection; local
210 memset (&connection, 0, sizeof (struct MHD_Connection))
232 struct MHD_Connection connection; local
267 struct MHD_Connection connection; local
302 struct MHD_Connection connection; local
[all...] |
| /external/oauth/core/src/main/java/net/oauth/client/ |
| URLConnectionResponse.java | 44 byte[] requestExcerpt, URLConnection connection) throws IOException {
49 this.connection = connection;
56 private final URLConnection connection; field in class:URLConnectionResponse
60 if (connection instanceof HttpURLConnection) {
61 return ((HttpURLConnection) connection).getResponseCode();
69 return connection.getInputStream();
79 for (int i = 0; (value = connection.getHeaderField(i)) != null; ++i) {
80 String name = connection.getHeaderFieldKey(i);
89 headers.add(new OAuth.Parameter(CONTENT_TYPE, connection
[all...] |
| /external/okhttp/okhttp-logging-interceptor/src/main/java/com/squareup/okhttp/logging/ |
| HttpLoggingInterceptor.java | 18 import com.squareup.okhttp.Connection;
151 Connection connection = chain.connection(); local
152 Protocol protocol = connection != null ? connection.getProtocol() : Protocol.HTTP_1_1;
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| Spdy3ConnectionTest.java | 77 FramedConnection connection = connection(peer, SPDY3); local
78 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
84 assertEquals(0, connection.openStreamCount());
106 FramedConnection connection = connection(peer, SPDY3); local
107 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false);
108 assertEquals(1, connection.openStreamCount());
110 connection.ping().roundTripTime(); // Ensure that inFinished has been received.
111 assertEquals(0, connection.openStreamCount())
123 FramedConnection connection = connection(peer, SPDY3); local
209 connection(peer, SPDY3); method
226 FramedConnection connection = connection(peer, SPDY3); local
[all...] |
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowSQLiteProgram.java | 10 import java.sql.Connection;
19 Connection connection; field in class:ShadowSQLiteProgram
23 connection = Robolectric.shadowOf(db).getConnection();
26 actualDBstatement = connection.prepareStatement(sql,
|
| /external/sl4a/InterpreterForAndroid/src/com/googlecode/android_scripting/ |
| UrlDownloaderTask.java | 146 URLConnection connection = null; local
148 connection = mUrl.openConnection();
153 int contentLength = connection.getContentLength();
168 int bytesCopied = IoUtils.copy(connection.getInputStream(), mProgressReportingOutputStream);
|
| /external/smali/smalidea/src/main/java/org/jf/smalidea/errorReporting/ |
| GithubFeedbackTask.java | 167 HttpURLConnection connection = (HttpURLConnection) ((new URL(url)).openConnection()); local
168 connection.setConnectTimeout(5000);
169 connection.setReadTimeout(5000);
170 return connection;
|
| /external/walt/android/WALT/app/src/main/java/org/chromium/latency/walt/ |
| WaltDevice.java | 65 private WaltConnection connection; field in class:WaltDevice
117 connection = WaltTcpConnection.getInstance(context);
119 // USB connection
120 logger.log("No TCP bridge detected, using direct USB connection");
121 connection = WaltUsbConnection.getInstance(context);
123 connection.setConnectionStateListener(this);
124 connection.connect();
131 connection = usbConnection;
132 connection.setConnectionStateListener(this);
137 return connection.isConnected()
[all...] |
| /external/webrtc/webrtc/base/ |
| httpserver.cc | 48 Connection* connection = new Connection(connection_id, this); local
49 connections_.insert(ConnectionMap::value_type(connection_id, connection));
50 connection->BeginProcess(stream);
57 if (Connection* connection = Find(connection_id)) {
58 connection->Respond(transaction);
62 // connection still exists.
68 if (Connection* connection = Find(connection_id))
106 Connection* connection = it->second; local
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| ARTPSession.cpp | 52 AString connection; local
53 if (!mDesc->findAttribute(i, "c=", &connection)) {
54 // No per-stream connection information, try global fallback.
55 if (!mDesc->findAttribute(0, "c=", &connection)) {
56 ALOGE("Unable to find connection attribute.");
60 if (!(connection == "IN IP4 127.0.0.1")) {
|
| /frameworks/base/apct-tests/perftests/core/src/android/os/ |
| StrictModeTest.java | 106 ServiceConnection connection = local
119 new Intent(context, SomeService.class), connection, Context.BIND_AUTO_CREATE);
125 context.unbindService(connection);
|
