- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 618 for Flock (0.01 seconds)
-
cmd/bootstrap-messages.go
func (bs *bootstrapTracer) Record(info madmin.TraceInfo) { bs.mu.Lock() defer bs.mu.Unlock() if len(bs.info) > bootstrapTraceLimit { return } bs.info = append(bs.info, info) } func (bs *bootstrapTracer) Events() []madmin.TraceInfo { traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit) bs.mu.RLock() traceInfo = append(traceInfo, bs.info...) bs.mu.RUnlock() return traceInfo
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 1.7K bytes - Click Count (0) -
cmd/api-router.go
) func newHTTPServerFn() *xhttp.Server { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalHTTPServer } func setHTTPServer(h *xhttp.Server) { globalObjLayerMutex.Lock() globalHTTPServer = h globalObjLayerMutex.Unlock() } func newConsoleServerFn() *consoleapi.Server { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalConsoleSrv }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 23.3K bytes - Click Count (0) -
internal/config/callhome/callhome.go
// Enabled - indicates if callhome is enabled or not func (c *Config) Enabled() bool { configLock.RLock() defer configLock.RUnlock() return c.Enable } // FrequencyDur - returns the currently configured callhome frequency func (c *Config) FrequencyDur() time.Duration { configLock.RLock() defer configLock.RUnlock() if c.Frequency == 0 { return callhomeCycleDefault } return c.Frequency
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 2.6K bytes - Click Count (0) -
doc/go_mem.html
<p class="rule"> For any call to <code>l.RLock</code> on a <code>sync.RWMutex</code> variable <code>l</code>, there is an <i>n</i> such that the <i>n</i>th call to <code>l.Unlock</code> is synchronized before the return from <code>l.RLock</code>, and the matching call to <code>l.RUnlock</code> is synchronized before the return from call <i>n</i>+1 to <code>l.Lock</code>. </p> <p class="rule">
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
internal/dsync/lock-args_gen.go
Klaus Post <******@****.***> 1759093161 +0200
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName) lkCtx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err)) return err } defer lock.Unlock(lkCtx) ctx = lkCtx.Context()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
internal/lock/lock_windows.go
} } return &LockedFile{File: f}, nil } // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.9K bytes - Click Count (0) -
internal/dsync/lock-args_gen_test.go
Klaus Post <******@****.***> 1759093161 +0200
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
cmd/site-replication-metrics.go
srs.Failed.addsize(st.TransferSize, st.Err) case st.Pending: } sr.M[dID] = srs } func (sr *SRStats) get() map[string]SRMetric { epMap := globalBucketTargetSys.healthStats() sr.lock.RLock() defer sr.lock.RUnlock() m := make(map[string]SRMetric, len(sr.M)) for dID, v := range sr.M { t := newXferStats() mx := make(map[RMetricName]XferStats) if v.XferRateLrg != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.2K bytes - Click Count (0) -
internal/config/heal/heal.go
// - '> 0' interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock() defer configMutex.RUnlock() return opts.cache.bitrotCycle } // Clone safely the heal configuration func (opts Config) Clone() (int, time.Duration, string) { configMutex.RLock() defer configMutex.RUnlock() return opts.IOCount, opts.Sleep, opts.Bitrot }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Nov 04 19:06:02 GMT 2024 - 4.9K bytes - Click Count (0)