- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for workerCh (0.07 sec)
-
cmd/bucket-replication.go
if (checkOld > 0 && len(p.workers) != checkOld) || n == len(p.workers) || n < 1 { // Either already satisfied or worker count changed while we waited for the lock. return } for len(p.workers) < n { input := make(chan ReplicationWorkerOperation, 10000) p.workers = append(p.workers, input) go p.AddWorker(input, &p.activeWorkers) } for len(p.workers) > n { worker := p.workers[len(p.workers)-1]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
docs/en/docs/deployment/server-workers.md
In particular, when running on **Kubernetes** you will probably **not** want to use workers and instead run **a single Uvicorn process per container**, but I'll tell you about it later in that chapter. /// ## Multiple Workers You can start multiple workers with the `--workers` command line option: //// tab | `fastapi` If you use the `fastapi` command: <div class="termy">
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 8.7K bytes - Viewed (0) -
docs/pt/docs/deployment/server-workers.md
/// ## Vários trabalhadores Você pode iniciar vários trabalhadores com a opção de linha de comando `--workers`: //// tab | `fastapi` Se você usar o comando `fastapi`: <div class="termy"> ```console $ <pre> <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:single">main.py</u> <font color="#3465A4">INFO </font> Using path <font color="#3465A4">main.py</font>
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Sep 20 11:01:03 UTC 2024 - 9K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
workers = workers[:len(workers)-1] worker <- expiryOp(nil) es.stats.workers.Add(-1) } // Atomically replace workers. es.workers.Store(&workers) } // Worker handles 4 types of expiration tasks. // 1. Expiry of objects, includes regular and transitioned objects // 2. Expiry of noncurrent versions due to NewerNoncurrentVersions
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
docs/en/docs/deployment/docker.md
And if you need to have multiple workers, you can simply use the `--workers` command line option. /// note | Technical Details The Docker image was created when Uvicorn didn't support managing and restarting dead workers, so it was needed to use Gunicorn with Uvicorn, which added quite some complexity, just to have Gunicorn manage and restart the Uvicorn worker processes.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 28.5K bytes - Viewed (0) -
docs/en/docs/deployment/concepts.md
Here are some possible combinations and strategies: * **Uvicorn** with `--workers` * One Uvicorn **process manager** would listen on the **IP** and **port**, and it would start **multiple Uvicorn worker processes**. * **Kubernetes** and other distributed **container systems**
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 17.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 { nWorkers := h.workers.Load() if nWorkers < h.maxWorkers {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
tensorflow/c/eager/immediate_execution_distributed_manager.h
int64_t init_timeout_in_ms, int retries, bool clear_existing_contexts = false) = 0; // Initializes context for the local worker and no contexts will be created // for remote workers. Currently this only works for resetting context. // TODO(b/289445025): Consider removing this when we find a proper fix. virtual absl::Status InitializeLocalOnlyContext(const ServerDef& server_def,
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 2.9K bytes - Viewed (0) -
.teamcity/test-buckets.json
"problems-api", "plugins-java-base", "build-cache" ] }, { "parallelizationMethod":{ "name":"TestDistribution" }, "subprojects":[ "workers", "wrapper-main", "testing-base-infrastructure", "messaging", "war", "instrumentation-agent-services", "build-profile", "resources-gcs", "ear",
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Oct 08 11:14:16 UTC 2024 - 87.8K bytes - Viewed (0) -
internal/s3select/json/preader.go
current []jstream.KVS // current block of results to be returned recordsRead int // number of records read in current slice input chan *queueItem // input for workers queue chan *queueItem // output from workers in order err error // global error state, only touched by Reader.Read bufferPool sync.Pool // pool of []byte objects for input
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0)