| /external/jetty/src/java/org/eclipse/jetty/client/ |
| SelectConnector.java | 33 import org.eclipse.jetty.io.Connection;
129 protected void endPointUpgraded(ConnectedEndPoint endpoint, Connection oldConnection)
147 LOG.debug("Channels with connection pending: {}", _connectingChannels.size());
161 AsyncConnection connection = selectSet.getManager().newConnection(channel,ep, key.attachment()); local
162 ep.setConnection(connection);
164 AbstractHttpConnection httpConnection=(AbstractHttpConnection)connection;
262 AsyncHttpConnection connection = (AsyncHttpConnection)_endp.getConnection(); local
268 sslConnection.getSslEndPoint().setConnection(connection);
270 LOG.debug("upgrade {} to {} for {}",this,sslConnection,connection);
274 public Connection getConnection(
[all...] |
| /external/libbrillo/brillo/http/ |
| http_transport_fake.cc | 35 std::shared_ptr<http::Connection> Transport::CreateConnection(
42 std::shared_ptr<http::Connection> connection; local
46 return connection;
57 connection =
58 std::make_shared<http::fake::Connection>(url, method, shared_from_this());
59 CHECK(connection) << "Unable to create Connection object";
60 if (!connection->SendHeaders(headers_copy, error))
61 connection.reset()
[all...] |
| http_request.h | 294 // Helper function to create an http::Connection and send off request headers.
300 // An established connection for adding request body. This connection
303 std::shared_ptr<Connection> connection_;
342 explicit Response(const std::shared_ptr<Connection>& connection);
373 std::shared_ptr<Connection> connection_;
|
| /frameworks/base/services/core/java/com/android/server/tv/ |
| TvInputHardwareManager.java | 77 * This class does a basic connection management and forwarding calls to TvInputHal which eventually
88 private final SparseArray<Connection> mConnections = new SparseArray<>();
156 Connection connection = new Connection(info); local
157 connection.updateConfigsLocked(configs);
158 mConnections.put(info.getDeviceId(), connection); local
178 Connection connection = mConnections.get(deviceId); local
179 if (connection == null)
206 Connection connection = mConnections.get(deviceId); local
232 Connection connection = mConnections.get(deviceId); local
303 Connection connection = mConnections.get(deviceId); local
375 Connection connection = mConnections.get(deviceId); local
401 Connection connection = mConnections.get(deviceId); local
426 Connection connection = mConnections.get(i); local
446 Connection connection = mConnections.get(deviceId); local
467 Connection connection = mConnections.get(deviceId); local
[all...] |
| /frameworks/base/telecomm/java/android/telecom/ |
| ConnectionRequest.java | 26 * create a new {@link Connection}.
39 * @param handle The handle (e.g., phone number) to which the {@link Connection} is to connect.
51 * @param handle The handle (e.g., phone number) to which the {@link Connection} is to connect.
53 * @param videoState Determines the video state for the connection.
65 * @param handle The handle (e.g., phone number) to which the {@link Connection} is to connect.
67 * @param videoState Determines the video state for the connection.
98 * The handle (e.g., phone number) to which the {@link Connection} is to connect.
110 * Describes the video states supported by the client requesting the connection.
116 * @return The video state for the connection.
123 * Returns the internal Telecom ID associated with the connection request
[all...] |
| RemoteConnection.java | 40 * A connection provided to a {@link ConnectionService} by another {@code ConnectionService}
56 * @param connection The {@code RemoteConnection} invoking this method.
59 public void onStateChanged(RemoteConnection connection, int state) {}
64 * @param connection The {@code RemoteConnection} invoking this method.
66 * connection.
69 RemoteConnection connection,
76 * @param connection The {@code RemoteConnection} invoking this method.
79 public void onRingbackRequested(RemoteConnection connection, boolean ringback) {}
85 * @param connection The {@code RemoteConnection} invoking this method.
89 RemoteConnection connection,
1072 final RemoteConnection connection = this; local
1093 final RemoteConnection connection = this; local
1112 final RemoteConnection connection = this; local
1130 final RemoteConnection connection = this; local
1147 final RemoteConnection connection = this; local
1170 final RemoteConnection connection = this; local
1190 final RemoteConnection connection = this; local
1206 final RemoteConnection connection = this; local
1223 final RemoteConnection connection = this; local
1240 final RemoteConnection connection = this; local
1255 final RemoteConnection connection = this; local
1270 final RemoteConnection connection = this; local
1286 final RemoteConnection connection = this; local
1302 final RemoteConnection connection = this; local
1319 final RemoteConnection connection = this; local
1336 final RemoteConnection connection = this; local
1372 final RemoteConnection connection = this; local
1386 final RemoteConnection connection = this; local
[all...] |
| /libcore/ojluni/src/main/java/java/sql/ |
| Statement.java | 40 * @see Connection#createStatement
302 * positioning. Also, cursor names must be unique within a connection.
305 * a connection
585 * Retrieves the <code>Connection</code> object
587 * @return the connection that produced this statement
592 Connection getConnection() throws SQLException;
[all...] |
| /system/connectivity/shill/vpn/ |
| vpn_service.h | 25 #include "shill/connection.h"
50 void SetConnection(const ConnectionRefPtr& connection) override;
79 // Returns the Type name of the lowest connection (presumably the "physical"
80 // connection) that this service depends on.
85 std::unique_ptr<Connection::Binder> connection_binder_;
|
| /cts/hostsidetests/devicepolicy/app/LauncherTests/src/com/android/cts/launchertests/ |
| LauncherAppsTests.java | 74 private Connection mConnection;
93 mConnection = new Connection();
195 private class Connection implements ServiceConnection {
|
| /libcore/luni/src/test/java/libcore/java/sql/ |
| OldConnectionTest.java | 20 import java.sql.Connection;
243 Connection con = md.getConnection();
552 fail("Could execute statement on closed connection.");
598 // TODO only Connection.TRANSACTION_SERIALIZABLE is supported
600 conn.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
601 assertEquals(Connection.TRANSACTION_READ_UNCOMMITTED, conn
603 conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
604 assertEquals(Connection.TRANSACTION_READ_COMMITTED, conn
606 conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
607 assertEquals(Connection.TRANSACTION_REPEATABLE_READ, con
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| AppScanStats.java | 257 List<ContextMap.Connection> connections =
262 Iterator<ContextMap.Connection> ii = connections.iterator();
264 ContextMap.Connection connection = ii.next();
265 long connectionTime = System.currentTimeMillis() - connection.startTime;
266 sb.append(" " + connection.connId + ": " +
267 connection.address + " " + connectionTime + "ms\n");
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/hfpclient/connserv/ |
| HfpClientConnection.java | 24 import android.telecom.Connection;
29 public class HfpClientConnection extends Connection {
81 getState() != Connection.STATE_DISCONNECTED;
|
| /packages/services/Telephony/src/com/android/phone/ |
| EmergencyCallHelper.java | 20 import com.android.internal.telephony.Connection;
237 Connection conn = (Connection) ((AsyncResult) msg.obj).result;
239 if (DBG) log("onDisconnect: connection '" + conn
|
| /frameworks/native/services/inputflinger/ |
| InputDispatcher.cpp | 79 // Amount of time to allow touch events to be streamed out to a connection before requiring
603 commandEntry->connection.clear();
938 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
1032 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
1679 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
2150 sp<Connection> connection = d->mConnectionsByFd.valueAt(connectionIndex); local
3285 const sp<Connection>& connection = mConnectionsByFd.valueAt(i); local
3358 sp<Connection> connection = new Connection(inputChannel, inputWindowHandle, monitor); local
3404 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
3432 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
3506 sp<Connection> connection = commandEntry->connection; local
3559 sp<Connection> connection = commandEntry->connection; local
3605 startDispatchCycleLocked(now(), connection); local
[all...] |
| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| DriverManagerTest.java | 26 import java.sql.Connection;
142 * Class under test for Connection getConnection(String)
144 // valid connection - data1 does not require a user and password...
147 // invalid connection - data2 requires a user & password
150 // invalid connection - URL is gibberish
153 // invalid connection - URL is null
160 Connection theConnection = null;
197 * Class under test for Connection getConnection(String, Properties)
218 Connection theConnection = null;
240 * Class under test for Connection getConnection(String, String, String
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| SelectChannelEndPoint.java | 32 import org.eclipse.jetty.io.Connection;
60 * The connection instance is the handler for any IO activity on the endpoint.
61 * There is a different type of connection for HTTP, AJP, WebSocket and
62 * ProxyConnect. The connection may change for an SCEP as it is upgraded
127 public Connection getConnection()
133 public void setConnection(Connection connection)
135 Connection old=_connection;
136 _connection=(AsyncConnection)connection;
700 Connection old=_connection
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| port_unittest.cc | 162 virtual Connection* CreateConnection(const Candidate& remote_candidate,
164 Connection* conn = new ProxyConnection(this, 0, remote_candidate);
232 Connection* conn() { return conn_; }
250 void OnConnectionStateChange(Connection* conn) {
251 if (conn->write_state() == Connection::STATE_WRITABLE) {
309 void OnDestroyed(Connection* conn) {
311 LOG(INFO) << "OnDestroy connection " << conn << " deleted";
313 // When the connection is destroyed, also clear these fields so future
336 // ReadyToSend will only issue after a Connection recovers from EWOULDBLOCK.
337 void OnConnectionReadyToSend(Connection* conn)
[all...] |
| relayport.h | 31 // order with a small delay in between. When a connection is
32 // successful all other connection attempts are aborted.
58 Connection* CreateConnection(const Candidate& address,
94 // Dispatches the given packet to the port or connection as appropriate.
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| WebSocketConnectionD00.java | 31 import org.eclipse.jetty.io.Connection;
69 public org.eclipse.jetty.websocket.WebSocket.Connection getConnection()
84 public Connection handle() throws IOException
|
| WebSocketConnectionD06.java | 31 import org.eclipse.jetty.io.Connection;
130 public WebSocket.Connection getConnection()
136 public Connection handle() throws IOException
269 final WebSocket.Connection connection = _connection; local
270 if (connection != null)
271 connection.close(CLOSE_SHUTDOWN, null);
|
| /frameworks/base/core/java/android/speech/ |
| SpeechRecognizer.java | 116 /** The connection to the actual service */
117 private Connection mConnection;
147 * Temporary queue, saving the messages until the connection will be established, afterwards,
168 private class Connection implements ServiceConnection {
267 if (mConnection == null) { // first time connection
268 mConnection = new Connection();
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| BaseTelecomTestWithMockServices.java | 35 import android.telecom.Connection;
130 // Generate a vanilla mock connection service, if not provided.
349 // MockConnectionService#onCreateOutgoingConnection, however the connection will not
353 // We will wait here until the list of connections includes one more connection to ensure
364 // Assuming only 1 connection present
372 fail("No outgoing call connection requested by Telecom");
378 assertThat("Telecom should create outgoing connection for outgoing call",
380 MockConnection connection = connectionService.outgoingConnections.get(connectionIndex); local
381 return connection;
385 // Assuming only 1 connection presen
401 MockConnection connection = connectionService.incomingConnections.get(connectionIndex); local
414 MockConnection connection = connectionService.outgoingConnections.get(connectionIndex); local
[all...] |
| /external/libmicrohttpd/src/testspdy/ |
| test_new_connection.c | 21 * @brief tests new connection callback. spdycli.c
107 struct Connection {
110 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
115 SSL connection. */
228 struct Connection *connection; local
230 connection = (struct Connection*)user_data;
231 connection->want_io = IO_NONE;
233 rv = SSL_write(connection->ssl, data, length)
260 struct Connection *connection; local
660 struct Connection connection; local
[all...] |
| test_request_response.c | 89 struct Connection {
92 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
97 SSL connection. */
210 struct Connection *connection; local
212 connection = (struct Connection*)user_data;
213 connection->want_io = IO_NONE;
215 rv = SSL_write(connection->ssl, data, length);
217 int err = SSL_get_error(connection->ssl, rv)
242 struct Connection *connection; local
648 struct Connection connection; local
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/sip/ |
| SipPhoneBase.java | 34 import com.android.internal.telephony.Connection;
70 public Connection dial(String dialString, UUSInfo uusInfo, int videoState, Bundle intentExtras)
179 void notifyNewRingingConnection(Connection c) {
183 void notifyDisconnect(Connection cn) {
|
