Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getStaleUploadsCleanupInterval (0.16 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  3. cmd/erasure-server-pool.go

    	go z.cleanupStaleMPCache(ctx)
    
    	return z, nil
    }
    
    func (z *erasureServerPools) cleanupStaleMPCache(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			z.mpCache.Range(func(id string, info MultipartInfo) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top