Home
last modified time | relevance | path

Searched refs:sendqueue (Results 1 – 25 of 39) sorted by relevance

12

/dports/net/libcoap/libcoap-4.3.0/tests/
H A Dtest_sendqueue.c46 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 DSocket.pm229 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 Dconnection.cpp144 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 Dforked.tt63 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 Dnet.c161 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 DS_sched.cc123 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 DS_sched.h213 Queue<NdbInstance> * sendqueue; variable
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/src/schedulers/
H A DS_sched.cc120 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 DS_sched.h211 Queue<NdbInstance> * sendqueue; variable
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/
H A DS_sched.cc123 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 DS_sched.h213 Queue<NdbInstance> * sendqueue; variable
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/
H A DS_sched.cc123 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 DS_sched.h213 Queue<NdbInstance> * sendqueue; variable
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/
H A DS_sched.cc123 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 DS_sched.h213 Queue<NdbInstance> * sendqueue; variable
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/src/schedulers/
H A DS_sched.cc123 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 DS_sched.h213 Queue<NdbInstance> * sendqueue; variable
/dports/irc/epic4/epic4-2.10.9/script/
H A Drevdcc46 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 DFastLeaderElection.java203 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 Drevdcc46 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 Dclient_zeroconf.py339 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 Dnet_server.c98 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 Dnet_server.c96 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 Ddict.cpp143 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 Dmemcache_pool.c654 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()

12