- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 543 for timeN (0.03 sec)
-
cmd/data-scanner-metric.go
} } } } // time a scanner action. // Use for s < scannerMetricLastRealtime func (p *scannerMetrics) time(s scannerMetric) func() { startTime := time.Now() return func() { duration := time.Since(startTime) atomic.AddUint64(&p.operations[s], 1) if s < scannerMetricLastRealtime { p.latency[s].add(duration) } } } // timeSize add time and size of a scanner action.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.4K bytes - Viewed (0) -
cmd/data-scanner.go
d.mu.RUnlock() // Don't sleep for really small amount of time wantSleep := time.Duration(float64(base) * factor) if wantSleep <= minWait { return } if maxWait > 0 && wantSleep > maxWait { wantSleep = maxWait } timer := time.NewTimer(wantSleep) select { case <-ctx.Done(): if !timer.Stop() { <-timer.C if d.isScanner {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/BasicFileInformationTest.java
}; for (long[] times : timeValues) { // Given FileBasicInfo info = new FileBasicInfo(times[0], // create time times[1], // last access time times[2], // last write time times[3], // change time TEST_ATTRIBUTES);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
/** * Establishes a connection to the remote endpoint. * * @param timeout the maximum time to wait for the connection in milliseconds * @throws TransportException if the connection fails or times out */ public synchronized void connect(final long timeout) throws TransportException { try { switch (state) { case 0:
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.3K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
if initial >= adjusted || adjusted >= adjustedAgain { t.Errorf("Failure to increase timeout multiple times") } } func TestDynamicTimeoutSingleDecrease(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout() for range dynamicTimeoutLogSize { timeout.LogSuccess(20 * time.Second) } adjusted := timeout.Timeout() if initial <= adjusted {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/create/Smb2CloseResponseTest.java
SMBUtil.writeInt2(60, buffer, 0); // SMB times are in 100-nanosecond intervals since 1601 // Java times are in milliseconds since 1970 long currentJavaTime = System.currentTimeMillis(); long smbTime = currentJavaTime * 10000L + 116444736000000000L; SMBUtil.writeInt8(smbTime, buffer, 8); SMBUtil.writeInt8(smbTime, buffer, 16);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 26.9K bytes - Viewed (0) -
cmd/callhome.go
return } // callhome running on a different node. // sleep for some time and try again. duration := max(time.Duration(r.Float64()*float64(globalCallhomeConfig.FrequencyDur())), // Make sure to sleep at least a second to avoid high CPU ticks. time.Second) time.Sleep(duration) } }() } func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// time occurrence from a list of time. func TestCommonTime(t *testing.T) { // List of test cases for common modTime. testCases := []struct { times []time.Time time time.Time quorum int }{ { // 1. Tests common times when slice has varying time elements. []time.Time{ time.Unix(0, 1).UTC(), time.Unix(0, 2).UTC(), time.Unix(0, 3).UTC(), time.Unix(0, 3).UTC(),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
type dynamicTimeout struct { timeout int64 minimum int64 entries int64 log [dynamicTimeoutLogSize]time.Duration mutex sync.Mutex retryInterval time.Duration } type dynamicTimeoutOpts struct { timeout time.Duration minimum time.Duration retryInterval time.Duration } func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.5K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/sub-dependencies.md
read_query["/items/"] query_extractor --> query_or_cookie_extractor --> read_query ``` ## Using the same dependency multiple times { #using-the-same-dependency-multiple-times } If one of your dependencies is declared multiple times for the same *path operation*, for example, multiple dependencies have a common sub-dependency, **FastAPI** will know to call that sub-dependency only once per request.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 3.7K bytes - Viewed (0)