| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/extra/memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
495 conn *pending_close[max_items]; in libevent_tap_process() local
499 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
503 &me->pending_close); in libevent_tap_process()
539 conn *ce = pending_close[i]; in libevent_tap_process()
546 pending_close[i] = NULL; in libevent_tap_process()
549 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
556 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
599 conn->thread->pending_close = list_remove(conn->thread->pending_close, in notify_io_complete()
664 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
493 conn *pending_close[max_items]; in libevent_tap_process() local
496 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
497 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
501 &me->pending_close); in libevent_tap_process()
536 conn *ce = pending_close[i]; in libevent_tap_process()
545 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
553 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
643 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
644 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
493 conn *pending_close[max_items]; in libevent_tap_process() local
496 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
497 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
501 &me->pending_close); in libevent_tap_process()
536 conn *ce = pending_close[i]; in libevent_tap_process()
545 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
553 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
643 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
644 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
493 conn *pending_close[max_items]; in libevent_tap_process() local
496 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
497 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
501 &me->pending_close); in libevent_tap_process()
536 conn *ce = pending_close[i]; in libevent_tap_process()
545 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
553 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
643 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
644 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 458 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
507 conn *pending_close[max_items]; in libevent_tap_process() local
510 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
511 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
515 &me->pending_close); in libevent_tap_process()
550 conn *ce = pending_close[i]; in libevent_tap_process()
559 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
567 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
657 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
658 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 454 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
503 conn *pending_close[max_items]; in libevent_tap_process() local
506 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
507 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
511 &me->pending_close); in libevent_tap_process()
546 conn *ce = pending_close[i]; in libevent_tap_process()
555 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
563 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
653 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
654 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
493 conn *pending_close[max_items]; in libevent_tap_process() local
496 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
497 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
501 &me->pending_close); in libevent_tap_process()
536 conn *ce = pending_close[i]; in libevent_tap_process()
545 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
553 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
643 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
644 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/databases/mysql56-client/mysql-5.6.51/plugin/innodb_memcached/daemon_memcached/daemon/ |
| H A D | thread.c | 444 assert(!list_contains(thr->pending_close, c)); in enlist_conn()
493 conn *pending_close[max_items]; in libevent_tap_process() local
496 if (me->pending_close && me->last_checked != current_time) { in libevent_tap_process()
497 assert(!has_cycle(me->pending_close)); in libevent_tap_process()
501 &me->pending_close); in libevent_tap_process()
536 conn *ce = pending_close[i]; in libevent_tap_process()
545 enlist_conn(ce, &me->pending_close); in libevent_tap_process()
553 finalize_list(pending_close, n_pending_close); in libevent_tap_process()
643 if (number_of_pending(conn, thr->pending_close) == 0) { in notify_io_complete()
644 enlist_conn(conn, &thr->pending_close); in notify_io_complete()
[all …]
|
| /dports/devel/arduino-core/Arduino-b439a77/hardware/arduino/avr/firmwares/wifishield/wifiHD/src/ |
| H A D | ard_tcp.c | 42 if (_ttcp) _ttcp->pending_close[i] = false; in atcp_init_pend_flags()
244 _ttcp->pending_close[id] = true; in close_conn()
247 _ttcp->pending_close[id] = false; in close_conn()
334 _ttcp->pending_close[id] = false; in atcp_poll()
348 if (_ttcp->pending_close[id]) in atcp_poll()
355 _ttcp->pending_close[id] = true; in atcp_poll()
359 _ttcp->pending_close[id] = false; in atcp_poll()
384 if (_ttcp->pending_close[id]) in atcp_poll_conn()
398 if ((id != NO_VALID_ID) && (_ttcp->pending_close[id])) in atcp_poll_conn()
403 _ttcp->pending_close[id] = true; in atcp_poll_conn()
[all …]
|
| /dports/devel/arduino-core/Arduino-b439a77/libraries/WiFi/extras/wifiHD/src/ |
| H A D | ard_tcp.c | 42 if (_ttcp) _ttcp->pending_close[i] = false; in atcp_init_pend_flags()
244 _ttcp->pending_close[id] = true; in close_conn()
247 _ttcp->pending_close[id] = false; in close_conn()
334 _ttcp->pending_close[id] = false; in atcp_poll()
348 if (_ttcp->pending_close[id]) in atcp_poll()
355 _ttcp->pending_close[id] = true; in atcp_poll()
359 _ttcp->pending_close[id] = false; in atcp_poll()
384 if (_ttcp->pending_close[id]) in atcp_poll_conn()
398 if ((id != NO_VALID_ID) && (_ttcp->pending_close[id])) in atcp_poll_conn()
403 _ttcp->pending_close[id] = true; in atcp_poll_conn()
[all …]
|
| /dports/audio/festival/festival/src/main/ |
| H A D | audsp.cc | 185 static int pending_close = FALSE; variable
245 if (pending_close == TRUE) in tidy_up()
386 pending_close = TRUE; in process_command()
|
| /dports/devel/p5-POE-Component-Child/POE-Component-Child-1.39/ |
| H A D | Child.pm | 225 $self->pending_close();
317 $self->pending_close();
320 sub pending_close { subroutine
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ |
| H A D | logreader.c | 251 self->pending_close = TRUE; in log_reader_close_proto_deferred()
269 while (self->pending_close) in log_reader_close_proto()
369 if (self->pending_close) in log_reader_work_finished()
379 self->pending_close = FALSE; in log_reader_work_finished()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/chelsio/inline_crypto/ch_ktls/ |
| H A D | chcr_ktls.h | 67 bool pending_close; member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/chelsio/inline_crypto/ch_ktls/ |
| H A D | chcr_ktls.h | 67 bool pending_close; member
|