- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for corners (0.22 sec)
-
cmd/bucket-replication.go
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] p.workers = p.workers[:len(p.workers)-1] xioutil.SafeClose(worker) } } // ResizeWorkerPriority sets replication failed workers pool size
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
.teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt
"\"-Porg.gradle.performance.db.username=%performance.db.username%\"", "-DenableTestDistribution=%enableTestDistribution%", "-Dorg.gradle.workers.max=%maxParallelForks%", "-PmaxParallelForks=%maxParallelForks%", pluginPortalUrlOverride, "-s", "--no-configuration-cache", "%additional.gradle.parameters%",
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.3K 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 Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_cluster_replication_current_active_workers` | Total number of active replication workers | | `minio_cluster_replication_average_active_workers` | Average number of active replication workers |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
cmd/erasure-server-pool-decom.go
const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS" workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets)) if err != nil { decomLogIf(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 Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.3K bytes - Viewed (1) -
.github/workflows/iam-integrations.yaml
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 4.2K bytes - Viewed (0) -
.teamcity/src/test/kotlin/ApplyDefaultConfigurationTest.kt
val expectedInstallationPaths = if (os == Os.WINDOWS) windowsPaths else linuxPaths
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
} } if errors.Is(err, grid.ErrDisconnected) { return true } // More corner cases suitable for storage REST API switch { // A peer node can be in shut down phase and proactively // return 503 server closed error, consider it as an offline node case strings.Contains(err.Error(), http.ErrServerClosed.Error()): return true // Corner case, the server closed the connection with a keep-alive timeout
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
go.sum
github.com/coreos/go-oidc/v3 v3.10.0 h1:tDnXHnLyiTVyT/2zLDGj09pFPkhND8Gl8lnTRhoEaJU= github.com/coreos/go-oidc/v3 v3.10.0/go.mod h1:5j11xcw0D3+SGxn6Z/WFADsgcWVMyNAlSQupk0KK3ac= github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk= github.com/coreos/go-semver v0.3.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk= github.com/coreos/go-semver v0.3.1 h1:yi21YpKnrx1gt5R+la8n5WgS0kCrsPp33dmEyHReZr4=
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 19:52:35 GMT 2024 - 110.5K bytes - Viewed (0)