- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 3,055 for Done (0.13 sec)
-
cmd/erasure-common.go
disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return } di, err := disks[i].DiskInfo(context.Background(), DiskInfoOptions{}) if err != nil || di.Healing { // - Do not consume disks which are not reachable
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/grid/connection.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/admin-handlers.go
hostMap = make(map[string]struct{}, len(hosts)) for _, k := range hosts { if k != "" { hostMap[k] = struct{}{} } } } dID := r.Form.Get("by-depID") done := ctx.Done() ticker := time.NewTicker(interval) defer ticker.Stop() w.Header().Set(xhttp.ContentType, string(mimeJSON)) enc := json.NewEncoder(w) for n > 0 { var m madmin.RealtimeMetrics
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/peer-rest-server.go
} done := keepHTTPResponseAlive(w) result, err := selfSpeedTest(r.Context(), speedTestOpts{ objectSize: size, concurrency: concurrent, duration: duration, storageClass: storageClass, bucketName: bucketName, enableSha256: enableSha256, }) if err != nil { result.Error = err.Error() } done(nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
buildscripts/disable-root.sh
nr_servers=4 addr="localhost" args="" for ((i = 0; i < $((nr_servers)); i++)); do args="$args $scheme://$addr:$((9100 + i))/${HOME}/tmp/dist/path1/$i" done echo $args for ((i = 0; i < $((nr_servers)); i++)); do (minio server --address ":$((9100 + i))" $args 2>&1 >/tmp/log$i.txt) & done sleep 10s if [ ! -f ./mc ]; then wget --quiet -O ./mc https://dl.minio.io/client/mc/release/linux-amd64/./mc && chmod +x mc fi
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 3.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/erasure-sets.go
timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval()) defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: var wg sync.WaitGroup for _, set := range s.sets { wg.Add(1) go func(set *erasureObjects) { defer wg.Done() if set == nil { return } set.cleanupDeletedObjects(ctx) }(set) } wg.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
internal/grid/handlers.go
// This must be done prior to registering the handler. func (h *StreamTypeHandler[Payload, Req, Resp]) WithOutCapacity(out int) *StreamTypeHandler[Payload, Req, Resp] { h.OutCapacity = out return h } // WithInCapacity adjusts the input capacity from the handler perspective. // This must be done prior to registering the handler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
if r == nil { return } for { select { case <-ctx.Done(): return case <-r.wTimer.C: r.wlock.Lock() r.workers.update() r.wlock.Unlock() } } } func (r *ReplicationStats) collectQueueMetrics(ctx context.Context) { if r == nil { return } for { select { case <-ctx.Done(): return case <-r.qTimer.C: r.qCache.update() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
docs/site-replication/run-ssec-object-replication-with-compression.sh
echo "done" if [ ! -f ./mc ]; then echo -n "Downloading MinIO client ..." wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc && chmod +x mc echo "done" fi sleep 10 export MC_HOST_minio1=https://minio:minio123@localhost:9001
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 08:43:09 GMT 2024 - 8.1K bytes - Viewed (0)