Home
last modified time | relevance | path

Searched refs:activeWorkers (Results 1 – 17 of 17) sorted by relevance

/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/ui/src/common/
H A Dwasm_engine_proxy.ts21 const activeWorkers = new Map<string, Worker>(); constant
34 if (activeWorkers.has(id)) {
39 activeWorkers.set(id, activeWorker);
44 if (!activeWorkers.has(id)) {
47 activeWorkers.get(id)!.terminate();
48 activeWorkers.delete(id);
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/ui/src/common/
H A Dwasm_engine_proxy.ts21 const activeWorkers = new Map<string, Worker>(); constant
34 if (activeWorkers.has(id)) {
39 activeWorkers.set(id, activeWorker);
44 if (!activeWorkers.has(id)) {
47 activeWorkers.get(id)!.terminate();
48 activeWorkers.delete(id);
/dports/net/goreplay/goreplay-1.2.0/
H A Doutput_binary.go27 activeWorkers int64 member
88 atomic.AddInt64(&o.activeWorkers, 1)
104 workersCount := atomic.LoadInt64(&o.activeWorkers)
108 atomic.AddInt64(&o.activeWorkers, -1)
127 workersCount := atomic.LoadInt64(&o.activeWorkers)
H A Doutput_http.go95 activeWorkers int64 member
161 atomic.AddInt64(&o.activeWorkers, int64(newWorkers))
179 atomic.AddInt64(&o.activeWorkers, 1)
193 atomic.AddInt64(&o.activeWorkers, -1)
222 workersCount := int(atomic.LoadInt64(&o.activeWorkers))
226 atomic.AddInt64(&o.activeWorkers, -1)
252 workersCount := int(atomic.LoadInt64(&o.activeWorkers))
/dports/devel/binaryen/binaryen-version_98/src/
H A Dwasm-module-building.h96 std::atomic<uint32_t> liveWorkers, activeWorkers, availableFuncs, variable
116 nextFunction(0), numWorkers(0), liveWorkers(0), activeWorkers(0), in OptimizingIncrementalModuleBuilder()
146 activeWorkers.store(0); in OptimizingIncrementalModuleBuilder()
278 self->activeWorkers++; in workerMain()
286 self->activeWorkers--; in workerMain()
296 self->activeWorkers++; in workerMain()
/dports/security/xray-core/Xray-core-1.5.0/app/reverse/
H A Dbridge.go49 var activeWorkers []*BridgeWorker
53 activeWorkers = append(activeWorkers, w)
57 if len(activeWorkers) != len(b.workers) {
58 b.workers = activeWorkers
H A Dportal.go133 var activeWorkers []*PortalWorker
136 activeWorkers = append(activeWorkers, w)
140 if len(activeWorkers) != len(p.workers) {
141 p.workers = activeWorkers
/dports/net/v2ray/v2ray-core-4.36.2/app/reverse/
H A Dbridge.go51 var activeWorkers []*BridgeWorker
55 activeWorkers = append(activeWorkers, w)
59 if len(activeWorkers) != len(b.workers) {
60 b.workers = activeWorkers
H A Dportal.go135 var activeWorkers []*PortalWorker
138 activeWorkers = append(activeWorkers, w)
142 if len(activeWorkers) != len(p.workers) {
143 p.workers = activeWorkers
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/caddyserver/certmagic/
H A Dasync.go16 activeWorkers int member
44 if jm.activeWorkers < jm.maxConcurrentJobs {
45 jm.activeWorkers++
54 jm.activeWorkers--
/dports/www/gitea/gitea-1.16.5/vendor/github.com/caddyserver/certmagic/
H A Dasync.go19 activeWorkers int member
48 if jm.activeWorkers < jm.maxConcurrentJobs {
49 jm.activeWorkers++
66 jm.activeWorkers--
/dports/math/gap/gap-4.11.0/hpcgap/lib/hpc/
H A Dtasks.g461 taskman := rec ( activeWorkers := 0,
475 taskman.activeWorkers := taskman.activeWorkers+1;
478 taskman.activeWorkers := taskman.activeWorkers-1;
480 if taskman.activeWorkers<Tasks.Initial then
489 taskman.activeWorkers := taskman.activeWorkers+1;
494 if taskman.activeWorkers>Tasks.Initial then
500 taskman.activeWorkers := taskman.activeWorkers-1;
/dports/math/gap/gap-4.11.0/hpcgap/lib/distributed/
H A Ddist_tasks.g605 activeWorkers:= 0,
631 taskman.activeWorkers := taskman.activeWorkers+1;
636 taskman.activeWorkers := taskman.activeWorkers-1;
638 if taskman.activeWorkers<Tasks.Initial then
647 taskman.activeWorkers := taskman.activeWorkers+1;
652 if taskman.activeWorkers>Tasks.Initial then
669 taskman.activeWorkers := taskman.activeWorkers-1;
696 … finishingState := rec ( myWorkersToFinish := taskman.activeWorkers + taskman.suspendedWorkers );
/dports/security/xray-core/Xray-core-1.5.0/common/mux/
H A Dclient.go67 var activeWorkers []*ClientWorker
70 activeWorkers = append(activeWorkers, w)
73 p.workers = activeWorkers
/dports/net/v2ray/v2ray-core-4.36.2/common/mux/
H A Dclient.go67 var activeWorkers []*ClientWorker
70 activeWorkers = append(activeWorkers, w)
73 p.workers = activeWorkers
/dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/internal/fuzz/
H A Dfuzz.go192 activeWorkers := len(workers)
220 activeWorkers--
221 if activeWorkers == 0 {
/dports/lang/spidermonkey60/firefox-60.9.0/dom/workers/
H A DRuntimeService.cpp1798 uint32_t activeWorkers = 0; in CrashIfHanging() local
1807 activeWorkers += aData->mActiveWorkers.Length(); in CrashIfHanging()
1823 MOZ_DIAGNOSTIC_ASSERT(activeWorkers + activeServiceWorkers + inactiveWorkers); in CrashIfHanging()
1829 activeWorkers, activeServiceWorkers, inactiveWorkers); in CrashIfHanging()