- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 130 for peak (0.02 sec)
-
cmd/bucket-stats.go
totpeak = math.Max(math.Max(tot.Peak, totpeak), tot.Curr) lpeak = math.Max(math.Max(v[Large].Peak, lpeak), v[Large].Curr) speak = math.Max(math.Max(v[Small].Peak, speak), v[Small].Curr) if lpeak > 0 || speak > 0 { count++ } } if count > 0 { lrg := XferStats{ Avg: lavg / float64(count), Curr: lcurr / float64(count), Peak: lpeak, } sml := XferStats{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.5K bytes - Viewed (0) -
cmd/bucket-targets.go
} type latencyStat struct { lastmin lastMinuteLatency curr time.Duration avg time.Duration peak time.Duration N int64 } func (l *latencyStat) update(d time.Duration) { l.lastmin.add(d) l.N++ if d > l.peak { l.peak = d } l.curr = l.lastmin.getTotal().avg() l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
*/ public JvmThreadsObj() { // Default constructor } /** Current number of threads */ public int count; /** Peak number of threads */ public int peak; } /** * Data transfer object representing JVM class loading statistics. */ public static class JvmClassesObj { /** * Default constructor.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java
buf.append("},"); final Threads threads = jvmStats.getThreads(); buf.append("\"threads\":{"); append(buf, "count", () -> threads.getCount()).append(','); append(buf, "peak", () -> threads.getPeakCount()); buf.append("},"); final Classes classes = jvmStats.getClasses(); buf.append("\"classes\":{");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7.8K bytes - Viewed (0) -
cmd/speedtest.go
throughputHighestGet = totalGet } sendResult() break } // We break if we did not see 2.5% growth rate in total GET // requests, we have reached our peak at this point. doBreak := float64(totalGet-throughputHighestGet)/float64(totalGet) < 0.025 throughputHighestGet = totalGet throughputHighestResults = results throughputHighestPut = totalPut
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 9.2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
metric.LastOnline = epHealth.lastOnline metric.Online = epHealth.Online metric.Latency = madmin.LatencyStat{ Curr: epHealth.latency.curr, Avg: epHealth.latency.avg, Max: epHealth.latency.peak, } } m[dID] = metric } return m } func (srs *SRStatus) updateXferRate(sz int64, duration time.Duration) { if sz > minLargeObjSize { srs.XferRateLrg.addSize(sz, duration)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
cmd/metrics-v2.go
if len(qs.XferStats) > 0 { tots := qs.XferStats[Total] currTransferRate.Value = tots.Curr avgTransferRate.Value = tots.Avg maxTransferRate.Value = tots.Peak } ml = []MetricV2{ activeWorkersCount, avgActiveWorkersCount, maxActiveWorkersCount, currInQueueCount, currInQueueBytes, avgQueueCount, avgQueueBytes,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
cmd/site-replication.go
x2, ok := v2.XferStats[replication.MetricName(rm)] if !ok { x2 = replication.XferStats{} } x2.AvgRate += x.Avg x2.CurrRate += x.Curr if x.Peak > x2.PeakRate { x2.PeakRate = x.Peak } v2.XferStats[replication.MetricName(rm)] = x2 } sm.Metrics[dID] = v2 } } sm.Uptime = UTCNow().Unix() - globalBootTime.Unix() return sm, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 184.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
"sort" "strings" "time" ) const ( // deadline (in seconds) up to which the go routine leak detection has to be retried. leakDetectDeadline = 5 // pause time (in milliseconds) between each snapshot at the end of the go routine leak detection. leakDetectPauseTimeMs = 50 ) // LeakDetect - type with methods for go routine leak detection. type LeakDetect struct { relevantRoutines map[string]bool }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java
} } }; assertEquals(0, (int) iter.peek()); assertEquals(0, (int) iter.peek()); assertTrue(iter.hasNext()); assertEquals(0, (int) iter.peek()); assertEquals(0, (int) iter.next()); assertEquals(1, (int) iter.peek()); assertEquals(1, (int) iter.next()); /* * We test peek() after various calls to make sure that one bad call doesn't interfere with its
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.8K bytes - Viewed (0)