| /dports/databases/pgadmin3/pgadmin3-1.22.2/pgadmin/libssh2/ |
| H A D | packet.c | 102 listen_state->host = s; in packet_queue_listener()
103 s += listen_state->host_len; in packet_queue_listener()
104 listen_state->port = _libssh2_ntohu32(s); in packet_queue_listener()
109 listen_state->shost = s; in packet_queue_listener()
110 s += listen_state->shost_len; in packet_queue_listener()
115 listen_state->shost, listen_state->sport, in packet_queue_listener()
116 listen_state->host, listen_state->port); in packet_queue_listener()
129 listen_state->channel = NULL; in packet_queue_listener()
195 p = listen_state->packet; in packet_queue_listener()
219 if (listen_state->channel) { in packet_queue_listener()
[all …]
|
| /dports/security/nmap/nmap-7.91/libssh2/src/ |
| H A D | packet.c | 102 listen_state->host = s; in packet_queue_listener()
103 s += listen_state->host_len; in packet_queue_listener()
104 listen_state->port = _libssh2_ntohu32(s); in packet_queue_listener()
109 listen_state->shost = s; in packet_queue_listener()
110 s += listen_state->shost_len; in packet_queue_listener()
115 listen_state->shost, listen_state->sport, in packet_queue_listener()
116 listen_state->host, listen_state->port); in packet_queue_listener()
129 listen_state->channel = NULL; in packet_queue_listener()
195 p = listen_state->packet; in packet_queue_listener()
219 if(listen_state->channel) { in packet_queue_listener()
[all …]
|
| /dports/devel/upp/upp/uppsrc/Core/SSH/libssh2/ |
| H A D | packet.c | 102 listen_state->host = s; in packet_queue_listener()
103 s += listen_state->host_len; in packet_queue_listener()
104 listen_state->port = _libssh2_ntohu32(s); in packet_queue_listener()
109 listen_state->shost = s; in packet_queue_listener()
110 s += listen_state->shost_len; in packet_queue_listener()
115 listen_state->shost, listen_state->sport, in packet_queue_listener()
116 listen_state->host, listen_state->port); in packet_queue_listener()
129 listen_state->channel = NULL; in packet_queue_listener()
195 p = listen_state->packet; in packet_queue_listener()
219 if (listen_state->channel) { in packet_queue_listener()
[all …]
|
| /dports/devel/gbump/gbump-1.0.1/cargo-crates/libssh2-sys-0.2.13/libssh2/src/ |
| H A D | packet.c | 102 listen_state->host = s; in packet_queue_listener()
103 s += listen_state->host_len; in packet_queue_listener()
104 listen_state->port = _libssh2_ntohu32(s); in packet_queue_listener()
109 listen_state->shost = s; in packet_queue_listener()
110 s += listen_state->shost_len; in packet_queue_listener()
115 listen_state->shost, listen_state->sport, in packet_queue_listener()
116 listen_state->host, listen_state->port); in packet_queue_listener()
129 listen_state->channel = NULL; in packet_queue_listener()
195 p = listen_state->packet; in packet_queue_listener()
219 if(listen_state->channel) { in packet_queue_listener()
[all …]
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libssh2-sys-0.2.23/libssh2/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) { in packet_queue_listener()
119 listen_state->host_len = (uint32_t)temp_len; in packet_queue_listener()
129 listen_state->shost_len = (uint32_t)temp_len; in packet_queue_listener()
138 listen_state->shost, listen_state->sport, in packet_queue_listener()
139 listen_state->host, listen_state->port); in packet_queue_listener()
152 listen_state->channel = NULL; in packet_queue_listener()
174 listen_state->channel = channel; in packet_queue_listener()
218 p = listen_state->packet; in packet_queue_listener()
242 if(listen_state->channel) { in packet_queue_listener()
260 p = listen_state->packet; in packet_queue_listener()
[all …]
|
| /dports/security/libssh2/libssh2-1.10.0/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) {
119 listen_state->host_len = (uint32_t)temp_len;
129 listen_state->shost_len = (uint32_t)temp_len;
138 listen_state->shost, listen_state->sport,
139 listen_state->host, listen_state->port);
152 listen_state->channel = NULL; in Cudd_ApaNumberOfDigits()
174 listen_state->channel = channel; in Cudd_ApaNumberOfDigits()
218 p = listen_state->packet; in Cudd_ApaNumberOfDigits()
242 if(listen_state->channel) { in Cudd_ApaNumberOfDigits()
260 p = listen_state->packet;
[all …]
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/libssh2-sys-0.2.21/libssh2/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) { in packet_queue_listener()
119 listen_state->host_len = (uint32_t)temp_len; in packet_queue_listener()
129 listen_state->shost_len = (uint32_t)temp_len; in packet_queue_listener()
138 listen_state->shost, listen_state->sport, in packet_queue_listener()
139 listen_state->host, listen_state->port); in packet_queue_listener()
152 listen_state->channel = NULL; in packet_queue_listener()
174 listen_state->channel = channel; in packet_queue_listener()
218 p = listen_state->packet; in packet_queue_listener()
242 if(listen_state->channel) { in packet_queue_listener()
260 p = listen_state->packet; in packet_queue_listener()
[all …]
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libssh2-sys-0.2.21/libssh2/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) { in packet_queue_listener()
119 listen_state->host_len = (uint32_t)temp_len; in packet_queue_listener()
129 listen_state->shost_len = (uint32_t)temp_len; in packet_queue_listener()
138 listen_state->shost, listen_state->sport, in packet_queue_listener()
139 listen_state->host, listen_state->port); in packet_queue_listener()
152 listen_state->channel = NULL; in packet_queue_listener()
174 listen_state->channel = channel; in packet_queue_listener()
218 p = listen_state->packet; in packet_queue_listener()
242 if(listen_state->channel) { in packet_queue_listener()
260 p = listen_state->packet; in packet_queue_listener()
[all …]
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/libssh2-sys-0.2.23/libssh2/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) { in packet_queue_listener()
119 listen_state->host_len = (uint32_t)temp_len; in packet_queue_listener()
129 listen_state->shost_len = (uint32_t)temp_len; in packet_queue_listener()
138 listen_state->shost, listen_state->sport, in packet_queue_listener()
139 listen_state->host, listen_state->port); in packet_queue_listener()
152 listen_state->channel = NULL; in packet_queue_listener()
174 listen_state->channel = channel; in packet_queue_listener()
218 p = listen_state->packet; in packet_queue_listener()
242 if(listen_state->channel) { in packet_queue_listener()
260 p = listen_state->packet; in packet_queue_listener()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libssh2-sys/libssh2/src/ |
| H A D | packet.c | 88 if(listen_state->state == libssh2_NB_state_idle) { in packet_queue_listener()
119 listen_state->host_len = (uint32_t)temp_len; in packet_queue_listener()
129 listen_state->shost_len = (uint32_t)temp_len; in packet_queue_listener()
138 listen_state->shost, listen_state->sport, in packet_queue_listener()
139 listen_state->host, listen_state->port); in packet_queue_listener()
152 listen_state->channel = NULL; in packet_queue_listener()
174 listen_state->channel = channel; in packet_queue_listener()
218 p = listen_state->packet; in packet_queue_listener()
242 if(listen_state->channel) { in packet_queue_listener()
260 p = listen_state->packet; in packet_queue_listener()
[all …]
|
| /dports/net/samba412/samba-4.12.15/ctdb/tests/src/ |
| H A D | tunnel_cmd.c | 33 struct listen_state { struct
43 struct listen_state *state = (struct listen_state *)private_data; in listen_callback() argument
67 struct listen_state state; in cmd_listen()
|
| /dports/net/mpich2/mpich2-1.5/src/pm/smpd/sock/iocp/ |
| H A D | smpd_util_sock.c | 959 sock_state_t * listen_state, **listener_copies; in SMPDU_Sock_listen() local
969 listen_state = (sock_state_t*)MPIU_Malloc(sizeof(sock_state_t)); in SMPDU_Sock_listen()
970 init_state_struct(listen_state); in SMPDU_Sock_listen()
983 …if (CreateIoCompletionPort((HANDLE)listen_state->listen_sock, set, (ULONG_PTR)listen_state, g_num_… in SMPDU_Sock_listen()
990 easy_get_sock_info(listen_state->listen_sock, host, port); in SMPDU_Sock_listen()
991 listen_state->user_ptr = user_ptr; in SMPDU_Sock_listen()
992 listen_state->type = SOCKI_LISTENER; in SMPDU_Sock_listen()
993 listen_state->set = set; in SMPDU_Sock_listen()
1001 memcpy(listener_copies[i], listen_state, sizeof(*listen_state)); in SMPDU_Sock_listen()
1014 listen_state->list = listener_copies[g_num_posted_accepts-1]; in SMPDU_Sock_listen()
[all …]
|
| /dports/net/mpich2/mpich2-1.5/src/mpid/common/sock/iocp/ |
| H A D | sock.c | 892 sock_state_t * listen_state, **listener_copies; in MPIDU_Sock_listen() local
905 listen_state = (sock_state_t*)MPIU_Malloc(sizeof(sock_state_t)); in MPIDU_Sock_listen()
906 init_state_struct(listen_state); in MPIDU_Sock_listen()
921 …if (CreateIoCompletionPort((HANDLE)listen_state->listen_sock, set, (ULONG_PTR)listen_state, g_num_… in MPIDU_Sock_listen()
928 easy_get_sock_info(listen_state->listen_sock, host, port); in MPIDU_Sock_listen()
929 listen_state->user_ptr = user_ptr; in MPIDU_Sock_listen()
930 listen_state->type = SOCKI_LISTENER; in MPIDU_Sock_listen()
931 listen_state->set = set; in MPIDU_Sock_listen()
941 memcpy(listener_copies[i], listen_state, sizeof(*listen_state)); in MPIDU_Sock_listen()
956 listen_state->list = listener_copies[g_num_posted_accepts-1]; in MPIDU_Sock_listen()
[all …]
|
| /dports/emulators/qemu/qemu-6.2.0/roms/qemu-palcode/ |
| H A D | hwrpb.h | 178 unsigned long listen_state; member
|
| /dports/math/stanmath/math-4.2.0/test/unit/math/prim/functor/ |
| H A D | mpi_cluster_test.cpp | 43 TEST(mpi_cluster, listen_state) { in TEST() argument
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | memcached.c | 348 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
349 ret = listen_state.disabled; in is_listen_disabled()
356 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
357 ret = listen_state.num_disable; in get_listen_disabled_num()
364 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
365 listen_state.disabled = true; in disable_listen()
366 listen_state.count = 10; in disable_listen()
367 ++listen_state.num_disable; in disable_listen()
5668 listen_state.count -= nr; in dispatch_event_handler()
5669 if (listen_state.count <= 0) { in dispatch_event_handler()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | memcached.c | 383 } listen_state; variable
387 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
388 ret = listen_state.disabled; in is_listen_disabled()
395 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
396 ret = listen_state.num_disable; in get_listen_disabled_num()
402 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
403 listen_state.disabled = true; in disable_listen()
404 listen_state.count = 10; in disable_listen()
405 ++listen_state.num_disable; in disable_listen()
5736 listen_state.count -= nr;
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | memcached.c | 383 } listen_state; variable
387 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
388 ret = listen_state.disabled; in is_listen_disabled()
395 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
396 ret = listen_state.num_disable; in get_listen_disabled_num()
402 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
403 listen_state.disabled = true; in disable_listen()
404 listen_state.count = 10; in disable_listen()
405 ++listen_state.num_disable; in disable_listen()
5736 listen_state.count -= nr;
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | memcached.c | 383 } listen_state; variable
387 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
388 ret = listen_state.disabled; in is_listen_disabled()
395 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
396 ret = listen_state.num_disable; in get_listen_disabled_num()
402 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
403 listen_state.disabled = true; in disable_listen()
404 listen_state.count = 10; in disable_listen()
405 ++listen_state.num_disable; in disable_listen()
5736 listen_state.count -= nr;
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | memcached.c | 384 } listen_state; variable
388 pthread_mutex_lock(&listen_state.mutex); in is_listen_disabled()
389 ret = listen_state.disabled; in is_listen_disabled()
396 pthread_mutex_lock(&listen_state.mutex); in get_listen_disabled_num()
397 ret = listen_state.num_disable; in get_listen_disabled_num()
403 pthread_mutex_lock(&listen_state.mutex); in disable_listen()
404 listen_state.disabled = true; in disable_listen()
405 listen_state.count = 10; in disable_listen()
406 ++listen_state.num_disable; in disable_listen()
5753 listen_state.count -= nr;
[all …]
|