Home
last modified time | relevance | path

Searched refs:workers (Results 1 – 25 of 6041) sorted by relevance

12345678910>>...242

/dports/www/mattermost-server/mattermost-server-6.0.2/jobs/
H A Dworkers.go51 if srv.workers != nil && srv.workers.running {
55 workers := &Workers{
58 workers.Watcher = srv.MakeWatcher(workers, DefaultWatcherPollingInterval)
132 srv.workers = workers
203 go workers.Cloud.Run()
216 workers.listenerId = workers.ConfigService.AddConfigListener(workers.handleConfigChange)
217 workers.running = true
275 workers.ConfigService.RemoveConfigListener(workers.listenerId)
277 workers.Watcher.Stop()
304 workers.Plugins.Stop()
[all …]
H A Djobs_watcher.go20 workers *Workers member
32 workers: workers,
76 if watcher.workers.DataRetention != nil {
83 if watcher.workers.MessageExport != nil {
111 if watcher.workers.LdapSync != nil {
118 if watcher.workers.Migrations != nil {
125 if watcher.workers.Plugins != nil {
132 if watcher.workers.ExpiryNotify != nil {
146 if watcher.workers.ActiveUsers != nil {
160 if watcher.workers.ImportDelete != nil {
[all …]
/dports/devel/R-cran-future/future/R/
H A DnbrOfWorkers.R25 if (is.function(workers)) workers <- workers()
28 workers <- length(workers)
31 workers <- length(workers)
35 stop_if_not(length(workers) == 1L, !is.na(workers), workers >= 1L, is.finite(workers))
54 if (is.function(workers)) workers <- workers()
59 stop_if_not(length(workers) == 1L, !is.na(workers), workers >= 1L, is.finite(workers))
70 if (is.function(workers)) workers <- workers()
77 stop_if_not(length(workers) == 1L, !is.na(workers), workers >= 1L)
122 workers <- workers - usedNodes
123 stop_if_not(length(workers) == 1L, !is.na(workers), workers >= 0L, is.finite(workers))
[all …]
H A DClusterRegistry.R9 if (is.null(workers)) {
10 } else if (is.numeric(workers)) {
11 workers <- as.integer(workers)
12 stop_if_not(length(workers) == 1, is.finite(workers))
13 } else if (is.character(workers)) {
14 stop_if_not(length(workers) >= 1, !anyNA(workers))
15 workers <- sort(workers)
22 last <<- workers
29 if (!identical(workers, last)) {
32 last <<- workers
[all …]
H A Dmulticore.R57 default_workers <- missing(workers)
58 if (is.function(workers)) workers <- workers()
59 workers <- as.integer(workers)
60 stop_if_not(is.finite(workers), workers >= 1L)
65 if (workers == 1L || !supportsMulticore(warn = TRUE)) {
72 oopts <- options(mc.cores = workers)
75 future <- MulticoreFuture(..., workers = workers, envir = envir)
158 stop_if_not(length(workers) == 1L, is.numeric(workers), is.finite(workers), workers >= 1)
164 if (debug) mdebugf("requestCore(): workers = %d", workers)
167 if (workers == 0L) {
[all …]
H A Dmultisession.R64 multisession <- function(..., workers = availableCores(), lazy = FALSE, rscript_libs = .libPaths(),… argument
65 if (is.function(workers)) workers <- workers()
66 workers <- as.integer(workers)
67 stop_if_not(length(workers) == 1, is.finite(workers), workers >= 1)
71 if (workers == 1L) {
75 …future <- MultisessionFuture(..., workers = workers, lazy = lazy, rscript_libs = rscript_libs, env…
H A DClusterFuture-class.R78 if (is.function(workers)) workers <- workers()
82 workers <- addCovrLibPath(workers)
84 workers <- ClusterRegistry("start", workers = workers, ...)
86 workers <- as.cluster(workers)
110 future$workers <- workers
132 workers <- future$workers functionVar
143 }, workers = workers) functionVar
221 workers <- x$workers functionVar
254 workers <- x$workers
369 workers <- future$workers functionVar
[all …]
/dports/www/mod_http2/mod_h2-2.0.2/mod_http2/
H A Dh2_workers.c80 slot->workers = workers; in activate_slot()
142 else if (workers->dynamic && !workers->shutdown) { in wake_idle_worker()
189 h2_workers *workers = slot->workers; in get_next() local
233 h2_workers *workers = slot->workers; in slot_done() local
374 if (!workers) { in h2_workers_create()
386 workers->min_workers, workers->max_workers, in h2_workers_create()
409 rv = apr_thread_cond_create(&workers->all_done, workers->pool); in h2_workers_create()
412 n = workers->nslots = workers->max_workers; in h2_workers_create()
427 rv = activate_slot(workers, &workers->slots[i]); in h2_workers_create()
432 push_slot(&workers->free, &workers->slots[i]); in h2_workers_create()
[all …]
/dports/www/apache24/httpd-2.4.53/modules/http2/
H A Dh2_workers.c81 slot->workers = workers; in activate_slot()
143 else if (workers->dynamic && !workers->shutdown) { in wake_idle_worker()
196 h2_workers *workers = slot->workers; in get_next() local
240 h2_workers *workers = slot->workers; in slot_done() local
384 if (!workers) { in h2_workers_create()
396 workers->min_workers, workers->max_workers, in h2_workers_create()
427 rv = apr_thread_cond_create(&workers->all_done, workers->pool); in h2_workers_create()
430 n = workers->nslots = workers->max_workers; in h2_workers_create()
445 rv = activate_slot(workers, &workers->slots[i]); in h2_workers_create()
450 push_slot(&workers->free, &workers->slots[i]); in h2_workers_create()
[all …]
/dports/math/gap/gap-4.11.0/hpcgap/demo/parorbit/
H A DTIMINGS3 5 hash servers, 10 workers, with Richard:
4 8 hash servers, 8 workers, with Richard : 132 seconds
5 6 hash servers, 6 workers, with Richard :
7 4 hash servers, 9 workers, with Richard : 192 seconds
21 Doing 2 hashservers and 3 workers... 389.2135620117188
22 Doing 2 hashservers and 6 workers... 390.5462260246277
25 Doing 4 hashservers and 6 workers... 1297.50292801857
98 5 hash 5 workers: 148
99 6 hash 6 workers: 129
100 7 hash 7 workers: 120
[all …]
/dports/devel/gearmand/gearmand-1.0.6/tests/workers/
H A Dinclude.am9 noinst_HEADERS+= tests/workers/aggregator/cat.h
11 noinst_HEADERS+= tests/workers/v1/echo_or_react.h
13 noinst_HEADERS+= tests/workers/v1/increment_reset.h
14 noinst_HEADERS+= tests/workers/v1/unique.h
16 noinst_HEADERS+= tests/workers/v2/call_exception.h
17 noinst_HEADERS+= tests/workers/v2/called.h
18 noinst_HEADERS+= tests/workers/v2/count.h
19 noinst_HEADERS+= tests/workers/v2/echo_or_react.h
21 noinst_HEADERS+= tests/workers/v2/increment_reset.h
23 noinst_HEADERS+= tests/workers/v2/split.h
[all …]
/dports/sysutils/py-salt/salt-3004.1/salt/states/
H A Dmodjk.py21 def _bulk_state(saltfunc, lbn, workers, profile): argument
27 if not isinstance(workers, list):
57 def worker_stopped(name, workers=None, profile="default"): argument
71 if workers is None:
72 workers = []
90 if workers is None:
91 workers = []
109 if workers is None:
110 workers = []
128 if workers is None:
[all …]
/dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/internal_stats/all_dispatchers/
H A Dmain.cpp121 workers_vector_t workers; in create_child_coops() local
122 workers.reserve( 100 ); in create_child_coops()
136 connect_workers( workers ); in create_child_coops()
146 workers_vector_t & workers ) in create_children_on_default_disp() argument
155 workers_vector_t & workers ) in create_children_on_one_thread_disp() argument
167 workers_vector_t & workers ) in create_children_on_active_obj_disp() argument
298 workers.push_back( in create_children_on()
307 for( auto w : workers ) in connect_workers()
312 [&workers] { in connect_workers()
313 return workers[ random_index( workers.size() ) ] in connect_workers()
[all …]
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dppqueue.go43 for i, worker := range workers {
46 workers = workers[1:]
48 workers = workers[:i]
50 workers = append(workers[:i], workers[i+1:]...)
55 return append(workers, self)
68 return workers[0:0]
83 workers := make([]worker_t, 0)
98 if len(workers) > 0 {
119 workers = s_worker_ready(s_worker_new(identity), workers)
136 workers = workers[1:]
[all …]
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dppqueue.go43 for i, worker := range workers {
46 workers = workers[1:]
48 workers = workers[:i]
50 workers = append(workers[:i], workers[i+1:]...)
55 return append(workers, self)
68 return workers[0:0]
83 workers := make([]worker_t, 0)
98 if len(workers) > 0 {
119 workers = s_worker_ready(s_worker_new(identity), workers)
136 workers = workers[1:]
[all …]
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dppqueue.go43 for i, worker := range workers {
46 workers = workers[1:]
48 workers = workers[:i]
50 workers = append(workers[:i], workers[i+1:]...)
55 return append(workers, self)
68 return workers[0:0]
83 workers := make([]worker_t, 0)
98 if len(workers) > 0 {
119 workers = s_worker_ready(s_worker_new(identity), workers)
136 workers = workers[1:]
[all …]
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dppqueue.go43 for i, worker := range workers {
46 workers = workers[1:]
48 workers = workers[:i]
50 workers = append(workers[:i], workers[i+1:]...)
55 return append(workers, self)
68 return workers[0:0]
83 workers := make([]worker_t, 0)
98 if len(workers) > 0 {
119 workers = s_worker_ready(s_worker_new(identity), workers)
136 workers = workers[1:]
[all …]
/dports/math/py-pyFFTW/pyFFTW-0.13.0/pyfftw/interfaces/
H A Dscipy_fft.py101 def _workers_to_threads(workers): argument
105 if workers is None:
108 if workers < 0:
109 if workers >= -_cpu_count:
110 workers += 1 + _cpu_count
114 elif workers == 0:
116 return workers
128 threads = _workers_to_threads(workers)
142 threads = _workers_to_threads(workers)
157 threads = _workers_to_threads(workers)
[all …]
/dports/devel/R-cran-parallelly/parallelly/tests/
H A DavailableWorkers.R48 print(workers)
57 workers <- workers0 globalVar
76 print(workers)
77 stopifnot(length(workers) == length(workers0), all(workers == sort(workers0)))
92 workersE <- c(workers, "n 3")
110 workers <- workers0 globalVar
129 stopifnot(length(workers) == length(workers0), all(workers == sort(workers0)))
134 print(workers)
135 stopifnot(length(workers) == length(workers0), all(workers == sort(workers0)))
140 print(workers)
[all …]
/dports/science/py-scipy/scipy-1.7.1/scipy/fft/_pocketfft/
H A Dbasic.py12 workers=None, *, plan=None): argument
20 workers = _workers(workers)
41 workers=None, *, plan=None): argument
50 workers = _workers(workers)
72 workers=None, *, plan=None): argument
81 workers = _workers(workers)
173 workers=None, *, plan=None): argument
184 workers = _workers(workers)
217 workers = _workers(workers)
254 workers = _workers(workers)
[all …]
/dports/devel/R-cran-future/future/tests/
H A DnbrOfWorkers.R25 workers <- availableWorkers() globalVar
26 nworkers <- length(workers)
59 workers <- rep("localhost", times = 2L) globalVar
60 plan(cluster, workers = workers)
63 stopifnot(n == length(workers))
71 plan(remote, workers = workers)
74 stopifnot(n == length(workers))
94 workers <- makeClusterPSOCK(2L) globalVar
95 print(workers)
96 plan(cluster, workers = workers)
[all …]
/dports/www/uwsgi/uwsgi-2.0.20/core/
H A Dmaster_checks.c10 if (uwsgi.workers[i].pid > 0) { in uwsgi_master_check_death()
100 uwsgi.workers[i].pid = 0; in uwsgi_master_commit_status()
120 if (uwsgi.workers[i].cheaped == 0 && uwsgi.workers[i].pid > 0) { in uwsgi_master_check_idle()
149 uwsgi.workers[i].cheaped = 1; in uwsgi_master_check_idle()
150 if (uwsgi.workers[i].pid == 0) in uwsgi_master_check_idle()
171 uwsgi.workers[i].pid = 0; in uwsgi_master_check_idle()
172 uwsgi.workers[i].rss_size = 0; in uwsgi_master_check_idle()
173 uwsgi.workers[i].vsz_size = 0; in uwsgi_master_check_idle()
206 uwsgi.workers[i].vsz_size = 0; in uwsgi_master_check_workers_deadline()
214 uwsgi.workers[i].rss_size = 0; in uwsgi_master_check_workers_deadline()
[all …]
/dports/devel/R-cran-parallelly/parallelly/R/
H A DavailableWorkers.R279 workers <- apply_fallback(workers)
286 workers <- apply_fallback(workers)
289 workers <- workers[[idx]]
291 workers <- apply_fallback(workers)
294 workers <- workers[[idx]]
298 if (is.character(workers) && length(workers) == 0) workers <- default
307 stop_if_not(is.character(workers), length(workers) >= min_count, all(nchar(workers) > 0))
310 workers
590 workers <- workers[-idx_fallback]
599 workers <- workers[-idx_system]
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/.rubocop_todo/gitlab/
H A Dnamespaced_class.yml757 - app/workers/admin_email_worker.rb
803 - app/workers/export_csv_worker.rb
805 - app/workers/file_hook_worker.rb
818 - app/workers/irker_worker.rb
826 - app/workers/merge_worker.rb
829 - app/workers/new_issue_worker.rb
831 - app/workers/new_note_worker.rb
839 - app/workers/pages_worker.rb
847 - app/workers/post_receive.rb
866 - app/workers/rebase_worker.rb
[all …]
/dports/benchmarks/nosqlbench/nosqlbench-0.0.20151214/sources/
H A Dnb_worker.c50 workers->head = NULL; in nb_workers_init()
51 workers->tail = NULL; in nb_workers_init()
52 workers->count = 0; in nb_workers_init()
57 struct nb_worker *c = workers->head, *n; in nb_workers_free()
79 n->id = workers->count; in nb_workers_create()
96 if (workers->head == NULL) in nb_workers_create()
97 workers->head = n; in nb_workers_create()
99 workers->tail->next = n; in nb_workers_create()
100 workers->tail = n; in nb_workers_create()
101 workers->count++; in nb_workers_create()
[all …]

12345678910>>...242