- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 172 for shard (0.03 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt
assertThat(original.interceptors.size).isEqualTo(0) assertThat(original.networkInterceptors.size).isEqualTo(0) } /** * When copying the client, stateful things like the connection pool are shared across all * clients. */ @Test fun cloneSharesStatefulInstances() { val client = clientTestRule.newClient() // Values should be non-null. val a = client.newBuilder().build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 13.4K bytes - Viewed (0) -
guava/src/com/google/common/escape/ArrayBasedEscaperMap.java
* when more than one escaper is created using the same character replacement mapping to allow the * underlying (implementation specific) data structures to be shared. * * <p>The size of the data structure used by ArrayBasedCharEscaper and ArrayBasedUnicodeEscaper is * proportional to the highest valued character that has a replacement. For example a replacement
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 28 01:26:26 UTC 2024 - 3.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
/** An HTTP request that came into the mock web server. */ public class RecordedRequest( /** * The index of the socket connection that carried this request. If two recorded requests share a * connection index, they also shared a socket connection. */ public val connectionIndex: Int, /** * The index of this exchange on its HTTP connection. A request is uniquely identified by the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 3.2K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
* Fix: Support TLSv1.3 on devices that support it. * Fix: Share pooled connections across equivalent `OkHttpClient` instances. Previous releases had a bug where a shared connection pool did not guarantee shared connections in some cases. * Fix: Prefer the server's response body on all conditional cache misses. Previously we would
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
this because it only occurs if you have proxy configured and you share a connection pool among multiple `OkHttpClient` instances. This particularly-subtle bug was caused by us assigning each `OkHttpClient` instance its own `NullProxySelector` when an explicit proxy is configured. But we don't share connections when the proxy selectors are different. Ugh! ## Version 4.2.0
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
smallest idea how to set about it; and while she was peering about anxiously among the trees, a little sharp bark just over her head made her look up in a great hurry. An enormous puppy was looking down at her with large round eyes, and feebly stretching out one paw, trying to touch her. `Poor little thing!' said Alice, in a coaxing tone, and she tried hard to whistle to it; but she was terribly frightened all the
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 145.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.isHealthy import okhttp3.internal.tls.OkHostnameVerifier import okio.Buffer /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection internal constructor( val taskRunner: TaskRunner,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt
sourceCount++ } return RelaySource() } internal inner class RelaySource : Source { private val timeout = Timeout() /** The operator to read and write the shared file. Null if this source is closed. */ private var fileOperator: FileOperator? = FileOperator(file!!.channel) /** The next byte to read. This is always less than or equal to [upstreamPos]. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 17:15:47 UTC 2025 - 11.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
/** Number of delayed unassigned shards */ public int delayedUnassignedShards; /** Number of unassigned shards */ public int unassignedShards; /** Number of initializing shards */ public int initializingShards; /** Number of relocating shards */ public int relocatingShards; /** Percentage of active shards */ public double activeShardsPercent;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/ProtocolHelperTest.java
assertFalse(protocolHelper.isValidFileProtocol("smb://server/share")); protocolHelper.addFileProtocol("smb"); assertEquals(2, protocolHelper.getFileProtocols().length); assertEquals("smb:", protocolHelper.getFileProtocols()[1]); assertTrue(protocolHelper.isValidFileProtocol("smb://server/share")); } public void test_addFileProtocol_duplicateProtocol() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 19 23:49:30 UTC 2025 - 21.5K bytes - Viewed (0)