Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 146 for interrupted (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top