- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Nimer (0.14 sec)
-
internal/http/server.go
// Wait for opened connection to be closed up to Shutdown timeout. shutdownTimeout := srv.ShutdownTimeout shutdownTimer := time.NewTimer(shutdownTimeout) defer shutdownTimer.Stop() timer := time.NewTimer(nextPollInterval()) defer timer.Stop() for { select { case <-shutdownTimer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } // Write all running goroutines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/mrf.go
// let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.scanMode != 0 { scan = u.scanMode } if u.object == "" { healBucket(u.bucket, scan) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/license-update.go
for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C: if globalSubnetConfig.Registered() { performLicenseUpdate(ctx, objAPI) } // Reset the timer for next cycle. licenseUpdateTimer.Reset(licUpdateCycle) } } } func performLicenseUpdate(ctx context.Context, objectAPI ObjectLayer) { // the subnet license renewal api renews the license only
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
// time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration { return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64()) } timer := time.NewTimer(randSleepFor()) defer timer.Stop() var ( quit bool traceMsg string ) for { select { case rebalErr := <-doneCh: quit = true now := time.Now()
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/iam.go
randAmt := time.Duration(r.Float64() * float64(baseInterval)) return baseInterval/2 + randAmt } var maxDurationSecondsForLog float64 = 5 timer := time.NewTimer(waitInterval()) defer timer.Stop() for { select { case <-timer.C: // Load all IAM items (except STS creds) periodically. refreshStart := time.Now() if err := sys.Load(ctx, false); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/dsync/dsync_test.go
defer cancel() dm.Unlock(ctx) unlockReturned <- struct{}{} }() timer := time.NewTimer(2 * testDrwMutexUnlockCallTimeout) defer timer.Stop() select { case <-unlockReturned: t.Fatal("Unlock timed out, which should not happen") case <-timer.C: } } // Borrowed from mutex_test.go func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
sha256hex := "" // benchmark utility which helps obtain number of allocations and bytes allocated per ops. b.ReportAllocs() // the actual benchmark for PutObject starts here. Reset the benchmark timer. b.ResetTimer() for i := 0; i < b.N; i++ { // insert the object. objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 8.2K bytes - Viewed (0) -
cmd/metrics-resource.go
collectLocalResourceMetrics() for { select { case <-GlobalContext.Done(): return case <-metricsTimer.C: collectLocalResourceMetrics() // Reset the timer for next cycle. metricsTimer.Reset(resourceMetricsCollectionInterval) } } } // minioResourceCollector is the Collector for resource metrics type minioResourceCollector struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// sequence automatically resumes. The return value indicates if the // operation succeeded. func (h *healSequence) pushHealResultItem(r madmin.HealResultItem) error { // start a timer to keep an upper time limit to find an empty // slot to add the given heal result - if no slot is found it // means that the server is holding the maximum amount of // heal-results in memory and the client has not consumed it
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/kms/kes.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0)