- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for numWrites (0.13 sec)
-
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) -
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)