- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 155 for duration (0.24 sec)
-
cmd/bucket-replication-metrics.go
return } duration := endTime.Sub(m.startTime) bytesSinceLastWindow := atomic.SwapUint64(&m.bytesSinceLastWindow, 0) if m.expMovingAvg == 0 { // Should address initial calculation and should be fine for resuming from 0 m.expMovingAvg = float64(bytesSinceLastWindow) / duration.Seconds() return } increment := float64(bytesSinceLastWindow) / duration.Seconds()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* simultaneously adopted and removed. */ private val connections = ConcurrentLinkedQueue<RealConnection>() init { // Put a floor on the keep alive duration, otherwise cleanup will spin loop. require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" } } fun idleConnectionCount(): Int { return connections.count {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheStats.java
private final long hitCount; private final long missCount; private final long loadSuccessCount; private final long loadExceptionCount; @SuppressWarnings("GoodTime") // should be a java.time.Duration private final long totalLoadTime; private final long evictionCount; /** * Constructs a new {@code CacheStats} instance. *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheStats.java
private final long hitCount; private final long missCount; private final long loadSuccessCount; private final long loadExceptionCount; @SuppressWarnings("GoodTime") // should be a java.time.Duration private final long totalLoadTime; private final long evictionCount; /** * Constructs a new {@code CacheStats} instance. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 12.6K bytes - Viewed (0) -
internal/grid/connection.go
case debugSetConnPingDuration: c.connMu.Lock() defer c.connMu.Unlock() c.connPingInterval = args[0].(time.Duration) case debugSetClientPingDuration: c.clientPingInterval = args[0].(time.Duration) case debugAddToDeadline: c.addDeadline = args[0].(time.Duration) case debugIsOutgoingClosed: // params: muxID uint64, isClosed func(bool) muxID := args[0].(uint64)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func NewLifecycleSys() *LifecycleSys { return &LifecycleSys{} } func ilmTrace(startTime time.Time, duration time.Duration, oi ObjectInfo, event string) madmin.TraceInfo { return madmin.TraceInfo{ TraceType: madmin.TraceILM, Time: startTime, NodeName: globalLocalNodeName, FuncName: event, Duration: duration, Path: pathJoin(oi.Bucket, oi.Name), Error: "", Message: getSource(4),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* rate at the end of the period (as long as there are enough requests to saturate it). Similarly, * if the {@code RateLimiter} is left <i>unused</i> for a duration of {@code warmupPeriod}, it * will gradually return to its "cold" state, i.e. it will go through the same warming up process * as when it was first created. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 18.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
return err } // Netperf - To initiate netperf on peer func (client *peerRESTClient) Netperf(ctx context.Context, duration time.Duration) (madmin.NetperfNodeResult, error) { var result madmin.NetperfNodeResult values := make(url.Values) values.Set(peerRESTDuration, duration.String()) respBody, err := client.callWithContext(context.Background(), peerRESTMethodNetperf, values, nil, -1) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
api/go1.21.txt
pkg log/slog, func Debug(string, ...interface{}) #56345 pkg log/slog, func Default() *Logger #56345 pkg log/slog, func Duration(string, time.Duration) Attr #56345 pkg log/slog, func DurationValue(time.Duration) Value #56345 pkg log/slog, func ErrorContext(context.Context, string, ...interface{}) #61200 pkg log/slog, func Error(string, ...interface{}) #56345
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Aug 07 09:39:17 GMT 2023 - 25.6K bytes - Viewed (0) -
api/go1.8.txt
pkg net/http, type PushOptions struct, Method string pkg net/http, type Request struct, GetBody func() (io.ReadCloser, error) pkg net/http, type Server struct, IdleTimeout time.Duration pkg net/http, type Server struct, ReadHeaderTimeout time.Duration pkg net/http, type Transport struct, ProxyConnectHeader Header pkg net/http, var ErrAbortHandler error pkg net/http, var ErrServerClosed error pkg net/http, var NoBody noBody
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Wed Dec 21 05:25:57 GMT 2016 - 16.3K bytes - Viewed (0)