- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for Fresh (0.03 sec)
-
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* acquire(10) request arriving. We serve the request partly from storedPermits, using all the * remaining 7.0 permits, and the remaining 3.0, we serve them by fresh permits produced by the * rate limiter. * * We already know how much time it takes to serve 3 fresh permits: if the rate is * "1 token per second", then this will take 3 seconds. But what does it mean to serve 7 stored
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
assertThat(client.connectionPool.connectionCount()).isEqualTo(2) assertThat(server.takeRequest().sequenceNumber) .isEqualTo(0) // Fresh connection. assertThat(server.takeRequest().sequenceNumber) .isEqualTo(0) // Fresh connection. } /** * Check we would use an existing connection to a later DNS result instead of connecting to the * first DNS result for the first time.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 18.7K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt
assertThat(ioe.cause!!).isInstanceOf<EOFException>() } } // TODO GET preferred order - with tests to confirm this // 1. successful fresh cached GET response // 2. unsuccessful (404, 500) fresh cached GET response // 3. successful network response // 4. successful stale cached GET response // 5. unsuccessful response @Test fun usesCache() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 11K bytes - Viewed (0) -
cmd/prepare-storage.go
return storageDisks, format, nil } tries++ switch { case errors.Is(err, errNotFirstDisk): // Fresh setup, wait for first server to be up. logger.Info("Waiting for the first server to format the drives (elapsed %s)\n", getElapsedTime()) case errors.Is(err, errFirstDiskWait): // Fresh setup, wait for other servers to come up.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
cmd/format-erasure.go
Version string `json:"version"` // Version of 'xl' format. Disk string `json:"drive"` // Disk field carries assigned disk uuid. // JBOD field carries the input disk order generated the first // time when fresh disks were supplied. JBOD []string `json:"jbod"` } `json:"xl"` // Erasure field holds xl format. } // Represents the V2 backend disk structure version // under `.minio.sys` and actual data namespace.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
internal fun connectFailed( client: OkHttpClient, failedRoute: Route, failure: IOException, ) { // Tell the proxy selector when we fail to connect on a fresh connection. if (failedRoute.proxy.type() != Proxy.Type.DIRECT) { val address = failedRoute.address address.proxySelector.connectFailed( address.url.toUri(), failedRoute.proxy.address(),
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CacheControl.kt
this.maxStaleSeconds = maxStaleSecondsLong.commonClampToInt() } /** * Sets the minimum number of seconds that a response will continue to be fresh for. If the * response will be stale when [minFresh] have elapsed, the cached response will not be used and * a network request will be made. *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 10K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
.headers(conditionalRequestHeaders.build()) .build() return CacheStrategy(conditionalRequest, cacheResponse) } /** * Returns the number of milliseconds that the response was fresh for, starting from the served * date. */ private fun computeFreshnessLifetime(): Long { val responseCaching = cacheResponse!!.cacheControl if (responseCaching.maxAgeSeconds != -1) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12K bytes - Viewed (0) -
cmd/storage-datatypes.go
Data []byte `msg:"d,allownil"` // optionally carries object data NumVersions int `msg:"nv"` SuccessorModTime time.Time `msg:"smt"` Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo. // Position of this version or object in a multi-object delete call, // no other caller must set this value other than multi-object delete call.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 17.3K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
val clientCertificates = HandshakeCertificates.Builder() .addPlatformTrustedCertificates() .addInsecureHost(server.hostName) .build() // Need fresh client to reset sslSocketFactoryOrNull client = OkHttpClient.Builder() .eventListenerFactory( clientTestRule.wrap( object : EventListener() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 27K bytes - Viewed (0)