Home
last modified time | relevance | path

Searched refs:recv_wait (Results 1 – 25 of 69) sorted by relevance

123

/dports/net/haproxy20/haproxy-2.0.26/src/
H A Dxprt_handshake.c19 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 Dmux_pt.c70 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 Dconnection.c97 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 Dxprt_handshake.c19 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 Dmux_pt.c70 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 Dconnection.c108 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 Dxprt_handshake.c19 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 Dmux_pt.c62 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 Dconnection.c108 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 Dh2conn.c82 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 Dprmwait.c277 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 Dprmwait.c277 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 Dprmwait.c273 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 Dprmwait.c273 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 Dprmwait.c277 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 Dprmwait.c277 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 Dprmwait.c277 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 Dmux_pt.c60 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 Dnfcsim.c61 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 Dnfcsim.c61 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 Dnfcsim.c61 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 Dbase.cc158 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 Djsonrpc.py317 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 Dpprmwait.h36 PRRecvWait *recv_wait; /* hash table of receive wait objects */ member
/dports/www/firefox/firefox-99.0/nsprpub/pr/include/private/
H A Dpprmwait.h36 PRRecvWait *recv_wait; /* hash table of receive wait objects */ member

123