- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 238 for Shutdown (0.05 sec)
-
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProvider.java
public String getProviderName() { return "TCP Fallback"; } @Override public int getMaxMessageSize() { return 65536; // 64KB for TCP } @Override public void shutdown() { // Nothing to clean up for TCP }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 20.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherCleanupTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 1.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
implements ListeningScheduledExecutorService { private final ListeningExecutorService delegate = newDirectExecutorService(); @Override public void shutdown() { delegate.shutdown(); } @Override public List<Runnable> shutdownNow() { return delegate.shutdownNow(); } @Override public boolean isShutdown() { return delegate.isShutdown(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
implements ListeningScheduledExecutorService { private final ListeningExecutorService delegate = newDirectExecutorService(); @Override public void shutdown() { delegate.shutdown(); } @Override public List<Runnable> shutdownNow() { return delegate.shutdownNow(); } @Override public boolean isShutdown() { return delegate.isShutdown(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java
verify(mockChannelManager, atLeast(1)).establishReplacementChannel(); } @Test void testShutdown() { failover.shutdown(); // Should not throw any exceptions assertDoesNotThrow(() -> failover.shutdown()); } @Test void testConcurrentFailureHandling() throws InterruptedException { IOException error = new IOException("Connection failed");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.7K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/Dispatcher.kt
@Throws(InterruptedException::class) abstract fun dispatch(request: RecordedRequest): MockResponse open fun peek(): MockResponse = MockResponse().apply { this.socketPolicy = SocketPolicy.KEEP_OPEN } open fun shutdown() {}
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 894 bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 4.1K bytes - Viewed (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 875 bytes - Viewed (0)