- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 139 for milliseconds (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/http/listener.go
} return addrs } // TCPOptions specify customizable TCP optimizations on raw socket type TCPOptions struct { UserTimeout int // this value is expected to be in milliseconds // When the net.Conn is a remote drive this value is honored, we close the connection to remote peer proactively. DriveOPTimeout func() time.DurationCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
import java.net.Socket import java.util.concurrent.CopyOnWriteArrayList import java.util.concurrent.ExecutorService import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit.MILLISECONDS import java.util.concurrent.atomic.AtomicBoolean import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.atomic.AtomicReferenceFieldUpdater
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 19.7K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
session.getResult().addException(e); break; } } executor.shutdown(); executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); } private void multiThreadedProjectTaskSegmentBuild( ConcurrencyDependencyGraph analyzer, ReactorContext reactorContext, MavenSession rootSession,
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 16 03:42:09 GMT 2025 - 8.9K bytes - Click Count (0) -
cmd/metrics-v2.go
Help: "Maximum replication link latency in milliseconds seen since server uptime", Type: gaugeMetric, } } func getClusterRepLinkLatencyAvgMD() MetricDescription { return MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: replicationSubsystem, Name: avgLinkLatency, Help: "Average replication link latency in milliseconds", Type: gaugeMetric, } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
cmd/metrics-v3-cache.go
m.writesKBPerSec = float64(ioStats.WriteSectors) * float64(sectorSize) / kib / durationSecs if ioStats.WriteIOs > 0 { m.writesAwait = float64(ioStats.WriteTicks) / float64(ioStats.WriteIOs) } // TotalTicks is in milliseconds m.percUtil = float64(ioStats.TotalTicks) * 100 / (durationSecs * 1000) return m } func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] { var (
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.1K bytes - Click Count (0) -
docs/recipes.md
.build() // Copy to customize OkHttp for this request. val client1 = client.newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build() try { client1.newCall(request).execute().use { response -> println("Response 1 succeeded: $response") } } catch (e: IOException) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 30 17:01:12 GMT 2025 - 47.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
builder = builder.noCache() builder = builder.noStore() builder = builder.maxAge(0, TimeUnit.MILLISECONDS) builder = builder.maxStale(0, TimeUnit.MILLISECONDS) builder = builder.minFresh(0, TimeUnit.MILLISECONDS) builder = builder.onlyIfCached() builder = builder.noTransform() builder = builder.immutable() val cacheControl: CacheControl = builder.build()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
internal/grid/msg.go
// //msgp:tuple message type message struct { MuxID uint64 // Mux to receive message if any. Seq uint32 // Sequence number. DeadlineMS uint32 // If non-zero, milliseconds until deadline (max 1193h2m47.295s, ~49 days) Handler HandlerID // ID of handler if invoking a remote handler. Op Op // Operation. Other fields change based on this value.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jul 25 21:07:21 GMT 2024 - 7.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
serverIpv6.enqueue( MockResponse(body = "hello from IPv6"), ) client = client .newBuilder() .fastFallback(false) .callTimeout(1_000, TimeUnit.MILLISECONDS) .build() val call = client.newCall(Request(url)) assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected).hasMessage("timeout") } }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
server.enqueue(MockResponse(body = "a")) server.enqueue(MockResponse(body = "b")) client = client .newBuilder() .connectionPool(ConnectionPool(5, 250, TimeUnit.MILLISECONDS)) .build() val request = Request(server.url("/")) val response1 = client.newCall(request).execute() assertThat(response1.body.string()).isEqualTo("a")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 12.2K bytes - Click Count (1)