- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for Reed (0.13 sec)
-
internal/bucket/bandwidth/reader.go
} else { // part of header can be accommodated r.opts.HeaderSize -= b - 1 need = 1 // to ensure we read at least one byte for every Read tokens = b } } else { // all tokens go towards payload need = int(math.Min(float64(b), float64(need))) tokens = need } err = r.throttle.WaitN(r.ctx, tokens) if err != nil { return } n, err = r.r.Read(buf[:need]) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
timeout.LogFailure() } else { timeout.LogSuccess(duration) } } } func TestDynamicTimeoutAdjustExponential(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) rand.Seed(0) initial := timeout.Timeout() for try := 0; try < 10; try++ { testDynamicTimeoutAdjust(t, timeout, rand.ExpFloat64) } adjusted := timeout.Timeout() if initial <= adjusted {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
cmd/crossdomain-xml-handler.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 06:42:40 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/namespace-lock_test.go
lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0) }() runtime.Gosched() // unlock the manual lock nsLk.lockMapMutex.Unlock() // To trigger the race: // 1) lk3 or lk4 need to advance and increment the ref on the existing resource, // successfully acquiring the lock. // 2) lk2 then needs to advance and remove the resource from lockMap.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
internal/http/listener.go
} if opts.Trace != nil { opts.Trace(fmt.Sprint("adding listener to ", l.Addr())) } listeners = append(listeners, l) } if len(listeners) == 0 { // No listeners initialized, no need to continue return } listener = &httpListener{ listeners: listeners, acceptCh: make(chan acceptResult, len(listeners)), opts: opts, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
for _, collectorPath := range h.metricsData.collectorPaths { if collectorPath.isDescendantOf(path) { gatherer := h.metricsData.mgGatherers[collectorPath] // For Bucket metrics we need to set the buckets argument inside the // metric group, so that it will affect collection. If no buckets // are provided, we will not return bucket metrics. if bmg, ok := h.metricsData.bucketMGMap[collectorPath]; ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/s3select/csv/reader.go
} recDst = recDst[:len(record)] copy(recDst, record) all = append(all, recDst) } }() if err != nil { in.err = err } // We don't need the input any more. //nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer. r.bufferPool.Put(in.input) in.input = nil in.dst <- all
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/data-usage.go
} // For forward compatibility reasons, we need to add this code. if len(dataUsageInfo.BucketsUsage) == 0 { dataUsageInfo.BucketsUsage = make(map[string]BucketUsageInfo, len(dataUsageInfo.BucketSizes)) for bucket, size := range dataUsageInfo.BucketSizes { dataUsageInfo.BucketsUsage[bucket] = BucketUsageInfo{Size: size} } } // For backward compatibility reasons, we need to add this code.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
// randomly picks a character and returns its equivalent byte array. func getRandomByte() []byte { const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ" // seeding the random number generator. rand.Seed(UTCNow().UnixNano()) // pick a character randomly. return []byte{letterBytes[rand.Intn(len(letterBytes))]} } // picks a random byte and repeats it to size bytes. func generateBytesData(size int) []byte {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 8.2K bytes - Viewed (0) -
internal/config/compress/legacy.go
) // SetCompressionConfig - One time migration code needed, for migrating from older config to new for Compression. func SetCompressionConfig(s config.Config, cfg Config) { if !cfg.Enabled { // No need to save disabled settings in new config. return } s[config.CompressionSubSys][config.Default] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jul 17 15:43:14 GMT 2022 - 1.8K bytes - Viewed (0)