- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,073 for measure (0.16 sec)
-
common-protos/k8s.io/api/coordination/v1/generated.proto
// +optional optional string holderIdentity = 1; // leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional optional int32 leaseDurationSeconds = 2; // acquireTime is a time when the current lease was acquired. // +optional
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/types_swagger_doc_generated.go
"holderIdentity": "holderIdentity contains the identity of the holder of a current lease.", "leaseDurationSeconds": "leaseDurationSeconds is a duration that candidates for a lease need to wait to force acquire it. This is measure against time of last observed renewTime.", "acquireTime": "acquireTime is a time when the current lease was acquired.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 00:51:25 UTC 2023 - 2.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java
} @Footprint Object sizeOfStriped() { return impl.get(numStripes); } // a place to put the locks in sizeOfPopulatedStriped so they don't get GC'd before we measure final List<Lock> locks = new ArrayList<>(numStripes); @Footprint Object sizeOfPopulatedStriped() { locks.clear(); Striped<Lock> striped = impl.get(numStripes); for (int i : stripes) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4K bytes - Viewed (0) -
src/runtime/semasleep_test.go
// can keep the process hung indefinitely, as long as we signal it often // enough.) timeout := 10 * time.Second // The subprocess begins sleeping for 1s after it writes to stdout, so measure // the timeout from here (not from when we started creating the process). // That should reduce noise from process startup overhead. ready := time.Now() // With the repro running, we can continuously send to it
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
private void weaklyReferenceQueue() { frq = new FinalizableReferenceQueue(); queueReference = new WeakReference<>(frq.queue); /* * Queue and clear a reference for good measure. We test later on that * the finalizer thread stopped, but we should test that it actually * started first. */ reference = new FinalizableWeakReference<Object>(new Object(), frq) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/11-language-change.yml
label: "Orthogonality: How does this change interact or overlap with existing features?" description: "Is the goal of this change a performance improvement? If so, what quantifiable improvement should we expect? How would we measure it?" validations: required: false - type: textarea id: learning-curve attributes: label: "Would this change make Go easier or harder to learn, and why?" - type: textarea
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 22 20:49:24 UTC 2023 - 4.7K bytes - Viewed (0) -
src/log/slog/internal/benchmarks/handlers.go
// we simulate a lock-free queue by adding the Record to a ring buffer. // Omitting the locking makes this little more than a copy of the Record, // but that is a worthwhile thing to measure because Records are on the large // side. Since nothing actually reads from the ring buffer, it can handle an // arbitrary number of Records without either blocking or allocation. type asyncHandler struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 12 20:33:37 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/jmh/java/org/gradle/internal/reflect/HashingAlgorithmsBenchmark.java
public void setup() throws CloneNotSupportedException { input = new byte[hashSize]; random.nextBytes(input); processorFactory = HASHERS.get(type); } @Benchmark public void measure(Blackhole blackhole) { HashProcessor processor = processorFactory.create(); processor.process(input, blackhole); } interface HashProcessor {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5.1K bytes - Viewed (0) -
src/internal/fuzz/worker_test.go
mem.setValue(encodedVals) mem.header().count = 0 ws.fuzz(context.Background(), fuzzArgs{Limit: 1}) } } // BenchmarkWorkerPing acts as the coordinator and measures the time it takes // a worker to respond to N pings. This is a rough measure of our RPC latency. func BenchmarkWorkerPing(b *testing.B) { if race.Enabled { b.Skip("TODO(48504): fix and re-enable") } b.SetParallelism(1) w := newWorkerForTest(b)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 4.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */ private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0)