- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Every (0.12 sec)
-
cmd/xl-storage-disk-id-check.go
func (e *lockedLastMinuteLatency) add(value time.Duration) { e.addSize(value, 0) } // addSize will add a duration and size. func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) { // alloc on every call, so we have a clean entry to swap in. t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/data-usage.go
dataUsageJSON, err := json.Marshal(dataUsageInfo) if err != nil { scannerLogIf(ctx, err) continue } if attempts > 10 { saveConfig(ctx, objAPI, dataUsageObjNamePath+".bkp", dataUsageJSON) // Save a backup every 10th update. attempts = 1 } if err = saveConfig(ctx, objAPI, dataUsageObjNamePath, dataUsageJSON); err != nil { scannerLogOnceIf(ctx, err, dataUsageObjNamePath) } attempts++ } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
doneCh := make(chan error, 1) defer xioutil.SafeClose(doneCh) // Save rebalance.bin periodically. go func() { // Update rebalance.bin periodically once every 5-10s, chosen randomly // to avoid multiple pool leaders herding to update around the same // time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration {
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/storage-rest-server.go
c.done = nil } return c.rc.Close() } // keepHTTPReqResponseAlive can be used to avoid timeouts with long storage // operations, such as bitrot verification or data usage scanning. // Every 10 seconds a space character is sent. // keepHTTPReqResponseAlive will wait for the returned body to be read before starting the ticker. // The returned function should always be called to release resources.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/batch-rotate.go
stopFn(result, nil) } ri.trackCurrentBucketObject(r.Bucket, result, success) ri.RetryAttempts = attempts globalBatchJobsMetrics.save(job.ID, ri) // persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) if success { break } if delay > 0 { time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay))) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/batch-expire.go
go func() { saveTicker := time.NewTicker(10 * time.Second) defer saveTicker.Stop() for { select { case <-saveTicker.C: // persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) case <-ctx.Done(): // persist in-memory state immediately before exiting due to context cancellation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
internal/grid/types.go
// call Recycle() when the object is no longer needed. // The recycler should handle nil pointers. type Recycler interface { Recycle() } // MSS is a map[string]string that can be serialized. // It is not very efficient, but it is only used for easy parameter passing. type MSS map[string]string // Get returns the value for the given key. func (m *MSS) Get(key string) string { if m == nil { return "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/test-utils_test.go
) // Temp files created in default Tmp dir var globalTestTmpDir = os.TempDir() // reseed - returns a new seed every time the function is called. func reseed() uint32 { return uint32(time.Now().UnixNano() + int64(os.Getpid())) } // nextSuffix - provides a new unique suffix every time the function is called. func nextSuffix() string { randmu.Lock() r := randN // Initial seed required, generate one.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/common-main.go
err = fmt.Errorf("Unable to load TLS certificate '%s,%s': %w", certFile, keyFile, err) bootLogIf(GlobalContext, err, logger.ErrorKind) } } secureConn = true // Certs might be symlinks, reload them every 10 seconds. manager.UpdateReloadDuration(10 * time.Second) // syscall.SIGHUP to reload the certs. manager.ReloadOnSignal(syscall.SIGHUP) return x509Certs, manager, secureConn, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/iam-store.go
if v == nil { v = set.CreateStringSet(group) } else { v.Add(group) } c.iamUserGroupMemberships[member] = v } } // removeGroupFromMembershipsMap - removes the group from every member // in the cache. IMPORTANT: Assumes c.Lock() is held by caller. func (c *iamCache) removeGroupFromMembershipsMap(group string) { for member, groups := range c.iamUserGroupMemberships { if !groups.Contains(group) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2)