- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 79 for measuredH (0.54 sec)
-
cmd/site-replication-metrics.go
return } } } func (sr *SRStats) updateMovingAvg() { sr.lock.Lock() defer sr.lock.Unlock() for _, s := range sr.M { s.XferRateLrg.measure.updateExponentialMovingAverage(time.Now()) s.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } // SRMetric captures replication metrics for a deployment type SRMetric struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
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) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 10 08:40:05 GMT 2023 - 4.8K 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) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 10 08:40:05 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
return } } } func (r *ReplicationStats) updateMovingAvg() { r.RLock() for _, s := range r.Cache { for _, st := range s.Stats { st.XferRateLrg.measure.updateExponentialMovingAverage(time.Now()) st.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } r.RUnlock() } // ActiveWorkers returns worker stats func (r *ReplicationStats) ActiveWorkers() ActiveWorkerStat {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
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
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 2.6K 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
Others - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Nov 22 20:49:24 GMT 2023 - 4.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) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K bytes - Viewed (0) -
android/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) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K 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)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/FarmHashFingerprint64.java
b ^= (b >>> 47); b *= mul; return b; } /** * Computes intermediate hash of 32 bytes of byte array from the given offset. Results are * returned in the output array because when we last measured, this was 12% faster than allocating * new arrays every time. */ private static void weakHashLength32WithSeeds( byte[] bytes, int offset, long seedA, long seedB, long[] output) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Apr 01 22:39:48 GMT 2022 - 7.6K bytes - Viewed (0)