- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for InitOnce (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)