- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 737 for contention (0.18 sec)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java
task.into(extension.getDocumentationRenderedRoot()); }); extension.getSourceRoot().convention(layout.getProjectDirectory().dir("src/docs")); extension.getDocumentationRenderedRoot().convention(layout.getBuildDirectory().dir("docs")); extension.getStagingRoot().convention(layout.getBuildDirectory().dir("working")); ConfigurableFileTree css = objects.fileTree();Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Jul 02 12:28:02 UTC 2025 - 7.6K bytes - Viewed (0) -
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) call.acquireConnectionNoEvents(connection) } call.eventListener.connectionAcquired(call, connection) connection.connectionListener.connectionAcquired(connection, call)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 19.3K bytes - Viewed (2) -
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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 25.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
connections.add(connection) // connection.queueEvent { connectionListener.connectEnd(connection) } scheduleCloser() } /** * Notify this pool that [connection] has become idle. Returns true if the connection has been * removed from the pool and should be closed. */ fun connectionBecameIdle(connection: RealConnection): Boolean { connection.assertLockHeld()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 11.1K 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 Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt
connection: Connection, route: Route, call: Call, ) {} /** * Invoked when a connection is released as no longer required. */ open fun connectionClosed(connection: Connection) {} /** * Invoked when a call is assigned a particular connection. */ open fun connectionAcquired( connection: Connection, call: Call, ) {} /**Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 2.2K 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
android/guava/src/com/google/common/base/CaseFormat.java
} }, /** Java variable naming convention, e.g., "lowerCamel". */ LOWER_CAMEL(CharMatcher.inRange('A', 'Z'), "") { @Override String normalizeWord(String word) { return firstCharOnlyToUpper(word); } @Override String normalizeFirstWord(String word) { return Ascii.toLowerCase(word); } }, /** Java and C++ class naming convention, e.g., "UpperCamel". */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Dec 03 18:46:33 UTC 2025 - 6.5K 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.5K 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 socketRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 19.2K bytes - Viewed (0)