/dports/net/haproxy20/haproxy-2.0.26/src/ |
H A D | xprt_handshake.c | 19 struct wait_event *recv_wait; member 91 if (ctx->recv_wait) { in xprt_handshake_io_cb() 92 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_io_cb() 93 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_io_cb() 95 ctx->recv_wait = NULL; in xprt_handshake_io_cb() 165 ctx->send_wait = ctx->recv_wait = NULL; in xprt_handshake_init() 184 if (ctx->recv_wait) { in xprt_handshake_close() 185 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_close() 186 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_close() 216 ctx->recv_wait = sw; in xprt_handshake_subscribe() [all …]
|
H A D | mux_pt.c | 70 if (ctx->conn->recv_wait) { in mux_pt_io_cb() 71 ctx->conn->recv_wait->events &= ~SUB_RETRY_RECV; in mux_pt_io_cb() 72 tasklet_wakeup(ctx->conn->recv_wait->tasklet); in mux_pt_io_cb() 73 ctx->conn->recv_wait = NULL; in mux_pt_io_cb()
|
H A D | connection.c | 97 if (conn->recv_wait) { in conn_fd_handler() 98 conn->recv_wait->events &= ~SUB_RETRY_RECV; in conn_fd_handler() 99 tasklet_wakeup(conn->recv_wait->tasklet); in conn_fd_handler() 100 conn->recv_wait = NULL; in conn_fd_handler() 247 BUG_ON(conn->recv_wait != sw); in conn_unsubscribe() 248 conn->recv_wait = NULL; in conn_unsubscribe() 269 BUG_ON(conn->recv_wait != NULL || (sw->events & SUB_RETRY_RECV)); in conn_subscribe() 271 conn->recv_wait = sw; in conn_subscribe()
|
/dports/net/haproxy21/haproxy-2.1.12/src/ |
H A D | xprt_handshake.c | 19 struct wait_event *recv_wait; member 91 if (ctx->recv_wait) { in xprt_handshake_io_cb() 92 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_io_cb() 93 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_io_cb() 95 ctx->recv_wait = NULL; in xprt_handshake_io_cb() 165 ctx->send_wait = ctx->recv_wait = NULL; in xprt_handshake_init() 184 if (ctx->recv_wait) { in xprt_handshake_close() 185 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_close() 186 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_close() 216 ctx->recv_wait = sw; in xprt_handshake_subscribe() [all …]
|
H A D | mux_pt.c | 70 if (ctx->conn->recv_wait) { in mux_pt_io_cb() 71 ctx->conn->recv_wait->events &= ~SUB_RETRY_RECV; in mux_pt_io_cb() 72 tasklet_wakeup(ctx->conn->recv_wait->tasklet); in mux_pt_io_cb() 73 ctx->conn->recv_wait = NULL; in mux_pt_io_cb()
|
H A D | connection.c | 108 if (conn->recv_wait) { in conn_fd_handler() 109 conn->recv_wait->events &= ~SUB_RETRY_RECV; in conn_fd_handler() 110 tasklet_wakeup(conn->recv_wait->tasklet); in conn_fd_handler() 111 conn->recv_wait = NULL; in conn_fd_handler() 256 BUG_ON(conn->recv_wait != sw); in conn_unsubscribe() 257 conn->recv_wait = NULL; in conn_unsubscribe() 278 BUG_ON(conn->recv_wait != NULL || (sw->events & SUB_RETRY_RECV)); in conn_subscribe() 280 conn->recv_wait = sw; in conn_subscribe()
|
/dports/net/nuster/nuster-5.0.4.21/src/ |
H A D | xprt_handshake.c | 19 struct wait_event *recv_wait; member 91 if (ctx->recv_wait) { in xprt_handshake_io_cb() 92 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_io_cb() 93 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_io_cb() 95 ctx->recv_wait = NULL; in xprt_handshake_io_cb() 165 ctx->send_wait = ctx->recv_wait = NULL; in xprt_handshake_init() 184 if (ctx->recv_wait) { in xprt_handshake_close() 185 ctx->recv_wait->events &= ~SUB_RETRY_RECV; in xprt_handshake_close() 186 tasklet_wakeup(ctx->recv_wait->tasklet); in xprt_handshake_close() 216 ctx->recv_wait = sw; in xprt_handshake_subscribe() [all …]
|
H A D | mux_pt.c | 62 if (ctx->conn->recv_wait) { in mux_pt_io_cb() 63 ctx->conn->recv_wait->events &= ~SUB_RETRY_RECV; in mux_pt_io_cb() 64 tasklet_wakeup(ctx->conn->recv_wait->tasklet); in mux_pt_io_cb() 65 ctx->conn->recv_wait = NULL; in mux_pt_io_cb()
|
H A D | connection.c | 108 if (conn->recv_wait) { in conn_fd_handler() 109 conn->recv_wait->events &= ~SUB_RETRY_RECV; in conn_fd_handler() 110 tasklet_wakeup(conn->recv_wait->tasklet); in conn_fd_handler() 111 conn->recv_wait = NULL; in conn_fd_handler() 256 BUG_ON(conn->recv_wait != sw); in conn_unsubscribe() 257 conn->recv_wait = NULL; in conn_unsubscribe() 278 BUG_ON(conn->recv_wait != NULL || (sw->events & SUB_RETRY_RECV)); in conn_subscribe() 280 conn->recv_wait = sw; in conn_subscribe()
|
/dports/multimedia/vlc/vlc-3.0.16/modules/access/http/ |
H A D | h2conn.c | 82 vlc_cond_t recv_wait; member 157 vlc_cond_signal(&s->recv_wait); in vlc_h2_stream_headers() 183 vlc_cond_signal(&s->recv_wait); in vlc_h2_stream_data() 195 vlc_cond_broadcast(&s->recv_wait); in vlc_h2_stream_end() 208 vlc_cond_broadcast(&s->recv_wait); in vlc_h2_stream_reset() 219 vlc_cond_signal(&s->recv_wait); in vlc_h2_stream_wake_up() 249 vlc_cond_wait(&s->recv_wait, &conn->lock); in vlc_h2_stream_wait() 281 vlc_cond_wait(&s->recv_wait, &conn->lock); in vlc_h2_stream_read() 374 vlc_cond_destroy(&s->recv_wait); in vlc_h2_stream_close() 417 vlc_cond_init(&s->recv_wait); in vlc_h2_stream_open() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/nsprpub/pr/src/io/ |
H A D | prmwait.c | 277 waiter = &hash->recv_wait; in MW_AddHashInternal() 354 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 421 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 502 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 506 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1086 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1133 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1161 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1202 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1286 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/www/firefox/firefox-99.0/nsprpub/pr/src/io/ |
H A D | prmwait.c | 277 waiter = &hash->recv_wait; in MW_AddHashInternal() 354 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 421 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 502 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 506 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1086 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1133 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1161 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1202 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1286 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/nsprpub/pr/src/io/ |
H A D | prmwait.c | 273 waiter = &hash->recv_wait; in MW_AddHashInternal() 349 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 414 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 490 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 494 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1045 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1090 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1116 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1152 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1234 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/www/firefox-legacy/firefox-52.8.0esr/nsprpub/pr/src/io/ |
H A D | prmwait.c | 273 waiter = &hash->recv_wait; in MW_AddHashInternal() 349 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 414 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 490 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 494 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1045 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1090 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1116 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1152 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1234 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/devel/nspr/nspr-4.33/nspr/pr/src/io/ |
H A D | prmwait.c | 277 waiter = &hash->recv_wait; in MW_AddHashInternal() 354 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 421 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 502 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 506 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1086 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1133 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1161 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1202 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1286 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/nsprpub/pr/src/io/ |
H A D | prmwait.c | 277 waiter = &hash->recv_wait; in MW_AddHashInternal() 354 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 421 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 502 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 506 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1086 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1133 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1161 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1202 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1286 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/nsprpub/pr/src/io/ |
H A D | prmwait.c | 277 waiter = &hash->recv_wait; in MW_AddHashInternal() 354 for (desc = &oldHash->recv_wait; in MW_ExpandHashInternal() 421 desc = (&hash->recv_wait) + hidx; in _MW_LookupInternal() 502 waiter = &group->waiter->recv_wait; in _MW_PollInternal() 506 PR_ASSERT(waiter < &group->waiter->recv_wait in _MW_PollInternal() 1086 PRRecvWait **recv_wait; in PR_CancelWaitFileDesc() local 1133 _MW_DoneInternal(group, recv_wait, PR_MW_INTERRUPT); in PR_CancelWaitFileDesc() 1161 PRRecvWait *recv_wait = NULL; in PR_CancelWaitGroup() local 1202 end = &group->waiter->recv_wait + group->waiter->length; in PR_CancelWaitGroup() 1286 recv_wait = (PRRecvWait*)head; in PR_CancelWaitGroup() [all …]
|
/dports/net/haproxy19/haproxy-1.9.16/src/ |
H A D | mux_pt.c | 60 if (ctx->conn->recv_wait) { in mux_pt_io_cb() 61 ctx->conn->recv_wait->events &= ~SUB_RETRY_RECV; in mux_pt_io_cb() 62 tasklet_wakeup(ctx->conn->recv_wait->task); in mux_pt_io_cb() 63 ctx->conn->recv_wait = NULL; in mux_pt_io_cb()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/nfc/ |
H A D | nfcsim.c | 61 wait_queue_head_t recv_wait; member 74 init_waitqueue_head(&link->recv_wait); in nfcsim_link_new() 88 wake_up_interruptible(&link->recv_wait); in nfcsim_link_recv_wake() 133 rc = wait_event_interruptible_timeout(link->recv_wait, in nfcsim_link_recv_skb()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/nfc/ |
H A D | nfcsim.c | 61 wait_queue_head_t recv_wait; member 74 init_waitqueue_head(&link->recv_wait); in nfcsim_link_new() 88 wake_up_interruptible(&link->recv_wait); in nfcsim_link_recv_wake() 133 rc = wait_event_interruptible_timeout(link->recv_wait, in nfcsim_link_recv_skb()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/nfc/ |
H A D | nfcsim.c | 61 wait_queue_head_t recv_wait; member 74 init_waitqueue_head(&link->recv_wait); in nfcsim_link_new() 88 wake_up_interruptible(&link->recv_wait); in nfcsim_link_recv_wake() 133 rc = wait_event_interruptible_timeout(link->recv_wait, in nfcsim_link_recv_skb()
|
/dports/devel/pecl-swoole/swoole-4.8.5/src/protocol/ |
H A D | base.cc | 158 if (socket->recv_wait) { in recv_with_length_protocol() 169 socket->recv_wait = 0; in recv_with_length_protocol() 226 socket->recv_wait = 1; in recv_with_length_protocol()
|
/dports/devel/py-ovs/ovs-2.9.0/ovs/ |
H A D | jsonrpc.py | 317 self.recv_wait(poller) 354 def recv_wait(self, poller): member in Connection 358 self.stream.recv_wait(poller) 566 def recv_wait(self, poller): member in Session 568 self.rpc.recv_wait(poller)
|
/dports/www/firefox-esr/firefox-91.8.0/nsprpub/pr/include/private/ |
H A D | pprmwait.h | 36 PRRecvWait *recv_wait; /* hash table of receive wait objects */ member
|
/dports/www/firefox/firefox-99.0/nsprpub/pr/include/private/ |
H A D | pprmwait.h | 36 PRRecvWait *recv_wait; /* hash table of receive wait objects */ member
|