- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for numWrites (0.18 sec)
-
pkg/channels/unbounded_test.go
wg.Add(1) go func() { defer wg.Done() ch := ub.Get() for i := 0; i < numWriters*numWrites; i++ { r := <-ch reads = append(reads, r) ub.Load() } }() wg.Add(numWriters) for i := 0; i < numWriters; i++ { go func(index int) { defer wg.Done() for j := 0; j < numWrites; j++ { ub.Put(index) } }(i) } wg.Wait() sort.Ints(reads)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 31 19:53:39 UTC 2022 - 2.3K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
// before all subsequent writes fail. breakAfter int // numWrites is the number of writes that have been done. numWrites int } // brokenConnErr is the error that brokenConn returns once exhausted. var brokenConnErr = errors.New("too many writes to brokenConn") func (b *brokenConn) Write(data []byte) (int, error) { if b.numWrites >= b.breakAfter { return 0, brokenConnErr }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
src/strings/builder_test.go
f(b, 3, true) }) } func BenchmarkBuildString_Builder(b *testing.B) { benchmarkBuilder(b, func(b *testing.B, numWrite int, grow bool) { for i := 0; i < b.N; i++ { var buf Builder if grow { buf.Grow(len(someBytes) * numWrite) } for i := 0; i < numWrite; i++ { buf.Write(someBytes) } sinkS = buf.String() } }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 19 19:51:15 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/controller/namespace/deletion/namespaced_resources_deleter_test.go
} } } }) } } func TestRetryOnConflictError(t *testing.T) { mockClient := &fake.Clientset{} numTries := 0 retryOnce := func(ctx context.Context, namespace *v1.Namespace) (*v1.Namespace, error) { numTries++ if numTries <= 1 { return namespace, errors.NewConflict(api.Resource("namespaces"), namespace.Name, fmt.Errorf("ERROR")) } return namespace, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 15.8K bytes - Viewed (0) -
cmd/site-replication.go
} tagMismatch := !isReplicated(tagCount, numSites, tagSet) olockCfgMismatch := !isReplicated(olockCfgCount, numSites, olockConfigSet) sseCfgMismatch := !isReplicated(sseCfgCount, numSites, sseCfgSet) versionCfgMismatch := !isReplicated(versionCfgCount, numSites, versionCfgSet) policyMismatch := !isBktPolicyReplicated(numSites, policies) replCfgMismatch := !isBktReplCfgReplicated(numSites, replCfgs)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
numReaders := 100 numRequestsPerReader := 1000 numWriters := 10 numWritesPerWriter := 1000 waitGroup := sync.WaitGroup{} // Spawn a bunch of writers that randomly add groups, remove groups, and // reset the list of groups for i := 0; i < numWriters; i++ { source := rand.NewSource(int64(i)) waitGroup.Add(1) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
close(c) }() <-c } func blockSelectRecvAsync(t *testing.T) { const numTries = 3 c := make(chan bool, 1) c2 := make(chan bool, 1) go func() { for i := 0; i < numTries; i++ { awaitBlockedGoroutine(t, "select", "blockSelectRecvAsync", 1) c <- true } }() for i := 0; i < numTries; i++ { select { case <-c: case <-c2: } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0)