| /libcore/luni/src/main/java/libcore/net/http/ |
| HttpConnectionPool.java | 29 * A pool of HTTP connections. This class exposes its tuning parameters as
32 * <li>{@code http.keepAlive} true if HTTP connections should be pooled at
34 * <li>{@code http.maxConnections} maximum number of connections to each URI.
40 * so before making HTTP connections, and that this class is initialized lazily.
67 List<HttpConnection> connections = connectionPool.get(address); local
68 while (connections != null) {
69 HttpConnection connection = connections.remove(connections.size() - 1);
70 if (connections.isEmpty()) {
72 connections = null
104 List<HttpConnection> connections = connectionPool.get(address); local
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 18 * Manages reuse of HTTP and SPDY connections for reduced network latency. HTTP
21 * which connections to keep open for future use.
26 * <li>{@code http.keepAlive} true if HTTP and SPDY connections should be
28 * <li>{@code http.maxConnections} maximum number of idle connections to
37 * parameters do so before making HTTP connections, and that this class is
61 /** The maximum number of idle connections for each address. */
65 private final LinkedList<Connection> connections = new LinkedList<Connection>(); field in class:ConnectionPool
67 /** We use a single background thread to cleanup expired connections. */
75 for (ListIterator<Connection> i = connections.listIterator(connections.size())
[all...] |
| /frameworks/base/services/java/com/android/server/am/ |
| AppBindRecord.java | 31 final HashSet<ConnectionRecord> connections = new HashSet<ConnectionRecord>(); field in class:AppBindRecord
41 if (connections.size() > 0) {
42 pw.println(prefix + "Per-process Connections:");
43 Iterator<ConnectionRecord> it = connections.iterator();
|
| ContentProviderRecord.java | 46 final ArrayList<ContentProviderConnection> connections field in class:ContentProviderRecord
174 if (connections.size() > 0 || externalProcessNoHandleCount > 0) {
175 pw.print(prefix); pw.print(connections.size());
176 pw.print(" connections, "); pw.print(externalProcessNoHandleCount);
180 if (connections.size() > 0) {
182 pw.print(prefix); pw.println("Connections:");
184 for (int i=0; i<connections.size(); i++) {
185 ContentProviderConnection conn = connections.get(i);
|
| IntentBindRecord.java | 86 if (app.connections.size() > 0) {
87 for (ConnectionRecord conn : app.connections) {
|
| ActiveServices.java | 97 * All currently bound service connections. Keys are the IBinder of
496 ArrayList<ConnectionRecord> clist = s.connections.get(binder);
499 s.connections.put(binder, clist);
502 b.connections.add(c);
504 if (activity.connections == null) {
505 activity.connections = new HashSet<ConnectionRecord>();
507 activity.connections.add(c);
509 b.client.connections.add(c);
577 if (r.connections.size() > 0) {
579 = r.connections.values().iterator()
[all...] |
| ProcessRecord.java | 127 final HashSet<ConnectionRecord> connections field in class:ProcessRecord
297 if (connections.size() > 0) {
298 pw.print(prefix); pw.println("Connections:");
299 for (ConnectionRecord cr : connections) {
383 if (connections.size() > 0) {
384 for (ConnectionRecord cr : connections) {
|
| /external/chromium/third_party/libevent/ |
| evrpc-internal.h | 79 struct evconq connections; member in struct:evrpc_pool
|
| evrpc.c | 389 TAILQ_INIT(&pool->connections);
421 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
422 TAILQ_REMOVE(&pool->connections, connection, next);
446 TAILQ_INSERT_TAIL(&pool->connections, connection, next);
463 * connections.
478 TAILQ_FOREACH(evcon, &pool->connections, next) {
496 TAILQ_FOREACH(connection, &pool->connections, next) {
572 /* we better have some available connections on the pool */
573 assert(TAILQ_FIRST(&pool->connections) != NULL);
|
| http-internal.h | 80 /* for server connections, the http server they are connected with */
103 /* both the http server as well as the rpc system need to queue connections */
117 struct evconq connections; member in struct:evhttp
|
| /external/chromium/third_party/libjingle/source/talk/p2p/client/ |
| socketmonitor.cc | 120 const std::vector<Connection *> &connections = p2p_channel->connections(); local
122 for (it = connections.begin(); it != connections.end(); it++) {
|
| basicportallocator.cc | 502 std::vector<Connection*> connections; local
511 for (iter = ports[i]->connections().begin();
512 iter != ports[i]->connections().end();
514 connections.push_back(iter->second);
519 << connections.size() << " connections";
521 for (size_t i = 0; i < connections.size(); ++i)
522 connections[i]->Destroy();
524 if (running_ || (ports.size() > 0) || (connections.size() > 0))
|
| /packages/apps/Phone/src/com/android/phone/ |
| CallTime.java | 132 List connections = call.getConnections(); local
133 int count = connections.size();
137 c = (Connection) connections.get(0);
143 c = (Connection) connections.get(i);
|
| ManageConferenceUtils.java | 168 * connections.
170 * @param connections the List of connections belonging to
174 public void updateManageConferencePanel(List<Connection> connections) {
175 mNumCallersInConference = connections.size();
176 if (DBG) log("updateManageConferencePanel()... num connections in conference = "
188 Connection connection = (Connection) connections.get(i);
|
| InCallScreen.java | 646 // connections in the DISCONNECTED state.
1779 List<Connection> connections = call.getConnections(); local
3691 List<Connection> connections = mCM.getFgCallConnections(); local
3808 List<Connection> connections = mCM.getFgCallConnections(); local
[all...] |
| BluetoothPhoneService.java | 97 private static final int GSM_MAX_CONNECTIONS = 6; // Max connections allowed by GSM
98 private static final int CDMA_MAX_CONNECTIONS = 2; // Max connections allowed by CDMA
467 // Collect all known connections
471 LinkedList<Connection> connections = new LinkedList<Connection>(); local
478 connections.addAll(ringingCall.getConnections());
481 connections.addAll(foregroundCall.getConnections());
484 connections.addAll(backgroundCall.getConnections());
487 // Mark connections that we already known about
493 for (Connection c : connections) {
509 // Find a CLCC index for new connections
[all...] |
| /external/chromium/net/test/ |
| openssl_helper.cc | 191 for (unsigned connections = 0; connections < connection_limit;
192 connections++) {
200 SSL_set_session_id_context(server, (unsigned char*) &connections,
201 sizeof(connections));
232 if (!npn_mispredict || connections == 0) {
|
| /external/chromium/net/tools/testserver/ |
| xmppserver_test.py | 170 self.connections = set()
192 self.connections.add(xmpp_connection)
195 self.connections.discard(xmpp_connection)
198 for connection in self.connections:
206 self.assertEqual(len(self.connections), 0)
209 self.assertEqual(len(self.connections), 1)
241 self.assertEqual(len(self.connections), 0)
|
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/base/ |
| DefaultServer.java | 77 private Map<Integer,HostedConnection> connections = new ConcurrentHashMap<Integer,HostedConnection>(); field in class:DefaultServer
125 // now, we hard-code the standard connections and treat the +2 extras
198 if( connections.isEmpty() )
216 if( connections.isEmpty() )
230 return connections.get(id);
235 return !connections.isEmpty();
240 return Collections.unmodifiableCollection((Collection<HostedConnection>)connections.values());
358 if( connections.put( c.getId(), c ) == null ) {
421 connections.remove( removed.getId() );
424 log.log( Level.FINE, "Connections size:{0}", connections.size() )
[all...] |
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/ |
| Call.java | 87 * @return true if the call contains one or more connections
90 List<Connection> connections = getConnections(); local
92 if (connections == null) {
96 return connections.size() > 0;
111 * @return true if the call contains only disconnected connections (if any)
119 * first, or null if there are no Connections in this Call
206 * last, or null if there are no Connections in this Call
|
| /sdk/eclipse/plugins/com.android.ide.eclipse.adt/src/com/android/ide/eclipse/adt/internal/launch/ |
| LaunchConfigDelegate.java | 171 int connections = -1; local
174 connections = bridge.getConnectionAttemptCount();
181 if (connections == -1 || restarts == -1) {
194 String.format("%1$s attempts have been made to reconnect.", connections),
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| ContextMap.java | 33 * This class manages application callbacks and keeps track of GATT connections.
287 List<Connection> connections = getConnectionByApp(entry.id); local
291 b.append("\nConnections: " + connections.size());
293 Iterator<Connection> ii = connections.iterator();
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| p2ptransportchannel.h | 30 // connections which are combinations of candidates from each end (Alice and
32 // Bob are used to make a connection, repeat to make many connections).
34 // When all of the available connections become invalid (non-writable), we
35 // kick off a process of determining more candidates and more connections.
93 const std::vector<Connection *>& connections() const { return connections_; } function in class:cricket::P2PTransportChannel
|
| /system/core/libcutils/ |
| mq.c | 196 * keep track of which connections we've sent to whom.
198 Hashmap* connections; member in struct:PeerProxy
368 hashmapRemove(otherPeer->connections, &(deadPeer->credentials.pid));
419 if (peerProxy->connections != NULL) {
421 hashmapForEach(peerProxy->connections, &peerProxyRemoveConnection,
423 hashmapFree(peerProxy->connections);
874 if (!hashmapContainsKey(peerProxy->connections, &targetPid)) {
1086 peerProxy->connections = hashmapCreate(10, &pidHash, &pidEquals);
[all...] |
| /external/wpa_supplicant_8/src/eap_server/ |
| tncs.c | 165 struct tncs_data *connections; member in struct:tncs_global
194 tncs = tncs_global_data->connections;
1145 tncs->next = tncs_global_data->connections;
1146 tncs_global_data->connections = tncs;
1164 conn = tncs_global_data->connections;
1170 tncs_global_data->connections = tncs->next;
|
