| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| D | Internal.java | 20 import com.squareup.okhttp.Connection;
51 public abstract Transport newTransport(Connection connection, HttpEngine httpEngine) in newTransport()
54 public abstract boolean clearOwner(Connection connection); in clearOwner()
56 public abstract void closeIfOwnedBy(Connection connection, Object owner) throws IOException; in closeIfOwnedBy()
58 public abstract int recycleCount(Connection connection); in recycleCount()
60 public abstract void setProtocol(Connection connection, Protocol protocol); in setProtocol()
62 public abstract void setOwner(Connection connection, HttpEngine httpEngine); in setOwner()
64 public abstract boolean isReadable(Connection pooled); in isReadable()
74 public abstract void recycle(ConnectionPool pool, Connection connection); in recycle()
82 public abstract void connectAndSetOwner(OkHttpClient client, Connection connection, in connectAndSetOwner()
[all …]
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ConnectionPool.java | 78 private final LinkedList<Connection> connections = new LinkedList<>();
124 for (Connection connection : connections) { in getMultiplexedConnectionCount()
136 public synchronized Connection get(Address address) { in get()
137 Connection foundConnection = null; in get()
138 for (ListIterator<Connection> i = connections.listIterator(connections.size()); in get()
140 Connection connection = i.previous(); in get()
174 void recycle(Connection connection) { in recycle()
204 private void addConnection(Connection connection) { in addConnection()
218 void share(Connection connection) { in share()
228 List<Connection> toEvict; in evictAll()
[all …]
|
| D | OkHttpClient.java | 66 Connection connection, HttpEngine httpEngine) throws IOException {
70 @Override public boolean clearOwner(Connection connection) {
74 @Override public void closeIfOwnedBy(Connection connection, Object owner) throws IOException {
78 @Override public int recycleCount(Connection connection) {
82 @Override public void setProtocol(Connection connection, Protocol protocol) {
86 @Override public void setOwner(Connection connection, HttpEngine httpEngine) {
90 @Override public boolean isReadable(Connection pooled) {
110 @Override public void recycle(ConnectionPool pool, Connection connection) {
126 @Override public void connectAndSetOwner(OkHttpClient client, Connection connection,
140 @Override public Connection callEngineGetConnection(Call call) {
[all …]
|
| /external/lldb/source/Core/ |
| D | Connection.cpp | 18 Connection::Connection () in Connection() function in Connection
22 Connection::~Connection () in ~Connection()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | ConnectionPoolTest.java | 67 private Connection httpA;
68 private Connection httpB;
69 private Connection httpC;
70 private Connection httpD;
71 private Connection httpE;
72 private Connection spdyA;
109 httpA = new Connection(pool, httpRoute); in setUp()
111 httpB = new Connection(pool, httpRoute); in setUp()
113 httpC = new Connection(pool, httpRoute); in setUp()
115 httpD = new Connection(pool, httpRoute); in setUp()
[all …]
|
| /external/lldb/include/lldb/Core/ |
| D | Connection.h | 34 class Connection
40 Connection ();
47 ~Connection ();
157 DISALLOW_COPY_AND_ASSIGN (Connection);
|
| /external/jetty/src/java/org/eclipse/jetty/server/ |
| D | BlockingHttpConnection.java | 27 import org.eclipse.jetty.io.Connection;
56 public Connection handle() throws IOException in handle()
58 Connection connection = this; in handle()
107 … Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); in handle()
|
| D | AsyncHttpConnection.java | 26 import org.eclipse.jetty.io.Connection;
55 public Connection handle() throws IOException in handle()
57 Connection connection = this; in handle()
125 … Connection switched=(Connection)_request.getAttribute("org.eclipse.jetty.io.Connection"); in handle()
|
| D | LocalConnector.java | 29 import org.eclipse.jetty.io.Connection;
116 public void setConnection(Connection connection) in run()
136 final Connection con = endPoint.getConnection(); in run()
137 final Connection next = con.handle(); in run()
|
| /external/apache-http/android/src/android/net/http/ |
| D | RequestQueue.java | 144 Connection connection = mThreads[i].mConnection; in disablePersistence()
157 Connection connection = ct.mConnection; in getThread()
166 public Connection getConnection(Context context, HttpHost host) { in getConnection()
168 Connection con = mIdleCache.getConnection(host); in getConnection()
171 con = Connection.getConnection(mContext, host, mProxyHost, in getConnection()
176 public boolean recycleConnection(Connection connection) { in recycleConnection()
379 Connection conn = Connection.getConnection(mContext, host, mProxyHost, in queueSynchronousRequest()
536 Connection getConnection(Context context, HttpHost host); in getConnection()
537 boolean recycleConnection(Connection connection); in recycleConnection()
|
| D | IdleCache.java | 31 Connection mConnection;
64 HttpHost host, Connection connection) { in cacheConnection()
94 synchronized Connection getConnection(HttpHost host) { in getConnection()
95 Connection ret = null; in getConnection()
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| D | WebSocket.java | 35 void onOpen(Connection connection); in onOpen()
112 public interface Connection interface
176 public interface FrameConnection extends Connection
|
| D | WebSocketClient.java | 305 …public WebSocket.Connection open(URI uri, WebSocket websocket,long maxConnectTime,TimeUnit units) … in open()
335 public Future<WebSocket.Connection> open(URI uri, WebSocket websocket) throws IOException in open()
393 static class WebSocketFuture implements Future<WebSocket.Connection>
555 …public org.eclipse.jetty.websocket.WebSocket.Connection get() throws InterruptedException, Executi… in get()
567 …public org.eclipse.jetty.websocket.WebSocket.Connection get(long timeout, TimeUnit unit) throws In… in get()
572 org.eclipse.jetty.websocket.WebSocket.Connection connection=null; in get()
|
| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| D | TestHelper_Driver1.java | 20 import java.sql.Connection;
76 public Connection connect(String url, Properties info) throws SQLException { in connect()
89 Connection connection = new TestHelper_Connection1(); in connect()
|
| D | TestHelper_Driver4.java | 20 import java.sql.Connection;
74 public Connection connect(String url, Properties info) throws SQLException { in connect()
105 Connection connection = new TestHelper_Connection1(); in connect()
|
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/base/ |
| D | DefaultServer.java | 83 private Map<Long,Connection> connecting = new ConcurrentHashMap<Long,Connection>();
309 Connection addedConnection = null; in registerClient()
319 Connection c = connecting.remove(tempId); in registerClient()
321 c = new Connection(channels.size()); in registerClient()
413 Connection removed = null; in connectionClosed()
419 removed = (Connection)endpointConnections.remove(p); in connectionClosed()
440 protected class Connection implements HostedConnection class in DefaultServer
449 public Connection( int channelCount ) in Connection() method in DefaultServer.Connection
|
| /external/clang/test/CodeGen/ |
| D | 2002-03-12-StructInitializer.c | 12 } Connection; typedef
14 Connection link[3]
|
| D | 2002-03-12-StructInitialize.c | 8 } Connection; typedef
10 Connection link[3]
|
| /external/jetty/src/java/org/eclipse/jetty/io/ |
| D | ConnectedEndPoint.java | 23 Connection getConnection(); in getConnection()
24 void setConnection(Connection connection); in setConnection()
|
| D | Connection.java | 35 public interface Connection interface
44 Connection handle() throws IOException; in handle()
|
| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| D | AsyncConnection.java | 23 import org.eclipse.jetty.io.Connection;
25 public interface AsyncConnection extends Connection
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| D | HttpEngine.java | 22 import com.squareup.okhttp.Connection;
116 private Connection connection;
189 boolean callerWritesRequestBody, boolean forWebSocket, Connection connection, in HttpEngine()
339 private Connection nextConnection() throws RouteException { in nextConnection()
340 Connection connection = createNextConnection(); in nextConnection()
345 private Connection createNextConnection() throws RouteException { in createNextConnection()
349 for (Connection pooled; (pooled = pool.get(address)) != null; ) { in createNextConnection()
358 return new Connection(pool, route); in createNextConnection()
407 public Connection getConnection() { in getConnection()
427 Connection connection = close(); in recover()
[all …]
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketCall.java | 20 import com.squareup.okhttp.Connection;
169 Connection connection = Internal.instance.callEngineGetConnection(call); in createWebSocket()
197 static RealWebSocket create(Response response, Connection connection, BufferedSource source, in create()
209 private final Connection connection;
211 private ConnectionWebSocket(Connection connection, BufferedSource source, BufferedSink sink, in ConnectionWebSocket()
|
| /external/jetty/src/java/org/eclipse/jetty/server/bio/ |
| D | SocketConnector.java | 32 import org.eclipse.jetty.io.Connection;
128 protected Connection newConnection(EndPoint endpoint) in newConnection()
193 volatile Connection _connection;
203 public Connection getConnection() in getConnection()
208 public void setConnection(Connection connection) in setConnection()
|
| /external/jetty/src/java/org/eclipse/jetty/client/ |
| D | SocketConnector.java | 26 import org.eclipse.jetty.io.Connection;
73 Connection con = connection; in startConnection()
76 final Connection next = con.handle(); in startConnection()
|