- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 293 for workers (0.15 sec)
-
docs/config/README.md
Each node is responsible of healing its local drives; Each drive will have multiple heal workers which is the quarter of the number of CPU cores of the node or the quarter of the configured nr_requests of the drive (https://www.kernel.org/doc/Documentation/block/queue-sysfs.txt). It is also possible to provide a custom number of workers by using this command: `mc admin config set alias/ heal drive_workers=100` . ``` ~ mc admin config set alias/ heal KEY:
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
docs/en/docs/deployment/docker.md
So, in this case, you **would not** want to have a process manager like Gunicorn with Uvicorn workers, or Uvicorn using its own Uvicorn workers. You would want to have just a **single Uvicorn process** per container (but probably multiple containers).
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 34K bytes - Viewed (0) -
cmd/batch-expire.go
lastObject := ri.Object now := time.Now().UTC() workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_EXPIRATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2))) if err != nil { return err } wk, err := workers.New(workerSize) if err != nil { // invalid worker size. return err } ctx, cancel := context.WithCancel(ctx) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
.teamcity/test-buckets.json
"ivy", "testing-native", "maven", "integ-test" ] }, { "parallelizationMethod":{ "name":"TestDistribution" }, "subprojects":[ "workers", "model-core", "language-groovy", "build-init", "logging", "plugins-groovy", "kotlin-dsl", "plugins-java", "samples", "plugin-development",
Json - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Mon May 06 14:29:38 GMT 2024 - 49.9K bytes - Viewed (0) -
internal/s3select/csv/reader.go
current [][]string // 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/config/api/help.go
config.HelpKV{ Key: apiReplicationMaxWorkers, Description: `set the maximum number of replication workers` + defaultHelpPostfix(apiReplicationMaxWorkers), Optional: true, Type: "number", }, config.HelpKV{ Key: apiTransitionWorkers, Description: `set the number of transition workers` + defaultHelpPostfix(apiTransitionWorkers), Optional: true, Type: "number", },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/batch-handlers.go
// newBatchJobPool creates a pool of job manifest workers of specified size func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool { jpool := &BatchJobPool{ ctx: ctx, objLayer: o, jobCh: make(chan *BatchJobRequest, 10000), workerKillCh: make(chan struct{}, workers), jobCancelers: make(map[string]context.CancelFunc), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
const envRebalanceWorkers = "_MINIO_REBALANCE_WORKERS" workerSize, err := env.GetInt(envRebalanceWorkers, len(pool.sets)) if err != nil { rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/global-heal.go
if v := globalHealConfig.GetWorkers(); v > 0 { numHealers = uint64(v) } healingLogEvent(ctx, fmt.Sprintf("Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers)) jt, _ := workers.New(int(numHealers)) var retErr error // Heal all buckets with all objects for _, bucket := range healBuckets { if tracker.isHealed(bucket) { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
tensorflow/c/eager/immediate_execution_distributed_manager.h
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 Status InitializeLocalOnlyContext(const ServerDef& server_def,
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 2.9K bytes - Viewed (0)