Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 618 for Flock (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top