/dports/mail/dovecot/dovecot-2.3.17/src/indexer/ |
H A D | worker-pool.c | 13 struct worker_pool { struct 21 struct worker_pool * argument 25 struct worker_pool *pool; in worker_pool_init() 27 pool = i_new(struct worker_pool, 1); in worker_pool_init() 35 void worker_pool_deinit(struct worker_pool **_pool) in worker_pool_deinit() 37 struct worker_pool *pool = *_pool; in worker_pool_deinit() 49 bool worker_pool_have_connections(struct worker_pool *pool) in worker_pool_have_connections() 54 static int worker_pool_add_connection(struct worker_pool *pool, in worker_pool_add_connection() 71 bool worker_pool_get_connection(struct worker_pool *pool, in worker_pool_get_connection() 86 worker_pool_find_username_connection(struct worker_pool *pool, in worker_pool_find_username_connection()
|
H A D | worker-pool.h | 9 struct worker_pool * 12 void worker_pool_deinit(struct worker_pool **pool); 14 bool worker_pool_have_connections(struct worker_pool *pool); 16 bool worker_pool_get_connection(struct worker_pool *pool, 20 worker_pool_find_username_connection(struct worker_pool *pool,
|
H A D | indexer.c | 21 static struct worker_pool *worker_pool; variable 36 !worker_pool_have_connections(worker_pool); in idle_die() 64 conn = worker_pool_find_username_connection(worker_pool, in queue_try_send_more() 82 if (!worker_pool_get_connection(worker_pool, &conn)) in queue_try_send_more() 134 worker_pool = worker_pool_init("indexer-worker", in main() 143 worker_pool_deinit(&worker_pool); in main()
|
/dports/biology/viennarna/ViennaRNA-2.4.18/src/bin/ |
H A D | parallel_helpers.h | 12 threadpool worker_pool; variable 50 worker_pool = thpool_init(max_threads); \ 56 thpool_wait(worker_pool); \ 60 thpool_destroy(worker_pool); \ 64 if (max_threads > 1) { thpool_add_work(worker_pool, (void *)&fun, (void *)data); } \ 70 while (thpool_num_threads_working(worker_pool) == (a)) \
|
/dports/www/libmicrohttpd/libmicrohttpd-0.9.74/src/lib/ |
H A D | daemon_destroy.c | 50 daemon->worker_pool[i].shutdown = true; in stop_workers() 51 if (MHD_ITC_IS_VALID_ (daemon->worker_pool[i].itc)) in stop_workers() 53 if (! MHD_itc_activate_ (daemon->worker_pool[i].itc, in stop_workers() 73 MHD_daemon_destroy (&daemon->worker_pool[i]); in stop_workers() 75 free (daemon->worker_pool); in stop_workers() 76 daemon->worker_pool = NULL; in stop_workers() 107 if (NULL != daemon->worker_pool) in MHD_daemon_destroy()
|
/dports/devel/hpx/hpx-1.2.1/tests/unit/resource/ |
H A D | suspend_pool.cpp | 45 hpx::threads::thread_pool_base& worker_pool = in hpx_main() local 65 worker_pool.suspend().get(); in hpx_main() 70 worker_pool.resume().get(); in hpx_main() 89 worker_pool.suspend_cb([&sem]() in hpx_main() 99 worker_pool.resume_cb([&sem]() in hpx_main() 117 worker_pool.suspend_processing_unit(thread_num); in hpx_main() 128 worker_pool.suspend().get(); in hpx_main() 133 worker_pool.resume().get(); in hpx_main()
|
/dports/net/flower/flower-0.10/flower/switchboard/ |
H A D | start.cc | 49 WorkerPool worker_pool(configuration.worker_pool_size(), &logger); in Start() local 56 if (Status status = worker_pool.StartWorker( in Start() 58 &directory, &target_picker, &worker_pool)); in Start() 80 if (Status status = worker_pool.StartWorker( in Start() 83 &worker_pool)); in Start()
|
H A D | handle.h | 29 WorkerPool* worker_pool) in Handle() argument 32 worker_pool_(worker_pool), in Handle() 77 WorkerPool* worker_pool, in Handle() argument 82 worker_pool_(worker_pool), in Handle()
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit_common/src/ |
H A D | worker_pool_sup.erl | 33 start_link(PoolSize, worker_pool:default_pool()). 48 [{worker_pool, {worker_pool, start_link, [PoolName]}, transient, 49 16#ffffffff, worker, [worker_pool]} |
|
H A D | worker_pool_worker.erl | 81 ok = worker_pool:ready(PoolName, self()), 97 ok = worker_pool:idle(get(worker_pool_name), self()), 109 ok = worker_pool:idle(get(worker_pool_name), self()), 114 ok = worker_pool:idle(get(worker_pool_name), self()), 120 ok = worker_pool:idle(get(worker_pool_name), self()), 131 ok = worker_pool:idle(get(worker_pool_name), self()),
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/kernel/ |
H A D | workqueue.c | 147 struct worker_pool { struct 868 struct worker_pool *pool; in wq_worker_sleeping() 1238 struct worker_pool *pool; in try_to_grab_pending() 2984 struct worker_pool *pool; in start_flush_work() 3506 struct worker_pool *pool = container_of(rcu, struct worker_pool, rcu); in rcu_free_pool() 3605 struct worker_pool *pool; in get_unbound_pool() 3802 struct worker_pool *pool; in alloc_unbound_pwq() 4575 struct worker_pool *pool; in work_busy() 4771 struct worker_pool *pool; in show_workqueue_state() 4901 struct worker_pool *pool; in unbind_workers() [all …]
|
H A D | workqueue_internal.h | 15 struct worker_pool; 39 struct worker_pool *pool; /* A: the associated pool */
|
/dports/multimedia/libv4l/linux-5.13-rc2/kernel/ |
H A D | workqueue.c | 147 struct worker_pool { struct 868 struct worker_pool *pool; in wq_worker_sleeping() 1238 struct worker_pool *pool; in try_to_grab_pending() 2984 struct worker_pool *pool; in start_flush_work() 3506 struct worker_pool *pool = container_of(rcu, struct worker_pool, rcu); in rcu_free_pool() 3605 struct worker_pool *pool; in get_unbound_pool() 3802 struct worker_pool *pool; in alloc_unbound_pwq() 4575 struct worker_pool *pool; in work_busy() 4771 struct worker_pool *pool; in show_workqueue_state() 4901 struct worker_pool *pool; in unbind_workers() [all …]
|
H A D | workqueue_internal.h | 15 struct worker_pool; 39 struct worker_pool *pool; /* A: the associated pool */
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/kernel/ |
H A D | workqueue.c | 147 struct worker_pool { struct 868 struct worker_pool *pool; in wq_worker_sleeping() 1238 struct worker_pool *pool; in try_to_grab_pending() 2984 struct worker_pool *pool; in start_flush_work() 3506 struct worker_pool *pool = container_of(rcu, struct worker_pool, rcu); in rcu_free_pool() 3605 struct worker_pool *pool; in get_unbound_pool() 3802 struct worker_pool *pool; in alloc_unbound_pwq() 4575 struct worker_pool *pool; in work_busy() 4771 struct worker_pool *pool; in show_workqueue_state() 4901 struct worker_pool *pool; in unbind_workers() [all …]
|
H A D | workqueue_internal.h | 15 struct worker_pool; 39 struct worker_pool *pool; /* A: the associated pool */
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/tools/perf/cli_tools/soundwave/ |
H A D | commands.py | 20 from cli_tools.soundwave import worker_pool 30 worker_pool.Process = Process 67 total_seconds = worker_pool.Run( 107 worker_pool.Process = Process 146 total_seconds = worker_pool.Run(
|
H A D | worker_pool_test.py | 16 from cli_tools.soundwave import worker_pool 29 worker_pool.Process = Process 48 worker_pool.Run(
|
/dports/devel/py-jenkins-job-builder/jenkins-job-builder-3.11.0/jenkins_jobs/ |
H A D | parallel.py | 120 worker_pool = [] 128 worker_pool.append(new_worker) 146 for worker in worker_pool:
|
/dports/devel/py-grab/grab-0.6.41/grab/spider/network_service/ |
H A D | threaded.py | 21 self.worker_pool = [] 23 self.worker_pool.append(self.create_worker(self.worker_callback)) 24 self.register_workers(self.worker_pool)
|
/dports/dns/knot3/knot-3.1.5/src/knot/worker/ |
H A D | pool.h | 23 struct worker_pool; 24 typedef struct worker_pool worker_pool_t;
|
/dports/dns/knot3-lib/knot-3.1.5/src/knot/worker/ |
H A D | pool.h | 23 struct worker_pool; 24 typedef struct worker_pool worker_pool_t;
|
/dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/rs/src/server/ |
H A D | threaded.rs | 128 worker_pool: ThreadPool, field 160 worker_pool: ThreadPool::with_name("Thrift service processor".to_owned(), num_workers), in new() 180 self.worker_pool in listen()
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/rs/src/server/ |
H A D | threaded.rs | 128 worker_pool: ThreadPool, field 158 worker_pool: ThreadPool::with_name( in new() 181 self.worker_pool in listen()
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/rs/src/server/ |
H A D | threaded.rs | 127 worker_pool: ThreadPool, field 159 worker_pool: ThreadPool::with_name("Thrift service processor".to_owned(), num_workers), in new() 179 self.worker_pool in listen()
|