Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for cycle (0.13 sec)

  1. cmd/metrics-resource.go

    // was collected since the server started, and the sum,
    // average and max values across the same.
    type ResourceMetric struct {
    	Name   MetricName
    	Labels map[string]string
    
    	// value captured in current cycle
    	Current float64
    
    	// Used when system provides cumulative (since uptime) values
    	// helps in calculating the current value by comparing the new
    	// cumulative value with previous one
    	Cumulative float64
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	minSleep time.Duration
    
    	// cycle will be closed
    	cycle chan struct{}
    
    	// isScanner should be set when this is used by the scanner
    	// to record metrics.
    	isScanner bool
    }
    
    // newDynamicSleeper
    func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    		maxSleep:  maxWait,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  3. cmd/data-usage-cache.go

    }
    
    // mod returns true if the hash mod cycles == cycle.
    // If cycles is 0 false is always returned.
    // If cycles is 1 true is always returned (as expected).
    func (h dataUsageHash) mod(cycle uint32, cycles uint32) bool {
    	if cycles <= 1 {
    		return cycles == 1
    	}
    	return uint32(xxhash.Sum64String(string(h)))%cycles == cycle%cycles
    }
    
    // modAlt returns true if the hash mod cycles == cycle.
    // This is out of sync with mod.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  4. cmd/config-current.go

    			errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err))
    		} else {
    			// update dynamic scanner values.
    			scannerIdleMode.Store(scannerCfg.IdleMode)
    			scannerCycle.Store(scannerCfg.Cycle)
    			scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions)
    			scannerExcessFolders.Store(scannerCfg.ExcessFolders)
    			configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait))
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    	// were changes to the in-memory cache we should wait for the next
    	// cycle until we can safely update the in-memory cache.
    	//
    	// An in-memory cache must be replaced only if we know for sure that the
    	// values loaded from disk are not stale. They might be stale if the
    	// cached.updatedAt is more recent than the refresh cycle began.
    	if cache.updatedAt.Before(loadedAt) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  6. cmd/xl-storage.go

    		}
    		return res, err
    	}
    
    	if len(xlMeta.versions) <= 10 {
    		// any number of versions beyond this is excessive
    		// avoid healing such objects in this manner, let
    		// it heal during the regular scanner cycle.
    		dst := []byte{}
    		for _, ver := range xlMeta.versions {
    			dst = slices.Grow(dst, 16)
    			copy(dst[len(dst):], ver.header.VersionID[:])
    		}
    		res.Sign = dst
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/erasure.go

    	}
    
    	// Collect disks we can use.
    	disks, healing := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		scannerLogIf(ctx, errors.New("data-scanner: all drives are offline or being healed, skipping scanner cycle"))
    		return nil
    	}
    
    	// Load bucket totals
    	oldCache := dataUsageCache{}
    	if err := oldCache.load(ctx, er, dataUsageCacheName); err != nil {
    		return err
    	}
    
    	// New cache..
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  8. cmd/erasure-sets.go

    	if !globalIsTesting {
    		go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval)
    	}
    
    	return s, nil
    }
    
    // cleanup ".trash/" folder every 5m minutes with sufficient sleep cycles, between each
    // deletes a dynamic sleeper is used with a factor of 10 ratio with max delay between
    // deletes to be 2 seconds.
    func (s *erasureSets) cleanupDeletedObjects(ctx context.Context) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top