| /dports/www/unit-python/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.h | 27 nxt_queue_t drain_queue; member
|
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/www/unit/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.h | 27 nxt_queue_t drain_queue; member
|
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/www/unit-java/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.h | 27 nxt_queue_t drain_queue; member
|
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/math/cado-nfs/cado-nfs-f4284e2391121b2bfb97bc4880b6273c7250dc2f/utils/ |
| H A D | threadpool.cpp | 302 void thread_pool::drain_queue(const size_t queue, void (*f)(task_result*)) in drain_queue() function in thread_pool
320 drain_queue(queue); in drain_all_queues()
|
| H A D | threadpool.hpp | 168 void drain_queue(const size_t queue, void (*f)(task_result*) = NULL);
|
| /dports/devel/libunit/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/www/unit-perl/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/www/unit-php/unit-1.26.1/src/python/ |
| H A D | nxt_python_asgi.c | 210 nxt_queue_init(&ctx_data->drain_queue); in nxt_python_asgi_ctx_data_alloc()
1026 while (!nxt_queue_is_empty(&ctx_data->drain_queue)) { in nxt_py_asgi_shm_ack_handler()
1027 lnk = nxt_queue_first(&ctx_data->drain_queue); in nxt_py_asgi_shm_ack_handler()
1393 nxt_queue_insert_tail(&ctx_data->drain_queue, link); in nxt_py_asgi_drain_wait()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/tools/testing/selftests/mqueue/ |
| H A D | mq_perf_tests.c | 337 #define drain_queue() \ macro
512 drain_queue(); in perf_test_thread()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/tools/testing/selftests/mqueue/ |
| H A D | mq_perf_tests.c | 337 #define drain_queue() \ macro
512 drain_queue(); in perf_test_thread()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/tools/testing/selftests/mqueue/ |
| H A D | mq_perf_tests.c | 337 #define drain_queue() \ macro
512 drain_queue(); in perf_test_thread()
|
| /dports/dns/bind-tools/bind-9.16.27/lib/isc/netmgr/ |
| H A D | netmgr.c | 156 drain_queue(isc__networker_t *worker, netievent_type_t type);
528 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIORITY); in isc_nm_resume()
541 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIVILEGED); in isc_nm_resume()
748 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
771 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
772 drain_queue(worker, NETIEVENT_TASK); in nm_thread()
915 drain_queue(isc__networker_t *worker, netievent_type_t type) { in drain_queue() function
|
| /dports/dns/bind916/bind-9.16.27/lib/isc/netmgr/ |
| H A D | netmgr.c | 156 drain_queue(isc__networker_t *worker, netievent_type_t type);
528 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIORITY); in isc_nm_resume()
541 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIVILEGED); in isc_nm_resume()
748 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
771 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
772 drain_queue(worker, NETIEVENT_TASK); in nm_thread()
915 drain_queue(isc__networker_t *worker, netievent_type_t type) { in drain_queue() function
|
| /dports/dns/bind9-devel/bind9-e112afa15668bd3b1baed59df2d21e01b46da15e/lib/isc/netmgr/ |
| H A D | netmgr.c | 146 drain_queue(isc__networker_t *worker, netievent_type_t type);
479 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIORITY); in isc_nm_resume()
492 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIVILEGED); in isc_nm_resume()
702 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
725 drain_queue(worker, NETIEVENT_PRIVILEGED); in nm_thread()
726 drain_queue(worker, NETIEVENT_TASK); in nm_thread()
869 drain_queue(isc__networker_t *worker, netievent_type_t type) { in drain_queue() function
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/staging/unisys/visorhba/ |
| H A D | visorhba_main.c | 883 static void drain_queue(struct uiscmdrsp *cmdrsp, in drain_queue() function
929 drain_queue(devdata->cmdrsp, devdata); in visorhba_channel_interrupt()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/staging/unisys/visorhba/ |
| H A D | visorhba_main.c | 883 static void drain_queue(struct uiscmdrsp *cmdrsp, in drain_queue() function
929 drain_queue(devdata->cmdrsp, devdata); in visorhba_channel_interrupt()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/staging/unisys/visorhba/ |
| H A D | visorhba_main.c | 883 static void drain_queue(struct uiscmdrsp *cmdrsp, in drain_queue() function
929 drain_queue(devdata->cmdrsp, devdata); in visorhba_channel_interrupt()
|
| /dports/math/cado-nfs/cado-nfs-f4284e2391121b2bfb97bc4880b6273c7250dc2f/sieve/ |
| H A D | las-threads-work-data.cpp | 158 pool.drain_queue(2); in allocate_buckets()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | g1CollectedHeap.cpp | 5486 G1ParEvacuateFollowersClosure drain_queue(_g1h, &pss, _task_queues, _terminator); in work() local
5489 _proc_task.work(worker_id, is_alive, keep_alive, drain_queue); in work()
5625 G1ParEvacuateFollowersClosure drain_queue(_g1h, &pss, _queues, &_terminator); in work() local
5626 drain_queue.do_void(); in work()
5712 G1STWDrainQueueClosure drain_queue(this, &pss); in process_discovered_references() local
5722 &drain_queue, in process_discovered_references()
5734 &drain_queue, in process_discovered_references()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | g1CollectedHeap.cpp | 5486 G1ParEvacuateFollowersClosure drain_queue(_g1h, &pss, _task_queues, _terminator); in work() local
5489 _proc_task.work(worker_id, is_alive, keep_alive, drain_queue); in work()
5625 G1ParEvacuateFollowersClosure drain_queue(_g1h, &pss, _queues, &_terminator); in work() local
5626 drain_queue.do_void(); in work()
5712 G1STWDrainQueueClosure drain_queue(this, &pss); in process_discovered_references() local
5722 &drain_queue, in process_discovered_references()
5734 &drain_queue, in process_discovered_references()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/gc/g1/ |
| H A D | g1CollectedHeap.cpp | 3875 G1ParEvacuateFollowersClosure drain_queue(_g1h, pss, _task_queues, _terminator); in work() local
3878 _proc_task.work(worker_id, is_alive, keep_alive, drain_queue); in work()
3927 G1STWDrainQueueClosure drain_queue(this, pss); in process_discovered_references() local
3939 &drain_queue, in process_discovered_references()
3953 &drain_queue, in process_discovered_references()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/hotspot/share/gc/g1/ |
| H A D | g1CollectedHeap.cpp | 3478 …G1ParEvacuateFollowersClosure drain_queue(_g1h, pss, _task_queues, _terminator, G1GCPhaseTimes::Ob… in work() local
3481 _proc_task.work(worker_id, is_alive, keep_alive, drain_queue); in work()
3530 G1STWDrainQueueClosure drain_queue(this, pss); in process_discovered_references() local
3542 &drain_queue, in process_discovered_references()
3556 &drain_queue, in process_discovered_references()
|