- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 163 for Reed (0.21 sec)
-
cmd/erasure-decode.go
shardSize := int(e.ShardSize()) if cap(b) < len(readers)*shardSize { // We should always have enough capacity, but older objects may be bigger. globalBytePoolCap.Load().Put(b) b = nil } else { // Seed the buffers. for i := range bufs { bufs[i] = b[i*shardSize : (i+1)*shardSize] } } return ¶llelReader{ readers: readers, orgReaders: readers, dataBlocks: e.dataBlocks,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/service.go
// freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // If multiple calls, first one creates channel. globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue1435.go
// The Go build system's swarming user is known not to be root. // Unfortunately, it sometimes appears as root due the current // implementation of a no-network check using 'unshare -n -r'. // Since this test does need root to work, we need to skip it. t.Skip("skipping root only test on a non-root builder") } if runtime.GOOS == "linux" { if _, err := os.Stat("/etc/alpine-release"); err == nil {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
AmbientEnabled bool `json:"ambient_enabled"` Kubernetes Kubernetes `json:"kubernetes"` } // K8sArgs is the valid CNI_ARGS used for Kubernetes // The field names need to match exact keys in containerd args for unmarshalling // https://github.com/containerd/containerd/blob/ced9b18c231a28990617bc0a4b8ce2e81ee2ffa1/pkg/cri/server/sandbox_run.go#L526-L532 type K8sArgs struct { types.CommonArgs
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
} } func runPlugin() error { if err := log.Configure(plugin.GetLoggingOptions("")); err != nil { return err } defer func() { // Log sync will send logs to install-cni container via UDS. // We don't need a timeout here because underlying the log pkg already handles it. // this may fail, but it should be safe to ignore according // to https://github.com/uber-go/zap/issues/328 _ = log.Sync() }()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 02:37:48 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/grid/benchmark_test.go
n++ } atomic.AddInt64(&ops, int64(n)) atomic.AddInt64(&lat, latency) }) spent := time.Since(t) if spent > 0 && n > 0 { // Since we are benchmarking n parallel servers we need to multiply by n. // This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/handler-api.go
} if err != nil { return 0 } limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64) if err != nil { // The kernel can return valid but non integer values // but still, no need to interpret more return 0 } if limit == cgroupMemNoLimit { // No limit set, It's the highest positive signed 64-bit // integer (2^63-1), rounded down to multiples of 4096 (2^12),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 09:22:27 GMT 2024 - 10K bytes - Viewed (0) -
src/cmd/cgo/internal/test/cgo_thread_lock.go
//export Gosched func Gosched() { runtime.Gosched() } func init() { testThreadLockFunc = testThreadLock } func testThreadLock(t *testing.T) { stop := make(chan int) go func() { // We need the G continue running, // so the M has a chance to run this G. for { select { case <-stop: return case <-time.After(time.Millisecond * 100): } } }() defer close(stop)
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu May 18 16:55:07 GMT 2023 - 939 bytes - Viewed (0) -
src/bytes/boundary_test.go
// operations do not read across the boundary and cause a page // fault where they shouldn't. // These tests run only on linux. The code being tested is // not OS-specific, so it does not need to be tested on all // operating systems. // dangerousSlice returns a slice which is immediately // preceded and followed by a faulting page. func dangerousSlice(t *testing.T) []byte { pagesize := syscall.Getpagesize()
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Nov 30 20:05:58 GMT 2023 - 2.8K bytes - Viewed (0)