- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Sleep (0.14 sec)
-
internal/rest/client.go
if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt)) sleep := unit * time.Duration(1<<attempt) if sleep > cap { sleep = cap } sleep -= time.Duration(r.Float64() * float64(sleep-unit)) return sleep } } func (c *Client) runHealthCheck() bool { // Start goroutine that will attempt to reconnect.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
if err != nil { t.Fatal(err) } if p.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled { return } time.Sleep(1 * time.Second) } t.Fatal("Pod not annotated") } func assertPodNotAnnotated(t *testing.T, client kube.Client, pod *corev1.Pod) { for i := 0; i < 5; i++ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/mrf.go
} } now := time.Now() if now.Sub(u.queued) < time.Second { // 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 }
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) -
internal/grid/grid_test.go
// Block until test is done. <-stopBlocking return nil }) }() <-nowBlocking // Wait for the receiver channel to fill. for len(st.responses) != cap(st.responses) { time.Sleep(time.Millisecond) } cancel() <-serverCanceled local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) { if !closed { t.Error("expected outgoing closed") } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/bucket-replication.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cni/pkg/nodeagent/net_test.go
// sure the netns is closed eventually. func assertNSClosed(t *testing.T, closed *atomic.Bool) { for i := 0; i < 5; i++ { if closed.Load() { return } time.Sleep(1 * time.Second) } t.Fatal("NS not closed")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} return } if configRetriableErrors(err) { decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pools %v: %w: retrying..", pools, err)) time.Sleep(time.Second + time.Duration(r.Float64()*float64(5*time.Second))) continue } decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pool %v: %w", pools, err)) return } } }()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/metacache-set.go
o.objectPath(0), "", ReadOptions{}) if err != nil { time.Sleep(retryDelay250) retries++ continue } break } } retryWait := func() { retries++ if retries == 1 { time.Sleep(retryDelay) } else { time.Sleep(retryDelay250) } } // Load first part metadata...
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/data-scanner.go
t := time.Now() return func() { doneAt := time.Now() d.Sleep(ctx, doneAt.Sub(t)) } } // Sleep sleeps the specified time multiplied by the sleep factor. // If the factor is updated the sleep will be done again with the new factor. func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
p.health.waiting.Add(1) go p.monitorDiskStatus(spent, fn) } } // Offset checks a bit. time.Sleep(time.Duration(rng.Int63n(int64(1 * time.Second)))) dctx, dcancel := context.WithCancel(ctx) started := time.Now() go func() { timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout()) select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)