/external/autotest/frontend/ |
H A D | setup_django_environment.py | 12 from django.db import connections namespace 14 connections[name].cursor() 15 connections[name].connection.autocommit(True)
|
H A D | setup_test_environment.py | 18 from django.db import connections namespace 21 connection = connections['default'] 22 connection_readonly = connections['readonly'] 23 connection_global = connections['global'] 24 connection_server = connections['server']
|
/external/libgdx/gdx/src/com/badlogic/gdx/net/ |
H A D | NetJavaImpl.java | 123 final ObjectMap<HttpRequest, HttpURLConnection> connections;
field in class:NetJavaImpl 128 connections = new ObjectMap<HttpRequest, HttpURLConnection>();
242 connections.remove(httpRequest);
248 connections.put(httpRequest, connection);
|
/external/libmicrohttpd/src/examples/ |
H A D | mhd2spdy.c | 80 struct SPDY_Connection *connections[MAX_SPDY_CONNECTIONS]; local 163 connections, MAX_SPDY_CONNECTIONS, &spdy_npollfds); 185 spdy_run_select(&rs, &ws, &es, connections, spdy_npollfds);
|
H A D | mhd2spdy_spdy.c | 911 struct SPDY_Connection *connections[], 942 connections[*real_size] = glob_opt.spdy_connection; 971 connections[*real_size] = connection; 986 struct SPDY_Connection *connections[], 1014 connections[*real_size] = glob_opt.spdy_connection; 1041 connections[*real_size] = connection; 1057 struct SPDY_Connection *connections[], 1066 // PRINT_INFO2("exec about to be called for %s", connections[i]->host); 1069 ret = spdy_exec_io(connections[i]); 1079 glob_opt.streams_opened -= connections[ 983 spdy_get_selectfdset(fd_set * read_fd_set, fd_set * write_fd_set, fd_set * except_fd_set, struct SPDY_Connection *connections[], unsigned int max_size, nfds_t *real_size) argument 1108 spdy_run_select(fd_set * read_fd_set, fd_set * write_fd_set, fd_set * except_fd_set, struct SPDY_Connection *connections[], int size) argument [all...] |
/external/autotest/contrib/ |
H A D | db_cleanup.py | 16 from django.db import connections, transaction namespace 58 cursor = connections['default'].cursor()
|
/external/autotest/tko/ |
H A D | site_parse_unittest.py | 27 from django.db import connections namespace 135 for query in connections[database].queries:
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | ConnectionPool.java | 32 * Manages reuse of HTTP and SPDY connections for reduced network latency. HTTP 35 * which connections to keep open for future use. 40 * <li>{@code http.keepAlive} true if HTTP and SPDY connections should be 42 * <li>{@code http.maxConnections} maximum number of idle connections to 51 * parameters do so before making HTTP connections, and that this class is 74 /** The maximum number of idle connections for each address. */ 78 private final LinkedList<Connection> connections = new LinkedList<>(); field in class:ConnectionPool 81 * A background thread is used to cleanup expired connections. There will be, at most, a single 110 /** Returns total number of connections in the pool. */ 112 return connections [all...] |
/external/chromium-trace/catapult/telemetry/third_party/tsproxy/ |
H A D | tsproxy.py | 33 connections = {} variable 69 global connections 72 if connection_id in connections and self.peer in connections[connection_id]: 86 global connections 107 if connection_id in connections: 108 if self.peer in connections[connection_id]: 112 connections[connection_id][self.peer].handle_message(self.next_message) 114 # Clean up any disconnected connections 116 connections[connection_i [all...] |
/external/dbus/bus/ |
H A D | stats.c | 186 BusConnections *connections; local 194 connections = bus_transaction_get_connections (transaction); 217 bus_connections_get_n_active (connections)) || 219 bus_connections_get_n_incomplete (connections)) || 221 bus_connections_get_total_match_rules (connections)) || 223 bus_connections_get_peak_match_rules (connections)) || 225 bus_connections_get_peak_match_rules_per_conn (connections)) || 227 bus_connections_get_total_bus_names (connections)) || 229 bus_connections_get_peak_bus_names (connections)) || 231 bus_connections_get_peak_bus_names_per_conn (connections))) [all...] |
H A D | bus.c | 62 BusConnections *connections; member in struct:BusContext 174 if (!bus_connections_setup_connection (context->connections, new_connection)) 655 * inotify, connections to SELinux, etc. 829 context->connections = bus_connections_new (context); 830 if (context->connections == NULL) 1073 if (context->connections) 1075 bus_connections_unref (context->connections); 1076 context->connections = NULL; 1180 return context->connections; 1528 /* Policy for inactive connections i [all...] |
H A D | driver.c | 254 BusConnections *connections; local 269 * incomplete connections. It's even OK if the connection wants to 272 connections = bus_connection_get_connections (connection); 273 if (!bus_connections_check_limits (connections, connection,
|
/external/jetty/src/java/org/eclipse/jetty/websocket/ |
H A D | WebSocketFactory.java | 43 * Factory to create WebSocket connections 48 private final Queue<WebSocketServletConnection> connections = new ConcurrentLinkedQueue<WebSocketServletConnection>(); field in class:WebSocketFactory 452 return isRunning() && connections.add(connection); 457 return connections.remove(connection); 462 for (WebSocketServletConnection connection : connections)
|
H A D | WebSocketClientFactory.java | 71 private final Queue<WebSocketConnection> connections = new ConcurrentLinkedQueue<WebSocketConnection>(); field in class:WebSocketClientFactory 257 return isRunning() && connections.add(connection); 262 return connections.remove(connection); 267 for (WebSocketConnection connection : connections)
|
/external/libevent/ |
H A D | evrpc-internal.h | 90 struct evconq connections; member in struct:evrpc_pool
|
H A D | http-internal.h | 92 /* for server connections, the http server they are connected with */ 119 /* both the http server as well as the rpc system need to queue connections */ 145 /* All live connections on this host. */ 146 struct evconq connections; member in struct:evhttp
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
H A D | ConnectionPoolTest.java | 242 // Allow enough time to pass so that the connections are now expired. 246 // The connections must be cleaned up. 443 // Add 3 connections to the pool. 465 // Now let enough time pass for the connections to expire. 468 // All remaining connections should be removed. 476 // Hit the max idle connections limit of 2. 552 private void assertPooled(ConnectionPool pool, Connection... connections) throws Exception { argument 553 assertEquals(Arrays.asList(connections), pool.getConnections());
|
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/bluetooth/ |
H A D | BluetoothFacade.java | 59 private Map<String, BluetoothConnection> connections = field in class:BluetoothFacade 199 @Rpc(description = "Requests that the device be discoverable for Bluetooth connections.") 418 for (Map.Entry<String, BluetoothConnection> entry : connections.entrySet()) { 422 connections.clear();
|
H A D | BluetoothRfcommFacade.java | 64 connections = new HashMap<String, BluetoothConnection>(); field in class:BluetoothRfcommFacade 79 conn = connections.get(connID); 80 } else if (connections.size() == 1) { 81 conn = (BluetoothConnection) connections.values().toArray()[0]; 91 connections.put(uuid, conn); 140 @Rpc(description = "Returns active Bluetooth connections.") 143 for (Map.Entry<String, BluetoothConnection> entry : connections.entrySet()) { 183 connections.remove(conn.getUUID()); 198 connections.remove(conn.getUUID()); 216 connections [all...] |
/external/webrtc/webrtc/base/ |
H A D | httpserver.cc | 80 std::list<Connection*> connections; local 83 connections.push_back(it->second); 85 for (std::list<Connection*>::const_iterator it = connections.begin(); 86 it != connections.end(); ++it) {
|
/external/webrtc/webrtc/p2p/base/ |
H A D | p2ptransportchannel.h | 13 // connections which are combinations of candidates from each end (Alice and 15 // Bob are used to make a connection, repeat to make many connections). 17 // When all of the available connections become invalid (non-writable), we 18 // kick off a process of determining more candidates and more connections. 174 const std::vector<Connection*>& connections() const { return connections_; } function in class:cricket::P2PTransportChannel
|
/external/autotest/frontend/afe/ |
H A D | model_logic.py | 8 from django.db import connections namespace 317 cursor = connections[query_set.db].cursor() 429 cursor = connections[related_model.objects.db].cursor()
|
/external/webrtc/webrtc/p2p/client/ |
H A D | basicportallocator.cc | 527 // creating candidate pairs (connections) and issue connectivity checks. 673 std::vector<Connection*> connections; local 682 for (iter = ports[i]->connections().begin(); 683 iter != ports[i]->connections().end(); 685 connections.push_back(iter->second); 690 << connections.size() << " connections"; 692 for (size_t i = 0; i < connections.size(); ++i) 693 connections[i]->Destroy(); 695 if (running_ || (ports.size() > 0) || (connections [all...] |
/external/wpa_supplicant_8/hostapd/src/eap_server/ |
H A D | tncs.c | 99 struct tncs_data *connections; member in struct:tncs_global 128 tncs = tncs_global_data->connections; 1077 tncs->next = tncs_global_data->connections; 1078 tncs_global_data->connections = tncs; 1096 conn = tncs_global_data->connections; 1102 tncs_global_data->connections = tncs->next;
|
/external/wpa_supplicant_8/src/eap_server/ |
H A D | tncs.c | 99 struct tncs_data *connections; member in struct:tncs_global 128 tncs = tncs_global_data->connections; 1077 tncs->next = tncs_global_data->connections; 1078 tncs_global_data->connections = tncs; 1096 conn = tncs_global_data->connections; 1102 tncs_global_data->connections = tncs->next;
|