/dports/net/libcoap/libcoap-4.3.0/tests/ |
H A D | test_sendqueue.c | 46 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue1() 134 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue5() 142 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue5() 143 CU_ASSERT(ctx->sendqueue->t == 0); in t_sendqueue5() 146 CU_ASSERT(ctx->sendqueue->next->t == 0); in t_sendqueue5() 176 ctx->sendqueue = NULL; in t_sendqueue6() 185 ctx->sendqueue = tmpqueue; in t_sendqueue6() 193 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue7() 205 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue7() 222 CU_ASSERT_PTR_NOT_NULL(ctx->sendqueue); in t_sendqueue8() [all …]
|
/dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/ |
H A D | Socket.pm | 229 my $sendqueue = $self->{sendqueue} ||= []; 230 push @$sendqueue, [ $data, $flags, $addr ]; 233 while( @$sendqueue ) { 234 my ( $data, $flags, $addr ) = @{ $sendqueue->[0] }; 239 shift @$sendqueue; 242 if( !@$sendqueue ) { 288 my $sendqueue = $self->{sendqueue}; 290 while( $sendqueue and @$sendqueue ) { 291 my ( $data, $flags, $addr ) = @{ shift @$sendqueue }; 313 if( !$sendqueue or !@$sendqueue ) {
|
/dports/net/net6/net6-1.3.14/src/ |
H A D | connection.cpp | 144 pack.enqueue(sendqueue); in send() 146 if(sendqueue.get_size() > 0) in send() 176 sendqueue.block(); in request_encryption() 368 sendqueue.get_data(), in do_io() 369 sendqueue.get_size() in do_io() 378 sendqueue.remove(bytes); in do_io() 488 sendqueue.unblock(); in do_handshake() 510 if(sendqueue.get_size() > 0) in do_handshake() 568 sendqueue.clear(); in on_close() 619 sendqueue.block(); in net_encryption() [all …]
|
/dports/devel/p5-IO-Event/IO-Event-0.813/t/ |
H A D | forked.tt | 63 sendqueue => [ 91 sendqueue => [ 118 sendqueue => [ 146 sendqueue => [ 174 sendqueue => [ 256 for (my $sqi = 0; $sqi <= $#{$test->{sendqueue}}; $sqi++) { 259 my $x = $test->{sendqueue}[$sqi]; 263 (print $s $test->{sendqueue}[$sqi]) || die "print $$: $!\n";
|
/dports/net/libcoap/libcoap-4.3.0/src/ |
H A D | net.c | 161 if (ctx->sendqueue) { in coap_adjust_basetime() 278 return context->sendqueue; in coap_peek_next() 288 next = context->sendqueue; in coap_pop_next() 289 context->sendqueue = context->sendqueue->next; in coap_pop_next() 290 if (context->sendqueue) { in coap_pop_next() 1983 while (context->sendqueue && context->sendqueue->session == session) { in coap_cancel_session_messages() 1993 if (!context->sendqueue) in coap_cancel_session_messages() 1996 p = context->sendqueue; in coap_cancel_session_messages() 2022 while (context->sendqueue && context->sendqueue->session == session && in coap_cancel_all_messages() 2036 p = context->sendqueue; in coap_cancel_all_messages() [all …]
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 123 wc->sendqueue->abort(); in shutdown() 272 if(wc->sendqueue->is_aborted()) { in schedule() 307 wc->sendqueue->produce(inst); in schedule() 362 if(wc && ! wc->sendqueue->is_aborted()) { in release() 517 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 557 delete sendqueue; in ~WorkerConnection() 767 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 768 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 213 Queue<NdbInstance> * sendqueue; variable
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 120 wc->sendqueue->abort(); in shutdown() 269 if(wc->sendqueue->is_aborted()) { in schedule() 304 wc->sendqueue->produce(inst); in schedule() 359 if(wc && ! wc->sendqueue->is_aborted()) { in release() 514 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 554 delete sendqueue; in ~WorkerConnection() 764 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 765 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 211 Queue<NdbInstance> * sendqueue; variable
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 123 wc->sendqueue->abort(); in shutdown() 272 if(wc->sendqueue->is_aborted()) { in schedule() 307 wc->sendqueue->produce(inst); in schedule() 362 if(wc && ! wc->sendqueue->is_aborted()) { in release() 517 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 557 delete sendqueue; in ~WorkerConnection() 767 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 768 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 213 Queue<NdbInstance> * sendqueue; variable
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 123 wc->sendqueue->abort(); in shutdown() 272 if(wc->sendqueue->is_aborted()) { in schedule() 307 wc->sendqueue->produce(inst); in schedule() 362 if(wc && ! wc->sendqueue->is_aborted()) { in release() 517 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 557 delete sendqueue; in ~WorkerConnection() 767 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 768 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 213 Queue<NdbInstance> * sendqueue; variable
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 123 wc->sendqueue->abort(); in shutdown() 272 if(wc->sendqueue->is_aborted()) { in schedule() 307 wc->sendqueue->produce(inst); in schedule() 362 if(wc && ! wc->sendqueue->is_aborted()) { in release() 517 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 557 delete sendqueue; in ~WorkerConnection() 767 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 768 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 213 Queue<NdbInstance> * sendqueue; variable
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/src/schedulers/ |
H A D | S_sched.cc | 123 wc->sendqueue->abort(); in shutdown() 272 if(wc->sendqueue->is_aborted()) { in schedule() 307 wc->sendqueue->produce(inst); in schedule() 362 if(wc && ! wc->sendqueue->is_aborted()) { in release() 517 sendqueue = new Queue<NdbInstance>(instances.max); in WorkerConnection() 557 delete sendqueue; in ~WorkerConnection() 767 nready += get_operations_from_queue(& readylist, wc->sendqueue); in run_ndb_send_thread() 768 if(wc->sendqueue->is_aborted()) { in run_ndb_send_thread()
|
H A D | S_sched.h | 213 Queue<NdbInstance> * sendqueue; variable
|
/dports/irc/epic4/epic4-2.10.9/script/ |
H A D | revdcc | 46 push sendqueue[$rev.nick] $rev.file 50 @ rev.host[$rev.nick] = sendqueue[$rev.nick] = [] 119 if (match($3 $sendqueue[$getnick])) { 130 …@ rev.host[$getnick] = sendqueue[$getnick] = rev.sendport[$getnick] = rev.socket[$getnick] = rev.s…
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/ |
H A D | FastLeaderElection.java | 203 LinkedBlockingQueue<ToSend> sendqueue; field in FastLeaderElection 355 sendqueue.offer(notmsg); in run() 428 sendqueue.offer(notmsg); in run() 464 sendqueue.offer(notmsg); in run() 496 ToSend m = sendqueue.poll(3000, TimeUnit.MILLISECONDS); in run() 648 sendqueue = new LinkedBlockingQueue<ToSend>(); in starter() 713 sendqueue.offer(notmsg); in sendNotifications()
|
/dports/irc/epic5/epic5-2.1.6/script/ |
H A D | revdcc | 46 push sendqueue[$rev.nick] $rev.file; 50 @ rev.host[$rev.nick] = sendqueue[$rev.nick] = []; 119 if (match($3 $sendqueue[$getnick])) { 130 …@ rev.host[$getnick] = sendqueue[$getnick] = rev.sendport[$getnick] = rev.socket[$getnick] = rev.s…
|
/dports/net-im/gajim/gajim-gajim-1.3.3/gajim/common/zeroconf/ |
H A D | client_zeroconf.py | 339 self.sendqueue = [] 444 self.sendqueue.insert(0, (r, is_message)) 447 self.sendqueue.append((r, is_message)) 569 if not self.sendqueue: 571 self.sendbuff, self.buff_is_message = self.sendqueue.pop(0) 577 if not self.sendbuff and not self.sendqueue: 601 writable = self.sendqueue or self.sendbuff
|
/dports/games/chocolate-doom/chocolate-doom-3.0.1/src/ |
H A D | net_server.c | 98 net_full_ticcmd_t sendqueue[BACKUPTICS]; member 576 memset(client->sendqueue, 0xff, sizeof(client->sendqueue)); in NET_SV_InitNewClient() 1241 cmd = &client->sendqueue[i % BACKUPTICS]; in NET_SV_SendTics() 1286 cmd = &client->sendqueue[i % BACKUPTICS]; in NET_SV_ParseResendRequest() 1547 client->sendqueue[client->sendseq % BACKUPTICS] = cmd; in NET_SV_PumpSendQueue()
|
/dports/games/crispy-doom/crispy-doom-crispy-doom-5.10.3/src/ |
H A D | net_server.c | 96 net_full_ticcmd_t sendqueue[BACKUPTICS]; member 578 memset(client->sendqueue, 0xff, sizeof(client->sendqueue)); in NET_SV_InitNewClient() 1305 cmd = &client->sendqueue[i % BACKUPTICS]; in NET_SV_SendTics() 1353 cmd = &client->sendqueue[i % BACKUPTICS]; in NET_SV_ParseResendRequest() 1664 client->sendqueue[client->sendseq % BACKUPTICS] = cmd; in NET_SV_PumpSendQueue()
|
/dports/textproc/dikt/dikt-2s4/src/net/ |
H A D | dict.cpp | 143 sendqueue << request; in send() 161 clearQueue(sendqueue); in clear() 608 foreach (const Request *request, sendqueue) in helloResponse() 610 sendqueue.clear(); in helloResponse()
|
/dports/databases/pecl-memcache/memcache-8.0/src/ |
H A D | memcache_pool.c | 654 mmc_queue_reset(&(mmc->sendqueue)); in mmc_server_deactivate() 840 mmc_queue_free(&(mmc->sendqueue)); in mmc_server_sleep() 1218 mmc_queue_push(&(mmc->sendqueue), request); in mmc_pool_schedule() 1375 mmc_queue_remove(&(mmc->sendqueue), request); in mmc_select_retry() 1380 mmc_pool_slot_send(pool, mmc, mmc_queue_pop(&(mmc->sendqueue)), 1); in mmc_select_retry() 1527 mmc_pool_slot_send(pool, mmc, mmc_queue_pop(&(mmc->sendqueue)), 1); in mmc_pool_select() 1549 if ( ! pool->sending->len && ( mmc->sendreq != NULL || mmc->sendqueue.len ) ) { in mmc_pool_select() 1550 …E_WARNING, "mmc_pool_select() failed to cleanup when sending! Sendqueue: %d", mmc->sendqueue.len ); in mmc_pool_select() 1626 mmc_pool_slot_send(pool, mmc, mmc_queue_pop(&(mmc->sendqueue)), 1); in mmc_pool_select()
|