Home
last modified time | relevance | path

Searched refs:connections (Results 1 - 25 of 56) sorted by relevance

123

/third_party/node/test/parallel/
H A Dtest-https-close.js14 const connections = {};
26 delete connections[key];
28 connections[key] = connection;
34 for (const key in connections) {
35 connections[key].destroy();
36 delete connections[key];
H A Dtest-process-getactiveresources-track-active-handles.js7 const connections = [];
12 connections.push(c);
35 clients.length + connections.length);
38 connections.forEach((item) => item.end());
H A Dtest-net-server-max-connections-close-makes-more-available.js8 // Open 2 connections (connection 0 and connection 1).
12 // Open 2 more connections (connection 2 and 3).
16 const connections = [];
46 connections[index] = connection;
53 connections[index].on('end', function() {
56 connections[index].end();
81 // Confirm that all connections tried to send data...
83 // ...but that only connections 0 and 2 were successful.
H A Dtest-process-getactivehandles.js7 const connections = [];
12 connections.push(c);
40 connections.forEach(function(item) {
H A Dtest-https-server-close-all.js19 let connections = 0;
31 connections++;
51 assert.strictEqual(connections, 2);
H A Dtest-https-server-close-idle.js19 let connections = 0;
31 connections++;
53 assert.strictEqual(connections, 2);
H A Dtest-internal-socket-list-receive.js52 // Verify that the connections count is added and an "empty" event
59 assert.strictEqual(list.connections, 0);
62 assert.strictEqual(list.connections, 1);
67 assert.strictEqual(list.connections, 0);
H A Dtest-child-process-fork-net-server.js97 // We expect 4 connections and close events.
98 const connections = new Countdown(4, () => countdown.dec());
111 connections.dec();
127 // Make connections.
141 connections.dec();
H A Dtest-tls-add-context.js23 let connections = 0;
26 if (++connections === 3) {
/third_party/pulseaudio/src/pulsecore/
H A Dprotocol-cli.c35 /* Don't allow more than this many concurrent connections */
42 pa_idxset *connections; member
49 pa_idxset_remove_by_data(p->connections, c, NULL); in cli_unlink()
67 if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) { in pa_cli_protocol_connect()
68 pa_log("Warning! Too many connections (%u), dropping incoming connection.", MAX_CONNECTIONS); in pa_cli_protocol_connect()
76 pa_idxset_put(p->connections, c, NULL); in pa_cli_protocol_connect()
86 while ((c = pa_idxset_iterate(p->connections, &state, NULL))) in pa_cli_protocol_disconnect()
99 p->connections = pa_idxset_new(NULL, NULL); in cli_protocol_new()
132 while ((c = pa_idxset_first(p->connections, NULL))) in pa_cli_protocol_unref()
135 pa_idxset_free(p->connections, NUL in pa_cli_protocol_unref()
[all...]
H A Dprotocol-http.c46 /* Don't allow more than this many concurrent connections */
104 pa_idxset *connections; member
137 pa_idxset_remove_by_data(c->protocol->connections, c, NULL); in connection_unlink()
692 if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) { in pa_http_protocol_connect()
693 pa_log("Warning! Too many connections (%u), dropping incoming connection.", MAX_CONNECTIONS); in pa_http_protocol_connect()
721 pa_idxset_put(p->connections, c, NULL); in pa_http_protocol_connect()
737 PA_IDXSET_FOREACH(c, p->connections, idx) in pa_http_protocol_disconnect()
750 p->connections = pa_idxset_new(NULL, NULL); in http_protocol_new()
784 while ((c = pa_idxset_first(p->connections, NULL))) in pa_http_protocol_unref()
787 pa_idxset_free(p->connections, NUL in pa_http_protocol_unref()
[all...]
H A Dprotocol-simple.c45 /* Don't allow more than this many concurrent connections */
75 pa_idxset *connections; member
128 pa_idxset_remove_by_data(c->protocol->connections, c, NULL); in connection_unlink()
483 if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) { in pa_simple_protocol_connect()
484 pa_log("Warning! Too many connections (%u), dropping incoming connection.", MAX_CONNECTIONS); in pa_simple_protocol_connect()
626 pa_idxset_put(p->connections, c, NULL); in pa_simple_protocol_connect()
641 while ((c = pa_idxset_iterate(p->connections, &state, NULL))) in pa_simple_protocol_disconnect()
654 p->connections = pa_idxset_new(NULL, NULL); in simple_protocol_new()
687 while ((c = pa_idxset_first(p->connections, NULL))) in pa_simple_protocol_unref()
690 pa_idxset_free(p->connections, NUL in pa_simple_protocol_unref()
[all...]
H A Dprotocol-dbus.c42 pa_hashmap *connections; /* DBusConnection -> struct connection_entry */ member
128 p->connections = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func); in dbus_protocol_new()
167 pa_assert(pa_hashmap_isempty(p->connections)); in pa_dbus_protocol_unref()
171 pa_hashmap_free(p->connections); in pa_dbus_protocol_unref()
614 PA_HASHMAP_FOREACH(conn_entry, p->connections, state) in register_object()
816 PA_HASHMAP_FOREACH(conn_entry, p->connections, state) in unregister_object()
900 if (pa_hashmap_get(p->connections, conn)) in pa_dbus_protocol_register_connection()
913 pa_hashmap_put(p->connections, conn, conn_entry); in pa_dbus_protocol_register_connection()
947 if (!(conn_entry = pa_hashmap_remove(p->connections, conn))) in pa_dbus_protocol_unregister_connection()
966 if (!(conn_entry = pa_hashmap_get(p->connections, con in pa_dbus_protocol_get_client()
[all...]
/third_party/node/lib/internal/
H A Dsocket_list.js63 this.connections = 0;
81 if (this.connections === 0) return onempty(this);
90 count: this.connections,
97 this.connections++;
101 this.connections--;
103 if (this.connections === 0) this.emit('empty', this);
/third_party/skia/third_party/externals/microhttpd/src/examples/
H A Dmhd2spdy_spdy.h74 struct SPDY_Connection *connections[],
83 struct SPDY_Connection *connections[],
90 struct SPDY_Connection *connections[],
98 struct SPDY_Connection *connections[],
H A Dmhd2spdy_spdy.c911 struct SPDY_Connection *connections[],
942 connections[*real_size] = glob_opt.spdy_connection;
971 connections[*real_size] = connection;
986 struct SPDY_Connection *connections[], in spdy_get_selectfdset()
1014 connections[*real_size] = glob_opt.spdy_connection; in spdy_get_selectfdset()
1041 connections[*real_size] = connection; in spdy_get_selectfdset()
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) spdy_get_selectfdset() 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) spdy_run_select() argument
[all...]
H A Dmhd2spdy.c80 struct SPDY_Connection *connections[MAX_SPDY_CONNECTIONS]; in run_everything() local
163 connections, MAX_SPDY_CONNECTIONS, &spdy_npollfds); in run_everything()
185 spdy_run_select(&rs, &ws, &es, connections, spdy_npollfds); in run_everything()
/third_party/node/benchmark/http/
H A Dincoming_headers.js6 connections: [50], // Concurrent connections
12 function main({ connections, headers, w, duration }) {
35 connections,
/third_party/node/benchmark/async_hooks/
H A Dhttp-server.js6 connections: [50, 500],
10 function main({ asyncHooks, connections, duration }) {
35 connections,
H A Dasync-resource-vs-destroy.js20 connections: 500,
171 function main({ type, asyncMethod, connections, duration, path }) {
180 connections,
/third_party/curl/tests/libtest/
H A Dlib1533.c105 long connections = 0; in perform_and_check_connections() local
113 res = curl_easy_getinfo(curl, CURLINFO_NUM_CONNECTS, &connections); in perform_and_check_connections()
119 fprintf(stderr, "%s: expected: %ld connections; actual: %ld connections\n", in perform_and_check_connections()
120 description, expected_connections, connections); in perform_and_check_connections()
122 if(connections != expected_connections) { in perform_and_check_connections()
/third_party/node/test/pummel/
H A Dtest-net-many-clients.js47 client.connections = 0;
54 client.connections += 1;
80 if (this.connections < connections_per_client) {
/third_party/node/benchmark/diagnostics_channel/
H A Dhttp.js12 connections: [50, 500],
17 function main({ apm, connections, duration, type, len, chunks, chunkedEnc }) {
26 connections,
/third_party/pulseaudio/src/modules/dbus/
H A Dmodule-dbus-protocol.c71 pa_idxset *connections; member
116 pa_idxset_remove_by_data(conn->server->userdata->connections, conn, NULL); in client_kill_cb()
211 pa_idxset_put(s->userdata->connections, c, NULL); in connection_new_cb()
498 /* Frees dead client connections. */
504 PA_IDXSET_FOREACH(conn, u->connections, idx) { in cleanup_cb()
506 pa_idxset_remove_by_data(u->connections, conn, NULL); in cleanup_cb()
549 pa_log("Starting the D-Bus server for remote connections failed."); in pa__init()
553 u->connections = pa_idxset_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func); in pa__init()
585 if (u->connections) in pa__done()
586 pa_idxset_free(u->connections, (pa_free_cb_ in pa__done()
[all...]
/third_party/libuv/test/
H A Dtest-pipe-connect-multiple.c41 static uv_pipe_t connections[NUM_CLIENTS]; variable
49 conn = &connections[connection_cb_called]; in connection_cb()
115 conn = &connections[connection_cb_called]; in connection_cb2()

Completed in 10 milliseconds

123