| /third_party/boost/libs/signals2/test/ |
| D | deletion_test.cpp | 17 static boost::signals2::connection connections[5]; variable
26 connections[idx].disconnect(); in operator ()()
46 connections[0] = s0.connect(remove_connection(0)); in test_remove_self()
47 connections[1] = s0.connect(remove_connection(1)); in test_remove_self()
48 connections[2] = s0.connect(remove_connection(2, 2)); in test_remove_self()
49 connections[3] = s0.connect(remove_connection(3)); in test_remove_self()
64 connections[0] = s0.connect(remove_connection(0)); in test_remove_self()
65 connections[1] = s0.connect(remove_connection(1)); in test_remove_self()
66 connections[2] = s0.connect(remove_connection(2)); in test_remove_self()
67 connections[3] = s0.connect(remove_connection(3, 3)); in test_remove_self()
[all …]
|
| D | shared_connection_block_test.cpp | 20 static boost::array<boost::signals2::connection, 4> connections; variable
39 for(unsigned i = 0; i < connections.size(); ++i) in BOOST_AUTO_TEST_CASE()
41 connections.at(i) = s0.connect(test_slot(i)); in BOOST_AUTO_TEST_CASE()
47 boost::signals2::shared_connection_block block(connections.at(2)); in BOOST_AUTO_TEST_CASE()
61 const boost::signals2::connection conn = connections.at(1); in BOOST_AUTO_TEST_CASE()
77 boost::signals2::shared_connection_block block(connections.at(3), false); in BOOST_AUTO_TEST_CASE()
101 boost::signals2::shared_connection_block block2(connections.at(0)); in BOOST_AUTO_TEST_CASE()
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | protocol-cli.c | 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()
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, NULL); in pa_cli_protocol_unref()
|
| /third_party/node/test/parallel/ |
| D | test-https-close.js | 14 const connections = {}; constant
26 delete connections[key];
28 connections[key] = connection;
34 for (const key in connections) {
35 connections[key].destroy();
36 delete connections[key];
|
| D | test-net-stream.js | 34 s.server.connections = 10;
37 assert.strictEqual(s.server.connections, 10);
39 assert.strictEqual(s.server.connections, 9);
41 assert.strictEqual(s.server.connections, 9);
72 assert.strictEqual(server.connections, 0);
|
| D | test-net-pause-resume-connecting.js | 27 let connections = 0; variable
34 connections++;
37 if (connections === 5)
93 assert.strictEqual(connections, 5);
|
| D | test-net-server-max-connections-close-makes-more-available.js | 16 const connections = []; variable
46 connections[index] = connection;
53 connections[index].on('end', function() {
56 connections[index].end();
|
| D | test-process-getactivehandles.js | 7 const connections = []; variable
12 connections.push(c);
40 connections.forEach(function(item) {
|
| /third_party/node/lib/internal/ |
| D | socket_list.js | 63 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/glib/gio/ |
| D | gdbusinterfaceskeleton.c | 51 GSList *connections; /* List of ConnectionData */ member
105 while (interface->priv->connections != NULL) in G_DEFINE_ABSTRACT_TYPE_WITH_CODE()
107 ConnectionData *data = interface->priv->connections->data; in G_DEFINE_ABSTRACT_TYPE_WITH_CODE()
720 interface_->priv->connections = g_slist_append (interface_->priv->connections, data); in add_connection_locked()
735 for (l = interface_->priv->connections; l != NULL; l = l->next) in remove_connection_locked()
742 interface_->priv->connections = g_slist_delete_link (interface_->priv->connections, l); in remove_connection_locked()
785 if (interface_->priv->connections != NULL) in g_dbus_interface_skeleton_get_connection()
787 data = interface_->priv->connections->data; in g_dbus_interface_skeleton_get_connection()
813 GList *connections; in g_dbus_interface_skeleton_get_connections() local
820 connections = NULL; in g_dbus_interface_skeleton_get_connections()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/sys/dvb/ |
| D | camtransport.c | 138 tl->connections = g_hash_table_new_full (g_direct_hash, g_direct_equal, in cam_tl_new()
147 g_hash_table_destroy (tl->connections); in cam_tl_destroy()
303 connection = g_hash_table_lookup (tl->connections, in cam_tl_read_tpdu_next()
376 g_hash_table_insert (tl->connections, GINT_TO_POINTER (conn->id), conn); in cam_tl_create_connection()
431 g_hash_table_remove (tl->connections, in handle_control_tpdu()
491 GList *connections = NULL; in cam_tl_read_all() local
526 connections = NULL; in cam_tl_read_all()
527 g_hash_table_foreach (tl->connections, in cam_tl_read_all()
528 foreach_connection_get, &connections); in cam_tl_read_all()
530 for (walk = connections; walk; walk = walk->next) { in cam_tl_read_all()
[all …]
|
| /third_party/node/test/pummel/ |
| D | test-http-upload-timeout.js | 29 let connections = 0; variable
37 connections--;
40 if (connections === 0) {
49 connections++;
|
| D | test-net-many-clients.js | 47 client.connections = 0;
54 client.connections += 1;
80 if (this.connections < connections_per_client) {
|
| /third_party/skia/third_party/externals/microhttpd/src/examples/ |
| D | mhd2spdy_spdy.h | 74 struct SPDY_Connection *connections[],
83 struct SPDY_Connection *connections[],
90 struct SPDY_Connection *connections[],
98 struct SPDY_Connection *connections[],
|
| D | mhd2spdy_spdy.c | 986 struct SPDY_Connection *connections[], in spdy_get_selectfdset() argument
1014 connections[*real_size] = glob_opt.spdy_connection; in spdy_get_selectfdset()
1041 connections[*real_size] = connection; in spdy_get_selectfdset()
1111 struct SPDY_Connection *connections[], in spdy_run_select() argument
1120 …if(FD_ISSET(connections[i]->fd, read_fd_set) || FD_ISSET(connections[i]->fd, write_fd_set) || FD_I… in spdy_run_select()
1123 ret = spdy_exec_io(connections[i]); in spdy_run_select()
1127 glob_opt.streams_opened -= connections[i]->streams_opened; in spdy_run_select()
1128 if(connections[i] == glob_opt.spdy_connection) in spdy_run_select()
1134 … DLL_remove(glob_opt.spdy_connections_head, glob_opt.spdy_connections_tail, connections[i]); in spdy_run_select()
1138 spdy_free_connection(connections[i]); in spdy_run_select()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-stress/ |
| D | README.md | 4 SS connections and a budget of sequential connections.
7 SS connections one after the other.
21 --budget <count>|Each fork sequentially does this many SS connections (default 1)|
|
| /third_party/node/benchmark/async_hooks/ |
| D | http-server.js | 6 connections: [50, 500], property
10 function main({ asyncHooks, connections, duration }) { property
35 connections, property
|
| /third_party/node/benchmark/http/ |
| D | incoming_headers.js | 6 connections: [50], // Concurrent connections property
12 function main({ connections, headers, w, duration }) { property
35 connections, property
|
| /third_party/boost/libs/asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 27 friend class connections;
56 class connections class
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections() function in connections
78 for co_await (tcp::socket s : connections(acceptor)) in listener()
|
| /third_party/boost/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| D | range_based_for.cpp | 27 friend class connections;
56 class connections class
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections() function in connections
78 for co_await (tcp::socket s : connections(acceptor)) in listener()
|
| /third_party/iptables/extensions/ |
| D | libxt_connlimit.man | 1 Allows you to restrict the number of parallel connections to a server per
5 Match if the number of existing connections is below or equal \fIn\fP.
8 Match if the number of existing connections is above \fIn\fP.
24 # allow 2 telnet connections per client host
40 # Limit the number of connections to a particular host:
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/ |
| D | README.md | 14 However it does it for 8 client connections concurrently.
20 -c <conns>|Count of simultaneous connections (default 8)
21 -s|Stagger the connections by 100ms, the last by 1s
|
| /third_party/libwebsockets/READMEs/ |
| D | README.routing.md | 10 connections quickly is a given. But POSIX sockets do not act like
16 table relates to existing connections, dynamically.
31 Both server and client connections now store their peer sockaddr in the
38 removing the highest priority gateway route, all connections to a peer
39 without a net route match are invalidated. However connections with
|
| /third_party/libwebsockets/lib/core-net/ |
| D | README.md | 10 connections to the same place by sharing any existing connection and its tls
13 There are two basic approaches, for h1 additional connections of the same type
25 connections themselves can register on as "active client connections".
55 h2 connections act the same as h1 before the initial connection has been made,
56 but once it is made all the queued connections join the network connection as
|
| /third_party/curl/tests/libtest/ |
| D | lib1533.c | 103 long connections = 0; in perform_and_check_connections() local
111 res = curl_easy_getinfo(curl, CURLINFO_NUM_CONNECTS, &connections); in perform_and_check_connections()
118 description, expected_connections, connections); in perform_and_check_connections()
120 if(connections != expected_connections) { in perform_and_check_connections()
|