Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newTimer (0.08 sec)

  1. cmd/bucket-replication.go

    // PersistToDisk persists in-memory resync metadata stats to disk at periodic intervals
    func (s *replicationResyncer) PersistToDisk(ctx context.Context, objectAPI ObjectLayer) {
    	resyncTimer := time.NewTimer(resyncTimeInterval)
    	defer resyncTimer.Stop()
    
    	// For each bucket name, store the last timestamp of the
    	// successful save of replication status in the backend disks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    		// Start profiling locally as well.
    		prof, err := startProfiler(profiler)
    		if err == nil {
    			globalProfiler[profiler] = prof
    		}
    	}
    	globalProfilerMu.Unlock()
    
    	timer := time.NewTimer(duration)
    	defer timer.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Stop remote profiles
    			go globalNotificationSys.DownloadProfilingData(GlobalContext, io.Discard)
    
    			// Stop local
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    func (c *SiteReplicationSys) startHealRoutine(ctx context.Context, objAPI ObjectLayer) {
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    	defer cancel()
    
    	healTimer := time.NewTimer(siteHealTimeInterval)
    	defer healTimer.Stop()
    
    	var maxRefreshDurationSecondsForLog float64 = 10 // 10 seconds..
    
    	for {
    		select {
    		case <-healTimer.C:
    			c.RLock()
    			enabled := c.enabled
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top