- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 542 for contention (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// 3 different lookups in the connection pool! val pooled3 = routePlanner.planReusePooledConnection(this, routes) if (pooled3 != null) return pooled3.connection connection.withLock { connectionPool.put(connection) user.acquireConnectionNoEvents(connection) } user.connectionAcquired(connection) user.connectionConnectionAcquired(connection) return connection }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
// flow-control window is fully depleted. if (!flushHeaders) { withLock { flushHeaders = (connection.writeBytesTotal >= connection.writeBytesMaximum) } } connection.writeHeaders(id, outFinished, responseHeaders) if (flushHeaders) { connection.flush() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
if (ex != null) { throw ex; } throw new TransportException("All connection attempts failed"); } /** * Checks if the specified transport is contained in the connection pool * @param trans the transport to check for * @return whether (non-exclusive) connection is in the pool */ public boolean contains(final SmbTransport trans) { cleanup();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
src/main/java/jcifs/SmbTransportPool.java
/** * Get transport connection * * @param tc * context to use * @param address the server address * @param port the port number * @param exclusive * whether to acquire an unshared connection * @param forceSigning * whether to enforce SMB signing on this connection * @return a transport connection to the target */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.5K bytes - Viewed (0) -
src/main/java/jcifs/http/NtlmHttpURLConnection.java
/** * Creates a new NTLM HTTP URL connection that wraps an existing HTTP connection. * * @param connection * connection to wrap * @param tc * context to use */ public NtlmHttpURLConnection(final HttpURLConnection connection, final CIFSContext tc) { super(connection.getURL()); this.connection = connection; this.transportContext = tc;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 25.6K bytes - Viewed (0) -
apache-maven/src/assembly/maven/conf/settings.xml
| or the command line, profiles have to have an ID that is unique. | | An encouraged best practice for profile identification is to use a consistent naming convention | for profiles, such as 'env-dev', 'env-test', 'env-production', 'user-jdcasey', 'user-brett', etc. | This will make it more intuitive to understand what the set of introduced profiles is attempting
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jan 22 07:44:50 UTC 2025 - 11.1K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportPoolImplTest.java
// Create an existing connection SmbTransportImpl first = testPool.getSmbTransport(ctx, address, 445, false); // When: Request another connection // Note: Real SmbTransportImpl will report as disconnected without actual socket SmbTransportImpl second = testPool.getSmbTransport(ctx, address, 445, false); // Then: Will create new connection since real transport has no socket
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 19.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
} /** * Invoked after a connection has been acquired for the `call`. * * This can be invoked more than 1 time for a single [Call]. For example, if the response * to the [Call.request] is a redirect to a different address. */ open fun connectionAcquired( call: Call, connection: Connection, ) { } /** * Invoked after a connection has been released for the `call`. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 17.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
} } else { exchange.noRequestBody() if (!exchange.connection.isMultiplexed) { // If the "Expect: 100-continue" expectation wasn't met, prevent the HTTP/1 connection // from being reused. Otherwise we're still obligated to transmit the request body to // leave the connection in a consistent state. exchange.noNewExchangesOnConnection() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 7.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
// Play it back. val connection = connect(peer) connection.newStream(headerEntries("a", "android"), false) connection.withLock { if (!connection.isHealthy(System.nanoTime())) { throw ConnectionShutdownException() } } connection.writePing() connection.shutdown(ErrorCode.PROTOCOL_ERROR) assertThat(connection.openStreamCount()).isEqualTo(1)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0)