Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getStaleUploadsCleanupInterval (0.21 sec)

  1. cmd/handler-api.go

    		return []string{"*"}
    	}
    
    	corsAllowOrigins := make([]string, len(t.corsAllowOrigins))
    	copy(corsAllowOrigins, t.corsAllowOrigins)
    	return corsAllowOrigins
    }
    
    func (t *apiConfig) getStaleUploadsCleanupInterval() time.Duration {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.staleUploadsCleanupInterval == 0 {
    		return 6 * time.Hour // default 6 hours
    	}
    
    	return t.staleUploadsCleanupInterval
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    			timer.Reset(globalAPIConfig.getDeleteCleanupInterval())
    		}
    	}
    }
    
    func (s *erasureSets) cleanupStaleUploads(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    				wg.Add(1)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
Back to top