| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| SslConnection.java | 33 import org.eclipse.jetty.io.Connection;
40 /** SSL Connection.
42 * Connection, that implements TLS encryption using an {@link SSLEngine}.
46 * expose a source/sink of unencrypted data to another connection (eg HttpConnection).
179 public Connection handle() throws IOException
191 // If we are handshook let the delegate connection
195 // handle the delegate connection
245 Connection connection = _sslEndPoint.getConnection(); local
246 if (connection != null && connection != this
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/server/ |
| AbstractConnector.java | 36 import org.eclipse.jetty.io.Connection;
97 /** requests per connection */
99 /** duration of a connection */
184 * Set the maximum Idle time for a connection, which roughly translates to the {@link Socket#setSoTimeout(int)} call, although with NIO implementations
187 * <li>When waiting for a new request to be received on a connection</li>
191 * Jetty interprets this value as the maximum time between some progress being made on the connection. So if a single byte is read or written, then the
1043 * @return Maximum duration in milliseconds of an open connection since statsReset() called. Undefined if setStatsOn(false).
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/ |
| CallManager.java | 47 * CallManager provides call and connection control as well as
104 // empty connection list
105 private final ArrayList<Connection> mEmptyConnections = new ArrayList<Connection>();
[all...] |
| PhoneInternalInterface.java | 64 * <li>DORMANT = The data connection is still active,
227 * @param apnType specify for which apn to get connection state info.
347 * Clears all DISCONNECTED connections from Call connection lists.
389 * connection (if present) that is pending answer/accept. (This connection
405 * Initiate a new voice connection. This happens asynchronously, so you
410 * @param videoState The desired video state for the connection.
416 Connection dial(String dialString, int videoState) throws CallStateException;
419 * Initiate a new voice connection with supplementary User to User
429 * @param videoState The desired video state for the connection
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/imsphone/ |
| ImsPhone.java | 87 import com.android.internal.telephony.Connection;
503 public void notifyNewRingingConnection(Connection c) {
507 void notifyUnknownConnection(Connection c) {
518 public Connection
524 public Connection
531 private Connection dialInternal(String dialString, int videoState, Bundle intentExtras)
[all...] |
| /external/apache-http/android/src/android/net/http/ |
| Connection.java | 39 abstract class Connection {
42 * Allow a TCP connection 60 idle seconds before erroring out
54 /** The low level connection */
58 * The server SSL certificate associated with this connection
59 * (null if the connection is not secure)
66 * The host this connection is connected to. If using proxy,
71 /** true if the connection can be reused for sending more requests */
91 private static final String HTTP_CONNECTION = "http.connection";
97 * connection reduces memory churn.
101 protected Connection(Context context, HttpHost host
[all...] |
| Request.java | 52 private Connection mConnection;
71 // This will be used to set the Range field if we retry a connection. This
151 * @param connection Request served by this connection
153 void setConnection(Connection connection) {
154 mConnection = connection;
358 * call. Does not close connection--use close() below for that.
507 HttpsConnection connection = (HttpsConnection)(mConnection); local
508 if (connection != null)
[all...] |
| RequestHandle.java | 48 private Connection mConnection;
79 * Creates a new request session with a given Connection. This connection
85 Connection conn) {
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| WebSocketClientFactory.java | 42 import org.eclipse.jetty.io.Connection;
255 protected boolean addConnection(WebSocketConnection connection)
257 return isRunning() && connections.add(connection);
260 protected boolean removeConnection(WebSocketConnection connection)
262 return connections.remove(connection);
267 for (WebSocketConnection connection : connections)
268 connection.shutdown();
293 // Detect if it is SSL, and wrap the connection if so
302 AsyncConnection connection = selectSet.getManager().newConnection(channel, endPoint, holder); local
303 endPoint.setConnection(connection);
500 WebSocketConnection connection = newWebSocketConnection(); local
[all...] |
| WebSocketConnectionD08.java | 31 import org.eclipse.jetty.io.Connection;
165 public WebSocket.Connection getConnection()
180 public Connection handle() throws IOException
353 final WebSocket.Connection connection = _connection; local
354 if (connection != null)
355 connection.close(CLOSE_SHUTDOWN, null);
782 // Brutally drop the connection
|
| WebSocketConnectionRFC6455.java | 31 import org.eclipse.jetty.io.Connection;
197 public WebSocket.Connection getConnection()
212 public Connection handle() throws IOException
395 final WebSocket.Connection connection = _connection; local
396 if (connection != null)
397 connection.close(CLOSE_SHUTDOWN, null);
[all...] |
| /external/libbrillo/brillo/http/ |
| http_connection_curl_unittest.cc | 38 // read callbacks to obtain the request data from the Connection and then
53 // CURL callback functions and |connection| pointer needed to invoke the
54 // callbacks from the Connection class.
55 Connection* connection{nullptr};
60 // Request body read from the connection.
63 // Response data to be sent back to connection.
74 size_t size_read = read_callback(buffer, sizeof(buffer), 1, connection);
109 const_cast<char*>(str.data() + pos), size_remaining, 1, connection);
157 connection_ = std::make_shared<Connection>(
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| HttpConnection.java | 19 import com.squareup.okhttp.Connection;
45 * A socket connection that can be used to send HTTP/1.1 messages. This class
77 private final Connection connection; field in class:HttpConnection
85 public HttpConnection(ConnectionPool pool, Connection connection, Socket socket)
88 this.connection = connection;
104 * Configure this connection to put itself back into the connection pool whe
[all...] |
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowSQLiteDatabase.java | 14 import java.sql.Connection;
32 * Implemented as a wrapper around an embedded SQL database, accessed via JDBC. The JDBC connection is
38 private static Connection connection; field in class:ShadowSQLiteDatabase
67 connection = DatabaseConfig.getMemoryConnection();
94 PreparedStatement insert = connection.prepareStatement(sqlInsertString.sql, Statement.RETURN_GENERATED_KEYS);
128 Statement statement = connection.createStatement(DatabaseConfig.getResultSetType(), ResultSet.CONCUR_READ_ONLY);
158 PreparedStatement statement = connection.prepareStatement(sqlUpdateString.sql);
176 return connection.prepareStatement(sql).executeUpdate();
190 connection.createStatement().execute(scrubbedSql)
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| stunport.cc | 29 // (in milliseconds) because the connection binding requests should keep
255 Connection* UDPPort::CreateConnection(const Candidate& address,
270 Connection* conn = new ProxyConnection(this, 0, address);
334 if (Connection* conn = GetConnection(remote_addr)) {
|
| turnport.h | 41 STATE_DISCONNECTED, // TCP connection died, cannot send any packets.
87 virtual Connection* CreateConnection(
247 void OnConnectionDestroyed(Connection* conn);
249 // Destroys the connection with remote address |address|. Returns true if
250 // a connection is found and destroyed.
|
| /frameworks/native/services/surfaceflinger/DisplayHardware/ |
| HWC2.h | 51 typedef std::function<void(std::shared_ptr<Display>, Connection)>
84 void callHotplug(std::shared_ptr<Display> display, Connection connected);
187 std::vector<std::pair<std::shared_ptr<Display>, Connection>>
|
| /external/autotest/client/common_lib/cros/graphite/ |
| stats.py | 31 def __init__(self, name, connection=None, bare=False,
34 conn = connection if connection else _conn
75 # This is the connection that we're going to reuse for every client
78 self.conn = statsd.Connection(host=host, port=port)
|
| /hardware/intel/img/psb_video/src/x11/ |
| psb_xrandr.h | 21 * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
128 Connection connection; member in struct:_psb_xrandr_output_s
|
| /system/connectivity/shill/ |
| connection_health_checker.h | 47 // connectivity status on some connection asynchronously.
49 // connection:
50 // -(1)- No connectivity (TCP connection can not be established)
51 // -(2)- Partial connectivity (TCP connection can be established, but no data
53 // -(3)- Connectivity OK (TCP connection established, is healthy)
58 // Could not attempt a tcp connection.
60 // Failed to create TCP connection. Condition -(1)-.
62 // Failed to send data on TCP connection. Condition -(2)-.
68 ConnectionHealthChecker(ConnectionRefPtr connection,
75 // TCP connection with. Add a URL to try
139 Connection* connection() const { return connection_.get(); } function in class:shill::ConnectionHealthChecker
[all...] |
| portal_detector.cc | 31 #include "shill/connection.h"
44 static string ObjectID(Connection* c) { return c->interface_name(); }
56 ConnectionRefPtr connection,
61 connection_(connection),
110 // connection. If Start has been called, but the trial was delayed,
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/shadows/ |
| SQLiteCursorTest.java | 13 import java.sql.Connection;
25 private Connection connection; field in class:SQLiteCursorTest
31 connection = DatabaseConfig.getMemoryConnection();
33 Statement statement = connection.createStatement();
44 connection.close();
214 PreparedStatement statement = connection.prepareStatement(sql);
234 PreparedStatement statement = connection.prepareStatement(sql);
335 connection.createStatement().executeUpdate(insert);
340 Statement statement = connection.createStatement(DatabaseConfig.getResultSetType(), ResultSet.CONCUR_READ_ONLY)
[all...] |
| /libcore/luni/src/test/java/tests/java/sql/ |
| MultiThreadAccessTest.java | 20 import java.sql.Connection;
37 private static Connection conn;
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/sqlite3/test/ |
| factory.py | 27 class MyConnection(sqlite.Connection):
29 sqlite.Connection.__init__(self, *args, **kwargs)
52 "connection is not instance of MyConnection")
|
| /prebuilts/gdb/linux-x86/lib/python2.7/sqlite3/test/ |
| factory.py | 27 class MyConnection(sqlite.Connection):
29 sqlite.Connection.__init__(self, *args, **kwargs)
52 "connection is not instance of MyConnection")
|
