Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for InitOnce (0.05 sec)

  1. cmd/data-usage_test.go

    				return
    			}
    			sizeS.totalSize = s.Size()
    			sizeS.versions++
    			return sizeS, nil
    		}
    		return
    	}
    	xls := xlStorage{drivePath: base, diskInfoCache: cachevalue.New[DiskInfo]()}
    	xls.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskInfo, error) {
    		return DiskInfo{Total: 1 << 40, Free: 1 << 40}, nil
    	})
    	weSleep := func() bool { return false }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  2. cmd/data-usage.go

    	z, ok := objAPI.(*erasureServerPools)
    	if !ok {
    		// Prefix usage is empty
    		return map[string]uint64{}, nil
    	}
    
    	cache := dataUsageCache{}
    
    	prefixUsageCache.InitOnce(30*time.Second,
    		// No need to fail upon Update() error, fallback to old value.
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (map[string]uint64, error) {
    			m := make(map[string]uint64)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. cmd/bucket-quota.go

    	return &BucketQuotaSys{}
    }
    
    var bucketStorageCache = cachevalue.New[DataUsageInfo]()
    
    // Init initialize bucket quota.
    func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) {
    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    				return DataUsageInfo{}, errServerNotInitialized
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Aug 06 23:48:58 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		}
    		info = *infop
    		if info.Error != "" {
    			return info, toStorageErr(errors.New(info.Error))
    		}
    		return info, nil
    	} // In all other cases cache the value upto 1sec.
    
    	client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (info DiskInfo, err error) {
    			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	healthCheck  bool
    
    	metricsCache *cachevalue.Cache[DiskMetrics]
    	diskCtx      context.Context
    	diskCancel   context.CancelFunc
    }
    
    func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
    	p.metricsCache.InitOnce(5*time.Second,
    		cachevalue.Opts{},
    		func(ctx context.Context) (DiskMetrics, error) {
    			diskMetric := DiskMetrics{
    				LastMinute: make(map[string]AccElem, len(p.apiLatencies)),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    // that all buckets are present on all serverPools.
    func (z *erasureServerPools) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) {
    	if opts.Cached {
    		listBucketsCache.InitOnce(time.Second,
    			cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    			func(ctx context.Context) ([]BucketInfo, error) {
    				ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    				defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    		s.oDirect = false
    	} else if err := s.checkODirectDiskSupport(info.FSType); err == nil {
    		s.oDirect = true
    	} else {
    		return s, err
    	}
    
    	// Initialize DiskInfo cache
    	s.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (DiskInfo, error) {
    			dcinfo := DiskInfo{}
    			di, root, err := getDiskInfo(s.drivePath)
    			if err != nil {
    				return dcinfo, err
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  8. lib/fips140/v1.0.0.zip

    basepoint. It is precomputed the first time it's used. func basepointTable() *[32]affineLookupTable { basepointTablePrecom.initOnce.Do(func() { p := NewGeneratorPoint() for i := 0; i < 32; i++ { basepointTablePrecom.table[i].FromP3(p) for j := 0; j < 8; j++ { p.Add(p, p) } } }) return &basepointTablePrecom.table } var basepointTablePrecom struct { table [32]affineLookupTable initOnce sync.Once } // ScalarBaseMult sets v = x * B, where B is the canonical generator, and // returns v. // // The scalar multiplication...
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Jan 29 15:10:35 UTC 2025
    - 635K bytes
    - Viewed (0)
Back to top