- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 627 for connecting (0.37 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
README.md
``` ### Connection Pool Tuning ```java container.singleton("httpClient", HcHttpClient.class, client -> { client.setMaxConnections(200); // Total connections client.setMaxConnectionsPerRoute(20); // Per-host connections client.setConnectionTimeout(30000); // Connection timeout client.setSocketTimeout(60000); // Read timeout });
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Aug 31 05:32:52 GMT 2025 - 15.3K bytes - Click Count (0) -
README.md
- **Authentication**: NTLM, Kerberos, SPNEGO unified subsystem - **SLF4J Logging**: Comprehensive logging throughout the codebase - **Resource Management**: AutoCloseable patterns for file handles and connections - **Thread Safety**: Components support concurrent access - **DFS Support**: Distributed File System resolution - **Streaming Operations**: Efficient directory listings and file operations
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 09:24:52 GMT 2025 - 6.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt
) { /** * An obsolete plaintext framing that does not use persistent sockets by default. */ HTTP_1_0("http/1.0"), /** * A plaintext framing that includes persistent connections. * * This version of OkHttp implements [RFC 7230][rfc_7230], and tracks revisions to that spec. * * [rfc_7230]: https://tools.ietf.org/html/rfc7230 */ HTTP_1_1("http/1.1"), /**Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jun 23 18:58:57 GMT 2025 - 4.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
import java.util.concurrent.SynchronousQueue import java.util.concurrent.ThreadPoolExecutor import java.util.concurrent.TimeUnit import okhttp3.internal.assertLockNotHeld import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealCall.AsyncCall import okhttp3.internal.okHttpName import okhttp3.internal.threadFactory import okhttp3.internal.unmodifiable /** * Policy on when async requests are executed. *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 14:16:22 GMT 2025 - 9.9K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
import java.util.logging.LogRecord import java.util.logging.Logger import okhttp3.internal.buildConnectionPool import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.concurrent.withLock import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.http2.Http2 import okhttp3.internal.taskRunnerInternal import okhttp3.testing.Flaky import okhttp3.testing.PlatformRule.Companion.LOOM_PROPERTY
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
ioe: IOException, ) = TODO() override fun connectionAcquired( call: Call, connection: Connection, ) = TODO() override fun connectionReleased( call: Call, connection: Connection, ) = TODO() override fun requestHeadersStart(call: Call) = TODO() override fun requestHeadersEnd(Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
*/ public void setMaxRetryCount(final int maxRetryCount) { this.maxRetryCount = maxRetryCount; } /** * Sets the connection timeout in milliseconds. * * @param connTimeout The connection timeout. */ public void setConnTimeout(final long connTimeout) { this.connTimeout = connTimeout; } /**Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
} @Test fun networkInterceptorsHaveConnectionAccess() { server.enqueue(MockResponse()) val interceptor = Interceptor { chain: Interceptor.Chain -> val connection = chain.connection() assertThat(connection).isNotNull() chain.proceed(chain.request()) } client = client .newBuilder() .addNetworkInterceptor(interceptor) .build()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 28.2K bytes - Click Count (0) -
src/main/java/jcifs/config/BaseConfiguration.java
/** Whether to disable Nagle's algorithm for TCP connections */ protected boolean smbTcpNoDelay = false; /** Response timeout in milliseconds for SMB operations */ protected int smbResponseTimeout = SmbConstants.DEFAULT_RESPONSE_TIMEOUT; /** Socket timeout in milliseconds for SMB connections */ protected int smbSocketTimeout = SmbConstants.DEFAULT_SO_TIMEOUT;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 36.5K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
final int localPort, final String hostName) { SmbTransport conn; synchronized (CONNECTIONS) { if (SSN_LIMIT != 1) { final ListIterator iter = CONNECTIONS.listIterator(); while (iter.hasNext()) { conn = (SmbTransport) iter.next();Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 31.8K bytes - Click Count (0)