- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 146 for interrupted (0.08 sec)
-
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
healthCheckExecutor.shutdownNow(); } } catch (InterruptedException e) { healthCheckExecutor.shutdownNow(); Thread.currentThread().interrupt(); } // Close all connections without synchronization - concurrent collections are thread-safe connections.forEach(conn -> { try { conn.disconnect(true, true);
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/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
completedOps.incrementAndGet(); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } finally { endLatch.countDown(); } }); } startLatch.countDown(); // Start all threads
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 43.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
cleanupExecutor.shutdownNow(); } } catch (InterruptedException e) { cleanupExecutor.shutdownNow(); Thread.currentThread().interrupt(); } } // Clean up expired weak references cleanupExpiredReferences(); // Release all leases releaseAll(); // Clear file cache
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
this.futures = checkNotNull(futures); this.allMustSucceed = allMustSucceed; this.collectsValues = collectsValues; } @Override @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller. protected final void afterDone() { super.afterDone(); @RetainedLocalRef ImmutableCollection<? extends Future<?>> localFutures = futures;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
try { Thread.sleep(5000); } catch (InterruptedException ie) { Thread.currentThread().interrupt(); break; } } } } }); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
docs/en/docs/deployment/concepts.md
## Running on Startup { #running-on-startup } In most cases, when you create a web API, you want it to be **always running**, uninterrupted, so that your clients can always access it. This is of course, unless you have a specific reason why you want it to run only in certain situations, but most of the time you want it constantly running and **available**.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 18.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Failed to interrupt executor.", e); } } finally { executor.shutdownNow(); } if (!deleteUrlList.isEmpty()) { deleteDocuments(); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 28.9K bytes - Viewed (0) -
docs/smb3-features/06-witness-protocol-design.md
// Wait briefly for witness notification before retrying try { Thread.sleep(2000); // 2 second grace period } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } // Proceed with normal error handling/retry super.handleConnectionLoss(error); } ``` ## 6. Configuration ### 6.1 Configuration Properties ```java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 42K bytes - Viewed (0) -
cmd/server-main.go
// serverMain handler called for 'minio server' command. func serverMain(ctx *cli.Context) { r := rand.New(rand.NewSource(time.Now().UnixNano())) var warnings []string signal.Notify(globalOSSignalCh, os.Interrupt, syscall.SIGTERM, syscall.SIGQUIT) go handleSignals() setDefaultProfilerRates() // Initialize globalConsoleSys system bootstrapTrace("newConsoleLogger", func() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
ifNoneMatch.compareAndSet(null, chain.request().header("If-None-Match")) chain.proceed(chain.request()) }, ).build() // Confirm the value is cached and intercepted. assertThat(get(url).body.string()).isEqualTo("A") assertThat(ifNoneMatch.get()).isEqualTo("v1") } @Test fun networkInterceptorNotInvokedForFullyCached() { server.enqueue(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 113.6K bytes - Viewed (0)