| /dports/devel/thrift/thrift-0.14.0/lib/nodejs/lib/thrift/ |
| H A D | ws_transport.js | 44 this.send_pending = []; //Buffers/Callback pairs waiting to be sent
73 this.send_pending.push({
82 if (this.send_pending.length > 0) {
85 this.send_pending.forEach(function(elem) {
95 this.send_pending = [];
|
| H A D | ws_connection.js | 88 this.send_pending = [];
109 this.send_pending = []; //Buffers/Callback pairs waiting to be sent
114 if (this.send_pending.length > 0) {
117 this.send_pending.forEach(function(data) {
120 this.send_pending = [];
269 this.send_pending.push(data);
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/fuzz/ |
| H A D | fuzz_target.cc | 40 void send_pending(nghttp2_session *session) { in send_pending() function
72 send_pending(session); in LLVMFuzzerTestOneInput()
74 send_pending(session); in LLVMFuzzerTestOneInput()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/fuzz/ |
| H A D | fuzz_target.cc | 40 void send_pending(nghttp2_session *session) { in send_pending() function
72 send_pending(session); in LLVMFuzzerTestOneInput()
74 send_pending(session); in LLVMFuzzerTestOneInput()
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/fuzz/ |
| H A D | fuzz_target.cc | 40 void send_pending(nghttp2_session *session) { in send_pending() function
72 send_pending(session); in LLVMFuzzerTestOneInput()
74 send_pending(session); in LLVMFuzzerTestOneInput()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/fuzz/ |
| H A D | fuzz_target.cc | 40 void send_pending(nghttp2_session *session) { in send_pending() function
72 send_pending(session); in LLVMFuzzerTestOneInput()
74 send_pending(session); in LLVMFuzzerTestOneInput()
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/abstract/protocols/smtp/ |
| H A D | smtp.c | 61 unsigned char send_pending:1; member
230 c->send_pending = 1; in lws_smtpc_abs_rx()
243 if (!c->send_pending || !c->e) in lws_smtpc_abs_writeable()
246 c->send_pending = 0; in lws_smtpc_abs_writeable()
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang-wx/otp-OTP-24.1.7/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang/otp-OTP-24.1.7/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/lang/erlang-java/otp-OTP-24.1.7/lib/megaco/src/engine/ |
| H A D | megaco_trans_sender.erl | 35 send_pending/2,
105 send_pending(Pid, Serial) when is_pid(Pid) andalso is_integer(Serial) -> function
106 Pid ! {send_pending, Serial},
182 {send_pending, Serial} ->
185 send_pending(S#state.conn_handle, Serial, [], [])
292 {send_pending, Serial} ->
296 send_pending(S#state.conn_handle, Serial, Reqs, Acks)
529 send_pending(CH, Serial, Reqs, Acks) -> function
|
| /dports/net/pjsip/pjproject-2.11.1/pjlib/src/pjlib-test/ |
| H A D | ioq_udp.c | 143 pj_bool_t send_pending, recv_pending; in compliance_test() local
252 send_pending = 1; in compliance_test()
256 send_pending = 0; in compliance_test()
269 while (send_pending || recv_pending) { in compliance_test()
324 send_pending = 0; in compliance_test()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/pml/ob1/ |
| H A D | pml_ob1_sendreq.h | 98 opal_list_append(&mca_pml_ob1.send_pending, item); in add_request_to_send_pending()
100 opal_list_prepend(&mca_pml_ob1.send_pending, item); in add_request_to_send_pending()
113 opal_list_remove_first(&mca_pml_ob1.send_pending); in get_request_from_send_pending()
|
| H A D | pml_ob1_progress.c | 69 int i, queue_length = opal_list_get_size(&mca_pml_ob1.send_pending); in mca_pml_ob1_progress()
|
| H A D | pml_ob1.h | 77 opal_list_t send_pending; member
304 if(opal_list_get_size(&mca_pml_ob1.send_pending)) \
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/pml/ob1/ |
| H A D | pml_ob1_sendreq.h | 98 opal_list_append(&mca_pml_ob1.send_pending, item); in add_request_to_send_pending()
100 opal_list_prepend(&mca_pml_ob1.send_pending, item); in add_request_to_send_pending()
113 opal_list_remove_first(&mca_pml_ob1.send_pending); in get_request_from_send_pending()
|
| H A D | pml_ob1_progress.c | 69 int i, queue_length = opal_list_get_size(&mca_pml_ob1.send_pending); in mca_pml_ob1_progress()
|
| H A D | pml_ob1.h | 77 opal_list_t send_pending; member
304 if(opal_list_get_size(&mca_pml_ob1.send_pending)) \
|
| /dports/devel/thrift/thrift-0.14.0/lib/js/src/ |
| H A D | thrift.js | 558 this.send_pending = []; //Buffers/Callback pairs waiting to be sent
589 this.send_pending.push({
598 if (this.send_pending.length > 0) {
601 this.send_pending.forEach(function(elem) {
611 this.send_pending = [];
|
| /dports/net/serveez/serveez-0.2.2/src/libserveez/ |
| H A D | pipe-socket.c | 584 sock->send_pending -= num_written; in svz_pipe_write_socket()
586 if (sock->send_pending != 0) in svz_pipe_write_socket()
589 sock->send_pending); in svz_pipe_write_socket()
602 sock->send_pending += do_write; in svz_pipe_write_socket()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/fs/cifs/ |
| H A D | smbdirect.c | 288 if (atomic_dec_and_test(&request->info->send_pending)) in send_done()
720 atomic_inc(&info->send_pending); in smbd_post_send_negotiate_req()
727 atomic_dec(&info->send_pending); in smbd_post_send_negotiate_req()
847 atomic_read(&info->send_pending) < info->send_credit_target || in smbd_post_send_sgl()
856 if (unlikely(atomic_inc_return(&info->send_pending) > in smbd_post_send_sgl()
858 atomic_dec(&info->send_pending); in smbd_post_send_sgl()
957 if (atomic_dec_and_test(&info->send_pending)) in smbd_post_send_sgl()
1341 atomic_read(&info->send_pending) == 0); in smbd_destroy()
1669 atomic_set(&info->send_pending, 0); in _smbd_get_connection()
2134 atomic_read(&info->send_pending) == 0); in smbd_send()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/fs/cifs/ |
| H A D | smbdirect.c | 288 if (atomic_dec_and_test(&request->info->send_pending)) in send_done()
720 atomic_inc(&info->send_pending); in smbd_post_send_negotiate_req()
727 atomic_dec(&info->send_pending); in smbd_post_send_negotiate_req()
847 atomic_read(&info->send_pending) < info->send_credit_target || in smbd_post_send_sgl()
856 if (unlikely(atomic_inc_return(&info->send_pending) > in smbd_post_send_sgl()
858 atomic_dec(&info->send_pending); in smbd_post_send_sgl()
957 if (atomic_dec_and_test(&info->send_pending)) in smbd_post_send_sgl()
1341 atomic_read(&info->send_pending) == 0); in smbd_destroy()
1669 atomic_set(&info->send_pending, 0); in _smbd_get_connection()
2134 atomic_read(&info->send_pending) == 0); in smbd_send()
|