/external/okhttp/src/main/java/libcore/net/http/ |
H A D | HttpConnectionPool.java | 29 * A pool of HTTP and SPDY connections. This class exposes its tuning parameters 32 * <li>{@code http.keepAlive} true if HTTP and SPDY connections should be 34 * <li>{@code http.maxConnections} maximum number of connections to each host. 40 * so before making HTTP connections, and that this class is initialized lazily. 66 List<HttpConnection> connections = connectionPool.get(address); 67 while (connections != null) { 68 HttpConnection connection = connections.get(connections.size() - 1); 70 connections.remove(connections [all...] |
/external/dbus/bus/ |
H A D | connection.c | 2 /* connection.c Client connections 56 DBusList *completed; /**< List of all completed connections */ 58 DBusList *incomplete; /**< List of all not-yet-active connections */ 61 DBusHashTable *completed_by_user; /**< Number of completed connections for each UID */ 62 DBusTimeout *expire_timeout; /**< Timeout for expiring incomplete connections. */ 71 BusConnections *connections; member in struct:__anon4954 89 int stamp; /**< connections->stamp last time we were traversed */ 96 static void bus_connection_drop_pending_replies (BusConnections *connections, 110 return bus_context_get_loop (d->connections->context); 115 get_connections_for_uid (BusConnections *connections, argument 132 adjust_connections_for_uid(BusConnections *connections, dbus_uid_t uid, int adjustment) argument 433 BusConnections *connections; local 487 bus_connections_ref(BusConnections *connections) argument 496 bus_connections_unref(BusConnections *connections) argument 606 bus_connections_setup_connection(BusConnections *connections, DBusConnection *connection) argument 781 bus_connections_expire_incomplete(BusConnections *connections) argument 840 BusConnections *connections = data; local 938 foreach_active(BusConnections *connections, BusConnectionForeachFunction function, void *data) argument 960 foreach_inactive(BusConnections *connections, BusConnectionForeachFunction function, void *data) argument 991 bus_connections_foreach_active(BusConnections *connections, BusConnectionForeachFunction function, void *data) argument 1007 bus_connections_foreach(BusConnections *connections, BusConnectionForeachFunction function, void *data) argument 1018 bus_connections_get_context(BusConnections *connections) argument 1031 bus_connections_increment_stamp(BusConnections *connections) argument 1436 bus_connections_check_limits(BusConnections *connections, DBusConnection *requesting_completion, DBusError *error) argument 1484 bus_pending_reply_send_no_reply(BusConnections *connections, BusTransaction *transaction, BusPendingReply *pending) argument 1531 BusConnections *connections = data; local 1566 bus_connection_drop_pending_replies(BusConnections *connections, DBusConnection *connection) argument 1627 BusConnections *connections; member in struct:__anon4955 1663 bus_connections_expect_reply(BusConnections *connections, BusTransaction *transaction, DBusConnection *will_get_reply, DBusConnection *will_send_reply, DBusMessage *reply_to_this, DBusError *error) argument 1778 BusConnections *connections; member in struct:__anon4956 1819 bus_connections_check_reply(BusConnections *connections, BusTransaction *transaction, DBusConnection *sending_reply, DBusConnection *receiving_reply, DBusMessage *reply, DBusError *error) argument 1910 DBusList *connections; member in struct:BusTransaction [all...] |
H A D | connection.h | 2 /* connection.h Client connections 36 BusConnections* bus_connections_ref (BusConnections *connections); 37 void bus_connections_unref (BusConnections *connections); 38 dbus_bool_t bus_connections_setup_connection (BusConnections *connections, 40 void bus_connections_foreach (BusConnections *connections, 43 void bus_connections_foreach_active (BusConnections *connections, 46 BusContext* bus_connections_get_context (BusConnections *connections); 47 void bus_connections_increment_stamp (BusConnections *connections); 55 dbus_bool_t bus_connections_check_limits (BusConnections *connections, 58 void bus_connections_expire_incomplete (BusConnections *connections); [all...] |
H A D | signals.h | 82 BusConnections *connections,
|
H A D | bus.c | 58 BusConnections *connections; member in struct:BusContext 185 if (!bus_connections_setup_connection (context->connections, new_connection)) 802 context->connections = bus_connections_new (context); 803 if (context->connections == NULL) 1044 if (context->connections) 1046 bus_connections_unref (context->connections); 1047 context->connections = NULL; 1151 return context->connections; 1448 /* Policy for inactive connections is that they can only send
|
H A D | driver.c | 253 BusConnections *connections; local 268 * incomplete connections. It's even OK if the connection wants to 271 connections = bus_connection_get_connections (connection); 272 if (!bus_connections_check_limits (connections, connection,
|
/external/chromium/third_party/libevent/ |
H A D | evrpc-internal.h | 79 struct evconq connections; member in struct:evrpc_pool
|
H A D | 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);
|
H A D | 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
|
H A D | http.c | 485 * persistent connections to work. 644 * layer like timeouts we just drop the connections. 1001 TAILQ_REMOVE(&http->connections, evcon, next); 2269 event_debug(("Bound to port %d - Awaiting connections ... ", 2318 TAILQ_INIT(&http->connections); 2369 while ((evcon = TAILQ_FIRST(&http->connections)) != NULL) { 2601 /* the timeout can be used by the server to close idle connections */ 2610 TAILQ_INSERT_TAIL(&http->connections, evcon, next);
|
/external/chromium/third_party/libjingle/source/talk/p2p/client/ |
H A D | socketmonitor.cc | 120 const std::vector<Connection *> &connections = p2p_channel->connections(); local 122 for (it = connections.begin(); it != connections.end(); it++) {
|
H A D | 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))
|
/external/chromium/net/test/ |
H A D | 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/ |
H A D | 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/ |
H A D | 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 [all...] |
/external/dbus/test/data/valid-config-files/system.d/ |
H A D | test.conf | 6 connections can get messages from it -->
|
/external/chromium/third_party/libjingle/source/talk/p2p/base/ |
H A D | 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
|
H A D | port.h | 74 // connections to similar mechanisms of the other client. Subclasses of this 138 // Returns a map containing all of the connections of this port, keyed by the 141 const AddressMap& connections() { return connections_; } function in class:cricket::Port 203 // Called if the port has no connections and is no longer useful. 258 // Called when one of our connections deletes itself. 304 // be false for TCP connections.
|
/external/wpa_supplicant_6/wpa_supplicant/src/eap_server/ |
H A D | tncs.c | 171 struct tncs_data *connections; member in struct:tncs_global 200 tncs = tncs_global_data->connections; 1151 tncs->next = tncs_global_data->connections; 1152 tncs_global_data->connections = tncs; 1170 conn = tncs_global_data->connections; 1176 tncs_global_data->connections = tncs->next;
|
/external/wpa_supplicant_8/hostapd/src/eap_server/ |
H A D | 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;
|
/external/wpa_supplicant_8/src/eap_server/ |
H A D | 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;
|
/external/wpa_supplicant_8/wpa_supplicant/src/eap_server/ |
H A D | 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;
|
/external/webkit/Source/WebCore/bridge/qt/ |
H A D | qt_runtime.h | 208 static QMultiMap<QObject *, QtConnectionObject *> connections; member in class:JSC::Bindings::QtRuntimeConnectionMethod
|
/external/chromium/chrome/common/extensions/docs/examples/apps/hello-python/httplib2/ |
H A D | __init__.py | 799 self.connections = {} 1005 if conn_key in self.connections: 1006 conn = self.connections[conn_key] 1012 conn = self.connections[conn_key] = connection_type(authority, key_file=certs[0][0], 1015 conn = self.connections[conn_key] = connection_type(authority, timeout=self.timeout, proxy_info=self.proxy_info)
|
/external/openssh/contrib/suse/ |
H A D | openssh.spec | 56 two untrusted hosts over an insecure network. X11 connections and 70 two untrusted hosts over an insecure network. X11 connections and
|