/dports/www/mattermost-server/mattermost-server-6.0.2/jobs/ |
H A D | workers.go | 51 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 D | jobs_watcher.go | 20 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 D | nbrOfWorkers.R | 25 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 D | ClusterRegistry.R | 9 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 D | multicore.R | 57 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 D | multisession.R | 64 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 D | ClusterFuture-class.R | 78 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 D | h2_workers.c | 80 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 D | h2_workers.c | 81 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 D | TIMINGS | 3 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 D | include.am | 9 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 D | modjk.py | 21 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 D | main.cpp | 121 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 D | ppqueue.go | 43 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 D | ppqueue.go | 43 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 D | ppqueue.go | 43 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 D | ppqueue.go | 43 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 D | scipy_fft.py | 101 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 D | availableWorkers.R | 48 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 D | basic.py | 12 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 D | nbrOfWorkers.R | 25 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 D | master_checks.c | 10 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 D | availableWorkers.R | 279 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 D | namespaced_class.yml | 757 - 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 D | nb_worker.c | 50 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 …]
|