Home
last modified time | relevance | path

Searched refs:worker_pool (Results 1 – 25 of 161) sorted by relevance

1234567

/dports/mail/dovecot/dovecot-2.3.17/src/indexer/
H A Dworker-pool.c13 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 Dworker-pool.h9 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 Dindexer.c21 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 Dparallel_helpers.h12 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 Ddaemon_destroy.c50 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 Dsuspend_pool.cpp45 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 Dstart.cc49 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 Dhandle.h29 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 Dworker_pool_sup.erl33 start_link(PoolSize, worker_pool:default_pool()).
48 [{worker_pool, {worker_pool, start_link, [PoolName]}, transient,
49 16#ffffffff, worker, [worker_pool]} |
H A Dworker_pool_worker.erl81 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 Dworkqueue.c147 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 Dworkqueue_internal.h15 struct worker_pool;
39 struct worker_pool *pool; /* A: the associated pool */
/dports/multimedia/libv4l/linux-5.13-rc2/kernel/
H A Dworkqueue.c147 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 Dworkqueue_internal.h15 struct worker_pool;
39 struct worker_pool *pool; /* A: the associated pool */
/dports/multimedia/v4l-utils/linux-5.13-rc2/kernel/
H A Dworkqueue.c147 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 Dworkqueue_internal.h15 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 Dcommands.py20 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 Dworker_pool_test.py16 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 Dparallel.py120 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 Dthreaded.py21 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 Dpool.h23 struct worker_pool;
24 typedef struct worker_pool worker_pool_t;
/dports/dns/knot3-lib/knot-3.1.5/src/knot/worker/
H A Dpool.h23 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 Dthreaded.rs128 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 Dthreaded.rs128 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 Dthreaded.rs127 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()

1234567