Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for cycle (0.17 sec)

  1. docs/config/README.md

    ARGS:
    delay     (float)     scanner delay multiplier, defaults to '10.0'
    max_wait  (duration)  maximum wait time between operations, defaults to '15s'
    cycle     (duration)  time duration between scanner cycles
    ```
    
    Example: the following setting will decrease the scanner speed by a factor of 3, reducing the system resource use, but increasing the latency of updates being reflected.
    
    ```sh
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  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/data-usage_test.go

    	}
    	createUsageTestFiles(t, base, bucket, files)
    	err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	// Changed dir must be picked up in this many cycles.
    	for i := 0; i < dataUsageUpdateDirCycles; i++ {
    		got, err = scanDataFolder(context.Background(), nil, base, got, getSize, 0, weSleep)
    		got.Info.NextCycle++
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  6. 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)
  7. docs/bucket/replication/README.md

    succeeded or failed respectively. On the destination side, a `X-Amz-Replication-Status` status of `REPLICA` indicates that the object was replicated successfully. Any replication failures are automatically re-attempted during a periodic disk scanner cycle.
    
    To perform bi-directional replication, repeat the above process on the target site - this time setting the source bucket as the replication target. It is recommended that replication be run in a system with at least two CPU's available...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 24 23:46:33 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  8. 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)
  9. docs/bucket/replication/DESIGN.md

    on` and `DeleteReplication` fields in the replication configuration. By default, this is set to `Disabled` unless the user specifies it while adding a replication rule.
    
    Similar to object version replication, DeleteMarker replication also cycles through `PENDING` to `COMPLETED` or `FAILED` states for the `X-Amz-Replication-Status` on the source when a delete marker is set (i.e. performing `mc rm` on an object without specifying a version).After replication syncs the delete marker on the target,...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  10. 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