| /dports/net/bredbandskollen/bbk-7b810a6/src/measurement/ |
| H A D | measurementtask.cpp | 14 if (active_connections < no_connections) in checkConnectionCount()
15 dbg_log() << "checkConnectionCount: act=" << active_connections in checkConnectionCount()
19 while (active_connections < no_connections && max_connections) { in checkConnectionCount()
26 if (no_connections && !active_connections) in checkConnectionCount()
31 ++active_connections; in connAdded()
32 log() << "conn added: " << c << " now have " << active_connections; in connAdded()
36 --active_connections; in connRemoved()
37 log() << "conn removed: " << c << " now have " << active_connections; in connRemoved()
|
| H A D | measurementtask.h | 17 active_connections(0), in HttpClientTask()
89 return active_connections; in currentNoConnections()
112 unsigned int no_connections, active_connections, max_connections; variable
|
| /dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/windows/ |
| H A D | win_wait_for.ps1 | 84 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Port … in Get-PortConnections() variable
86 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Addre… in Get-PortConnections() variable
89 if ($null -ne $active_connections) { in Get-PortConnections()
90 foreach ($active_connection in $active_connections) { in Get-PortConnections()
217 $active_connections = Get-PortConnections -hostname $hostname -port $port variable
218 if ($null -eq $active_connections) {
221 } elseif ($active_connections.Count -eq 0) {
228 $connection_info = $active_connections
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/ansible/windows/plugins/modules/ |
| H A D | win_wait_for.ps1 | 84 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Port … in Get-PortConnections() variable
86 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Addre… in Get-PortConnections() variable
89 if ($null -ne $active_connections) { in Get-PortConnections()
90 foreach ($active_connection in $active_connections) { in Get-PortConnections()
217 $active_connections = Get-PortConnections -hostname $hostname -port $port variable
218 if ($null -eq $active_connections) {
221 } elseif ($active_connections.Count -eq 0) {
228 $connection_info = $active_connections
|
| /dports/sysutils/py-ansible-core/ansible-core-2.11.6/test/support/windows-integration/plugins/modules/ |
| H A D | win_wait_for.ps1 | 84 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Port … in Get-PortConnections() variable
86 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Addre… in Get-PortConnections() variable
89 if ($null -ne $active_connections) { in Get-PortConnections()
90 foreach ($active_connection in $active_connections) { in Get-PortConnections()
217 $active_connections = Get-PortConnections -hostname $hostname -port $port variable
218 if ($null -eq $active_connections) {
221 } elseif ($active_connections.Count -eq 0) {
228 $connection_info = $active_connections
|
| /dports/sysutils/py-ansible-base/ansible-base-2.10.15/test/support/windows-integration/plugins/modules/ |
| H A D | win_wait_for.ps1 | 84 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Port … in Get-PortConnections() variable
86 …$active_connections = $conn_info.GetActiveTcpConnections() | Where-Object { $_.LocalEndPoint.Addre… in Get-PortConnections() variable
89 if ($null -ne $active_connections) { in Get-PortConnections()
90 foreach ($active_connection in $active_connections) { in Get-PortConnections()
217 $active_connections = Get-PortConnections -hostname $hostname -port $port variable
218 if ($null -eq $active_connections) {
221 } elseif ($active_connections.Count -eq 0) {
228 $connection_info = $active_connections
|
| /dports/net/bredbandskollen/bbk-7b810a6/src/http/ |
| H A D | httprequestengine.cpp | 161 ++active_connections; in connAdded()
162 dbg_log() << "conn added: " << c << " now have " << active_connections; in connAdded()
166 --active_connections; in connRemoved()
167 dbg_log() << "conn removed: " << c << " now have " << active_connections; in connRemoved()
207 dbg_log() << "checkConnectionCount: act=" << active_connections in checkConnectionCount()
213 for (unsigned int i = active_connections; i < no_connections; ++i) { in checkConnectionCount()
218 if (no_connections && !active_connections) in checkConnectionCount()
|
| /dports/devel/dee/dee-1.2.7/src/ |
| H A D | dee-server.c | 58 GSList *active_connections; member
355 if (priv->active_connections) in dee_server_finalize()
357 g_slist_foreach (priv->active_connections, close_connection, object); in dee_server_finalize()
358 g_slist_free_full (priv->active_connections, g_object_unref); in dee_server_finalize()
359 priv->active_connections = NULL; in dee_server_finalize()
591 priv->active_connections = g_slist_prepend (priv->active_connections, in on_new_connection()
628 element = g_slist_find (priv->active_connections, connection); in on_connection_closed()
636 priv->active_connections = g_slist_delete_link (priv->active_connections, in on_connection_closed()
670 return g_slist_copy (priv->active_connections); in dee_server_get_connections()
681 result = g_new (gchar*, g_slist_length (priv->active_connections) + 1); in dee_server_list_peers()
[all …]
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/networkmanager/impl/ |
| H A D | MultiPeerDownloader2.java | 50 private connectionList active_connections = new connectionList(); field in MultiPeerDownloader2
231 active_connections.add( connection ); in doProcessing()
235 active_connections.remove( connection ); in doProcessing()
271 active_connections.addToStart( entry ); in doProcessing()
285 connectionEntry entry = active_connections.head(); in doProcessing()
287 int num_entries = active_connections.size(); in doProcessing()
349 active_connections.moveToEnd( entry ); in doProcessing()
355 active_connections.remove( entry ); in doProcessing()
385 …str.append( "MPD (" + connections_cow.size() + "/" + active_connections.size() + "/" + idle_connec… in getString()
|
| /dports/www/py-fastapi/fastapi-0.70.0/docs_src/websockets/ |
| H A D | tutorial003.py | 48 self.active_connections: List[WebSocket] = []
52 self.active_connections.append(websocket)
55 self.active_connections.remove(websocket)
61 for connection in self.active_connections:
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/python_functional/src/helpers/loggen/ |
| H A D | loggen.py | 44 rate, interval, permanent, syslog_proto, proxied, sdata, no_framing, active_connections, argument
114 if active_connections is not None:
115 start_parameters.append("--active-connections={}".format(active_connections))
145 …manent=None, syslog_proto=None, proxied=None, sdata=None, no_framing=None, active_connections=None, argument
159 rate, interval, permanent, syslog_proto, proxied, sdata, no_framing, active_connections,
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/loggen/socket_plugin/ |
| H A D | socket_plugin.c | 163 active_thread_count = option->active_connections; in start()
168 for (int j = 0 ; j < option->active_connections; j++) in start()
193 while (connect_finished != option->active_connections + option->idle_connections) in start()
226 for (int j = 0; j < option->active_connections + option->idle_connections; j++) in stop()
240 option->active_connections, in stop()
276 if (connect_finished == option->active_connections + option->idle_connections) in idle_thread_func()
342 if (connect_finished == option->active_connections + option->idle_connections) in active_thread_func()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/loggen/ssl_plugin/ |
| H A D | ssl_plugin.c | 150 active_thread_count = option->active_connections; in start()
156 for (int j =0; j < option->active_connections; j++) in start()
182 while (connect_finished != option->active_connections + option->idle_connections) in start()
216 for (int j = 0; j < option->active_connections + option->idle_connections; j++) in stop()
232 option->active_connections, in stop()
258 if (connect_finished == option->active_connections + option->idle_connections) in idle_thread_func()
345 if (connect_finished == option->active_connections + option->idle_connections) in active_thread_func()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/tests/loggen/ |
| H A D | loggen.c | 54 .active_connections = 1,
96 …{ "active-connections", 0, 0, G_OPTION_ARG_INT, &global_plugin_option.active_connections, "Number …
322 …thread_stat_count = (gint64 *) g_malloc0(global_plugin_option.active_connections * sizeof(gint64)); in init_csv_statistics()
323 …thread_stat_count_last = (gint64 *) g_malloc0(global_plugin_option.active_connections * sizeof(gin… in init_csv_statistics()
328 for (int j=0; j < global_plugin_option.active_connections; j++) in init_csv_statistics()
416 for (int j=0; j < global_plugin_option.active_connections; j++) in print_statistic()
570 read_from_file = init_file_reader(global_plugin_option.active_connections); in main()
588 close_file_reader(global_plugin_option.active_connections); in main()
|
| /dports/devel/py-python-dbusmock/python-dbusmock-0.25.0/dbusmock/templates/ |
| H A D | networkmanager.py | 167 if path not in active_connections:
642 active_connections = NM.Get(MANAGER_IFACE, 'ActiveConnections')
643 active_connections.append(dbus.ObjectPath(active_connection_path))
644 NM.SetProperty(MANAGER_OBJ, MANAGER_IFACE, 'ActiveConnections', active_connections)
722 active_connections = NM.Get(MANAGER_IFACE, 'ActiveConnections')
724 if active_connection_path not in active_connections:
727 active_connections.remove(dbus.ObjectPath(active_connection_path))
728 NM.SetProperty(MANAGER_OBJ, MANAGER_IFACE, 'ActiveConnections', active_connections)
907 active_connections = NM.Get(MANAGER_IFACE, 'ActiveConnections')
909 for ac in active_connections:
[all …]
|
| /dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/src/ |
| H A D | main.rs | 289 let active_connections = globals.tcp_active_connections.clone(); in tcp_acceptor() localVariable
293 let mut active_connections = active_connections.lock(); in tcp_acceptor() localVariable
294 if active_connections.len() >= globals.tcp_max_active_connections as _ { in tcp_acceptor()
295 let tx_oldest = active_connections.pop_back().unwrap(); in tcp_acceptor()
298 active_connections.push_front(tx); in tcp_acceptor()
348 let active_connections = globals.udp_active_connections.clone(); in udp_acceptor() localVariable
363 let mut active_connections = active_connections.lock(); in udp_acceptor() localVariable
364 if active_connections.len() >= globals.tcp_max_active_connections as _ { in udp_acceptor()
365 let tx_oldest = active_connections.pop_back().unwrap(); in udp_acceptor()
368 active_connections.push_front(tx); in udp_acceptor()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/neqo-transport/tests/ |
| H A D | server.rs | 85 assert_eq!(server.active_connections().len(), 1); in duplicate_initial()
109 assert_eq!(server.active_connections().len(), 2); in duplicate_initial_new_path()
131 assert_eq!(server.active_connections().len(), 2); in different_initials_same_path()
148 assert_eq!(server.active_connections().len(), 0); in same_initial_after_connected()
155 assert_eq!(server.active_connections().len(), 1); in same_initial_after_connected()
210 assert_eq!(server.active_connections().len(), 1); in zero_rtt()
239 assert!(server.active_connections().is_empty()); in zero_rtt()
245 let active = server.active_connections(); in zero_rtt()
257 let active = server.active_connections(); in zero_rtt()
391 for server in server.active_connections() { in bad_client_initial()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/neqo-transport/tests/ |
| H A D | server.rs | 85 assert_eq!(server.active_connections().len(), 1); in duplicate_initial()
109 assert_eq!(server.active_connections().len(), 2); in duplicate_initial_new_path()
131 assert_eq!(server.active_connections().len(), 2); in different_initials_same_path()
148 assert_eq!(server.active_connections().len(), 0); in same_initial_after_connected()
155 assert_eq!(server.active_connections().len(), 1); in same_initial_after_connected()
210 assert_eq!(server.active_connections().len(), 1); in zero_rtt()
239 assert!(server.active_connections().is_empty()); in zero_rtt()
245 let active = server.active_connections(); in zero_rtt()
257 let active = server.active_connections(); in zero_rtt()
391 for server in server.active_connections() { in bad_client_initial()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/neqo-transport/tests/ |
| H A D | server.rs | 85 assert_eq!(server.active_connections().len(), 1); in duplicate_initial()
109 assert_eq!(server.active_connections().len(), 2); in duplicate_initial_new_path()
131 assert_eq!(server.active_connections().len(), 2); in different_initials_same_path()
148 assert_eq!(server.active_connections().len(), 0); in same_initial_after_connected()
155 assert_eq!(server.active_connections().len(), 1); in same_initial_after_connected()
210 assert_eq!(server.active_connections().len(), 1); in zero_rtt()
239 assert!(server.active_connections().is_empty()); in zero_rtt()
245 let active = server.active_connections(); in zero_rtt()
257 let active = server.active_connections(); in zero_rtt()
391 for server in server.active_connections() { in bad_client_initial()
|
| /dports/sysutils/tracker/tracker-2.3.4/src/libtracker-miner/ |
| H A D | tracker-miner-online.c | 208 const GPtrArray *active_connections; in find_default_active_connection() local
211 active_connections = nm_client_get_active_connections (client); in find_default_active_connection()
213 for (i = 0; i < active_connections->len; i++) { in find_default_active_connection()
214 active_connection = g_ptr_array_index (active_connections, i); in find_default_active_connection()
|
| /dports/security/libgcrypt/libgcrypt-1.9.4/src/ |
| H A D | gcryptrnd.c | 60 static int active_connections; variable
551 active_connections++; in connection_thread()
558 active_connections--; in connection_thread()
590 active_connections); in handle_signal()
641 if (!active_connections) in serve()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/comm/third_party/libgcrypt/src/ |
| H A D | gcryptrnd.c | 60 static int active_connections; variable
551 active_connections++; in connection_thread()
558 active_connections--; in connection_thread()
590 active_connections); in handle_signal()
641 if (!active_connections) in serve()
|
| /dports/sysutils/py-ansible-base/ansible-base-2.10.15/lib/ansible/modules/ |
| H A D | wait_for.py | 288 active_connections = 0
319 active_connections += 1
320 return active_connections
366 active_connections = 0
391 active_connections += 1
397 return active_connections
|
| /dports/sysutils/py-ansible-core/ansible-core-2.11.6/lib/ansible/modules/ |
| H A D | wait_for.py | 290 active_connections = 0
321 active_connections += 1
322 return active_connections
368 active_connections = 0
393 active_connections += 1
399 return active_connections
|
| /dports/net/erlang-ranch/ranch-1.3.2/src/ |
| H A D | ranch_conns_sup.erl | 23 -export([active_connections/1]).
77 -spec active_connections(pid()) -> non_neg_integer().
78 active_connections(SupPid) -> function
80 catch erlang:send(SupPid, {?MODULE, active_connections, self(), Tag},
135 {?MODULE, active_connections, To, Tag} ->
|