- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 955 for pcount (0.25 sec)
-
cmd/erasure-healing-common.go
latest := int64(0) // Find the common cardinality from previously collected // occurrences of elements. for nano, count := range timeOccurrenceMap { if count < maxima { continue } // We are at or above maxima if count > maxima || nano > latest { maxima = count latest = nano } } // Return the collected common max time, with maxima return time.Unix(0, latest).UTC(), maxima
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/configurationcache/ConfigurationCacheFixture.groovy
void problem(String message, int count = 1, boolean hasStackTrace = true) { problems.add(new ProblemDetails(message, count, hasStackTrace)) } void serializationProblem(String message, int count = 1) { problems.add(new ProblemDetails(message, count, false)) } int getTotalProblems() { return problems.inject(0) { a, b -> a + b.count } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 15.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
if err != nil { err = msgp.WrapError(err, "Curr") return } switch msgp.UnsafeString(field) { case "Count": z.Curr.Count, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Count") return } case "Bytes": z.Curr.Bytes, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Bytes")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 33.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/schedule.go
} storeNumber[w.ID] = n count[n]++ stack = stack[:len(stack)-1] } } // convert count to prefix sum of counts: count'[i] = sum_{j<=i} count[i] for i := range count { if i == 0 { continue } count[i] += count[i-1] } if count[len(count)-1] != int32(len(values)) { f.Fatalf("storeOrder: value is missing, total count = %d, values = %v", count[len(count)-1], values) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 15:53:17 UTC 2024 - 16.4K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
errorCounts[context.Canceled]++ continue } errorCounts[err]++ } max := 0 for err, count := range errorCounts { switch { case max < count: max = count maxErr = err // Prefer `nil` over other error values with the same // number of occurrences. case max == count && err == nil: maxErr = err } } return max, maxErr }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
src/time/tick_test.go
} } for _, test := range []struct { count int delta Duration }{{ count: baseCount, delta: baseDelta, }, { count: 8, delta: 1 * Second, }} { count, delta := test.count, test.delta ticker := NewTicker(delta) t0 := Now() for range count / 2 { <-ticker.C } ticker.Reset(delta * 2) for range count - count/2 { <-ticker.C } ticker.Stop() t1 := Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/runtime/iface.go
// fail to find it. That's ok, they will then try to get the itab lock // and as a consequence wait until this copying is complete. iterate_itabs(t2.add) if t2.count != t.count { throw("mismatched count during itab table copy") } // Publish new hash table. Use an atomic write: see comment in getitab. atomicstorep(unsafe.Pointer(&itabTable), unsafe.Pointer(t2)) // Adopt the new table as our own.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 22.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go
continue } debugPrintf("releaseLock %s: unlocked\n", c.name) return } } func (c *Counter) add(n uint64) uint64 { count := c.ptr.count for { old := count.Load() sum := old + n if sum < old { sum = ^uint64(0) } if count.CompareAndSwap(old, sum) { runtime.KeepAlive(c.ptr.m) return sum } } } func (c *Counter) invalidate() { for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 10.3K bytes - Viewed (0) -
src/net/textproto/reader_test.go
} } // Test that reading a header doesn't overallocate. Issue 58975. func TestReadMIMEHeaderAllocations(t *testing.T) { var totalAlloc uint64 const count = 200 for i := 0; i < count; i++ { r := reader("A: b\r\n\r\n" + strings.Repeat("\n", 4096)) var m1, m2 runtime.MemStats runtime.ReadMemStats(&m1) _, err := r.ReadMIMEHeader() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14.7K bytes - Viewed (0)