- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Milliseconds (0.35 sec)
-
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * ```java * public final OkHttpClient client = new OkHttpClient.Builder() * .readTimeout(1000, TimeUnit.MILLISECONDS) * .writeTimeout(1000, TimeUnit.MILLISECONDS) * .build(); * ``` * * This example shows a call with a short 500 millisecond read timeout and a 1000 millisecond * write timeout. Original configuration is kept, but can be overriden. * * ```java
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
common/scripts/metallb-native.yaml
control packets in milliseconds. Defaults to 300ms. format: int32 maximum: 60000 minimum: 10 type: integer transmitInterval: description: The minimum transmission interval (less jitter) that this system wants to use to send BFD control packets in milliseconds. Defaults to 300ms
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Feb 23 23:56:31 GMT 2024 - 63.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.play() // Play it back. val connection = connect(peer) val stream = connection.newStream(headerEntries("b", "banana"), false) stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS) val startNanos = System.nanoTime() assertFailsWith<InterruptedIOException> { stream.takeHeaders() } val elapsedNanos = System.nanoTime() - startNanos awaitWatchdogIdle()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
.build() // Delay the response to give 1 ping enough time to be sent and replied to. server.enqueue( MockResponse.Builder() .bodyDelay(750, TimeUnit.MILLISECONDS) .body("ABC") .build(), ) val call = client.newCall(Request(server.url("/"))) val response = call.execute() assertThat(response.body.string()).isEqualTo("ABC")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
// be exhausted // return new ThreadPoolExecutor( parallelism, Integer.MAX_VALUE, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>()) { final AtomicInteger parked = new AtomicInteger(); @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// TODO(diamondm) consider moving this into addPendingString so it's always in the output if (this instanceof ScheduledFuture) { return "remaining delay=[" + ((ScheduledFuture) this).getDelay(TimeUnit.MILLISECONDS) + " ms]"; } return null; } @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void addPendingString(StringBuilder builder) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
cmd/iam.go
if err != nil { atomic.AddUint64(&sys.TotalRefreshFailures, 1) return err } loadDuration := time.Since(loadStartTime) atomic.StoreUint64(&sys.LastRefreshDurationMilliseconds, uint64(loadDuration.Milliseconds())) atomic.StoreUint64(&sys.LastRefreshTimeUnixNano, uint64(loadStartTime.Add(loadDuration).UnixNano())) atomic.AddUint64(&sys.TotalRefreshSuccesses, 1) if !globalSiteReplicatorCred.IsValid() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/iam-store.go
Policy policy.Policy CreateDate time.Time `json:",omitempty"` UpdateDate time.Time `json:",omitempty"` } func newPolicyDoc(p policy.Policy) PolicyDoc { now := UTCNow().Round(time.Millisecond) return PolicyDoc{ Version: 1, Policy: p, CreateDate: now, UpdateDate: now, } } // defaultPolicyDoc - used to wrap a default policy as PolicyDoc.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/batch-handlers.go
batchJobPrefix = "batch-jobs" batchJobReportsPrefix = batchJobPrefix + "/reports" batchReplJobAPIVersion = "v1" batchReplJobDefaultRetries = 3 batchReplJobDefaultRetryDelay = 250 * time.Millisecond ) func getJobReportPath(job BatchJobRequest) string { var fileName string switch { case job.Replicate != nil: fileName = batchReplName case job.KeyRotate != nil:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/test-utils_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0)