| /dports/net/lambdamoo/MOO-1.8.1/ |
| H A D | net_bsd_lcl.c | 43 static listener *all_listeners = 0; variable
106 l->next = all_listeners; in proto_make_listener()
107 all_listeners = l; in proto_make_listener()
158 for (l = all_listeners, ll = &all_listeners; l; ll = &(l->next), in proto_close_listener()
|
| H A D | net_sysv_lcl.c | 101 static listener *all_listeners = 0; variable
166 l->next = all_listeners; in proto_make_listener()
167 all_listeners = l; in proto_make_listener()
185 for (l = all_listeners; l; l = l->next) in find_listener()
342 for (l = all_listeners, ll = &all_listeners; l; ll = &(l->next), in proto_close_listener()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
| H A D | handle_connections_win.cc | 537 static Listener *all_listeners[MAX_WAIT_HANDLES]; variable
547 all_listeners[n_listeners++]= new Socket_Listener(extra_ip_sock, 0); in network_init_win()
556 all_listeners[n_listeners++]= new Pipe_Listener(); in network_init_win()
563 …all_listeners[n_listeners++]= new Socket_Listener(base_ip_sock, get_threadpool_win_callback_enviro… in network_init_win()
583 HANDLE wait_handle= all_listeners[i]->wait_handle(); in handle_connections_win()
586 DBUG_ASSERT((i == 0) || (all_listeners[i - 1]->wait_handle() != 0)); in handle_connections_win()
589 all_listeners[i]->begin_accept(); in handle_connections_win()
600 all_listeners[idx - LISTENER_START_IDX]->completion_callback(); in handle_connections_win()
606 Listener *listener= all_listeners[i]; in handle_connections_win()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
| H A D | handle_connections_win.cc | 542 Listener* all_listeners[MAX_WAIT_HANDLES]= {}; in handle_connections_win() local
551 all_listeners[n_listeners++]= new Socket_Listener(extra_ip_sock, 0); in handle_connections_win()
560 all_listeners[n_listeners++]= new Pipe_Listener(); in handle_connections_win()
567 …all_listeners[n_listeners++]= new Socket_Listener(base_ip_sock, get_threadpool_win_callback_enviro… in handle_connections_win()
581 HANDLE wait_handle= all_listeners[i]->wait_handle(); in handle_connections_win()
584 DBUG_ASSERT((i == 0) || (all_listeners[i-1]->wait_handle() != 0)); in handle_connections_win()
587 all_listeners[i]->begin_accept(); in handle_connections_win()
598 all_listeners[idx - LISTENER_START_IDX]->completion_callback(); in handle_connections_win()
604 Listener *listener= all_listeners[i]; in handle_connections_win()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
| H A D | handle_connections_win.cc | 542 Listener* all_listeners[MAX_WAIT_HANDLES]= {}; in handle_connections_win() local
551 all_listeners[n_listeners++]= new Socket_Listener(extra_ip_sock, 0); in handle_connections_win()
560 all_listeners[n_listeners++]= new Pipe_Listener(); in handle_connections_win()
567 …all_listeners[n_listeners++]= new Socket_Listener(base_ip_sock, get_threadpool_win_callback_enviro… in handle_connections_win()
581 HANDLE wait_handle= all_listeners[i]->wait_handle(); in handle_connections_win()
584 DBUG_ASSERT((i == 0) || (all_listeners[i-1]->wait_handle() != 0)); in handle_connections_win()
587 all_listeners[i]->begin_accept(); in handle_connections_win()
598 all_listeners[idx - LISTENER_START_IDX]->completion_callback(); in handle_connections_win()
604 Listener *listener= all_listeners[i]; in handle_connections_win()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | handle_connections_win.cc | 537 static Listener *all_listeners[MAX_WAIT_HANDLES]; variable
547 all_listeners[n_listeners++]= new Socket_Listener(extra_ip_sock, 0); in network_init_win()
556 all_listeners[n_listeners++]= new Pipe_Listener(); in network_init_win()
563 …all_listeners[n_listeners++]= new Socket_Listener(base_ip_sock, get_threadpool_win_callback_enviro… in network_init_win()
583 HANDLE wait_handle= all_listeners[i]->wait_handle(); in handle_connections_win()
586 DBUG_ASSERT((i == 0) || (all_listeners[i - 1]->wait_handle() != 0)); in handle_connections_win()
589 all_listeners[i]->begin_accept(); in handle_connections_win()
600 all_listeners[idx - LISTENER_START_IDX]->completion_callback(); in handle_connections_win()
606 Listener *listener= all_listeners[i]; in handle_connections_win()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/master/ |
| H A D | master-settings.c | 281 ARRAY_TYPE(const_string) *all_listeners, in fix_file_listener_paths()
309 array_push_back(all_listeners, &set->path); in fix_file_listener_paths()
315 ARRAY_TYPE(const_string) *all_listeners) in add_inet_listeners()
326 array_push_back(all_listeners, &str); in add_inet_listeners()
418 ARRAY_TYPE(const_string) all_listeners; in master_settings_verify()
510 t_array_init(&all_listeners, 64); in master_settings_verify()
595 set, &all_listeners, error_r)) { in master_settings_verify()
601 set, &all_listeners, error_r)) { in master_settings_verify()
606 add_inet_listeners(&service->inet_listeners, &all_listeners); in master_settings_verify()
640 array_sort(&all_listeners, i_strcmp_p); in master_settings_verify()
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | LibrdkafkaTestApp.py | 120 … all_listeners = (','.join(cluster.get_all('advertised.listeners', '', KafkaBrokerApp))).split(',')
121 … bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(self.security_protocol)])
123 bootstrap_servers = all_listeners[0]
124 … will fail (which might be the intention)' % (self.security_protocol, all_listeners, bootstrap_ser…
|
| H A D | cluster_testing.py | 81 … all_listeners = (','.join(self.get_all('advertised_listeners', '', KafkaBrokerApp))).split(',')
82 … return ','.join([x for x in all_listeners if x.startswith(self.conf.get('security.protocol'))])
|
| H A D | interactive_broker_version.py | 128 all_listeners = (','.join(cluster.get_all('listeners', '', KafkaBrokerApp))).split(',')
129 bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(security_protocol)])
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | LibrdkafkaTestApp.py | 120 … all_listeners = (','.join(cluster.get_all('advertised.listeners', '', KafkaBrokerApp))).split(',')
121 bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(security_protocol)])
123 bootstrap_servers = all_listeners[0]
124 …tests will fail (which might be the intention)' % (security_protocol, all_listeners, bootstrap_ser…
|
| H A D | cluster_testing.py | 81 … all_listeners = (','.join(self.get_all('advertised_listeners', '', KafkaBrokerApp))).split(',')
82 … return ','.join([x for x in all_listeners if x.startswith(self.conf.get('security.protocol'))])
|
| H A D | interactive_broker_version.py | 128 all_listeners = (','.join(cluster.get_all('listeners', '', KafkaBrokerApp))).split(',')
129 bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(security_protocol)])
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | LibrdkafkaTestApp.py | 120 … all_listeners = (','.join(cluster.get_all('advertised.listeners', '', KafkaBrokerApp))).split(',')
121 … bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(self.security_protocol)])
123 bootstrap_servers = all_listeners[0]
124 … will fail (which might be the intention)' % (self.security_protocol, all_listeners, bootstrap_ser…
|
| H A D | cluster_testing.py | 81 … all_listeners = (','.join(self.get_all('advertised_listeners', '', KafkaBrokerApp))).split(',')
82 … return ','.join([x for x in all_listeners if x.startswith(self.conf.get('security.protocol'))])
|
| H A D | interactive_broker_version.py | 128 all_listeners = (','.join(cluster.get_all('listeners', '', KafkaBrokerApp))).split(',')
129 bootstrap_servers = ','.join([x for x in all_listeners if x.startswith(security_protocol)])
|
| /dports/security/tor-devel/tor-0.4.7.2-alpha/src/core/or/ |
| H A D | channel.c | 99 static smartlist_t *all_listeners = NULL; variable
498 if (!all_listeners) all_listeners = smartlist_new(); in channel_listener_register()
499 smartlist_add(all_listeners, chan_l); in channel_listener_register()
542 if (all_listeners) smartlist_remove(all_listeners, chan_l); in channel_listener_unregister()
2104 if (all_listeners && smartlist_len(all_listeners) > 0) { in channel_listener_dumpstats()
2107 smartlist_len(all_listeners)); in channel_listener_dumpstats()
2115 SMARTLIST_FOREACH(all_listeners, channel_listener_t *, chan_l, in channel_listener_dumpstats()
2287 if (all_listeners) { in channel_free_all()
2288 channel_listener_free_list(all_listeners, 1); in channel_free_all()
2289 smartlist_free(all_listeners); in channel_free_all()
[all …]
|
| /dports/security/tor/tor-0.4.6.8/src/core/or/ |
| H A D | channel.c | 99 static smartlist_t *all_listeners = NULL; variable
498 if (!all_listeners) all_listeners = smartlist_new(); in channel_listener_register()
499 smartlist_add(all_listeners, chan_l); in channel_listener_register()
542 if (all_listeners) smartlist_remove(all_listeners, chan_l); in channel_listener_unregister()
2104 if (all_listeners && smartlist_len(all_listeners) > 0) { in channel_listener_dumpstats()
2107 smartlist_len(all_listeners)); in channel_listener_dumpstats()
2115 SMARTLIST_FOREACH(all_listeners, channel_listener_t *, chan_l, in channel_listener_dumpstats()
2287 if (all_listeners) { in channel_free_all()
2288 channel_listener_free_list(all_listeners, 1); in channel_free_all()
2289 smartlist_free(all_listeners); in channel_free_all()
[all …]
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/tag/impl/ |
| H A D | TagTypeBase.java | 379 List<List<TagListener>> all_listeners = new ArrayList<List<TagListener>>(); in taggableSync() local
383 all_listeners.addAll( tag_listeners.values()); in taggableSync()
386 for ( List<TagListener> listeners: all_listeners ){ in taggableSync()
|
| /dports/mail/dovecot/dovecot-2.3.17/src/config/ |
| H A D | all-settings.c | 3478 ARRAY_TYPE(const_string) *all_listeners, in fix_file_listener_paths()
3506 array_push_back(all_listeners, &set->path); in fix_file_listener_paths()
3512 ARRAY_TYPE(const_string) *all_listeners) in add_inet_listeners()
3523 array_push_back(all_listeners, &str); in add_inet_listeners()
3615 ARRAY_TYPE(const_string) all_listeners; in master_settings_verify()
3707 t_array_init(&all_listeners, 64); in master_settings_verify()
3792 set, &all_listeners, error_r)) { in master_settings_verify()
3798 set, &all_listeners, error_r)) { in master_settings_verify()
3803 add_inet_listeners(&service->inet_listeners, &all_listeners); in master_settings_verify()
3837 array_sort(&all_listeners, i_strcmp_p); in master_settings_verify()
[all …]
|