Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 206 for shutdowned (0.19 sec)

  1. src/main/java/jcifs/smb1/smb1/SmbSession.java

                                     * server will return "Access denied" even if a logoff is
                                     * sent. Unfortunately calling disconnect() doesn't always
                                     * actually shutdown the connection before other threads
                                     * have committed themselves (e.g. InterruptTest example).
                                     */
                                    try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

        }
    
        /**
         * Close the transport pool and cleanup resources
         */
        public void closePool() {
            stopProactiveHealthChecking();
            healthCheckExecutor.shutdown();
            try {
                if (!healthCheckExecutor.awaitTermination(5, TimeUnit.SECONDS)) {
                    healthCheckExecutor.shutdownNow();
                }
            } catch (InterruptedException e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

                pool.execute(() -> {
                    assertEquals(result, crawlingInfoHelper.generateId(dataMap));
                    counter.incrementAndGet();
                });
            }
            pool.shutdown();
            pool.awaitTermination(10, TimeUnit.SECONDS);
            assertEquals(1000, counter.get());
        }
    
        public void test_getCanonicalSessionId() {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 05:35:01 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  4. docs/smb3-features/04-directory-leasing-design.md

        return directoryLeaseManager;
    }
    
    @Override
    public void logoff() throws IOException {
        if (directoryLeaseManager != null) {
            directoryLeaseManager.shutdown();
        }
        super.logoff();
    }
    ```
    
    ## 6. Configuration
    
    ### 6.1 Configuration Properties
    ```java
    // In PropertyConfiguration.java
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) // New connection.
      }
    
      /**
       * We had a bug where we'd perform infinite retries of route that fail with connection shutdown
       * errors. The problem was that the logic that decided whether to reuse a route didn't track
       * certain HTTP/2 errors. https://github.com/square/okhttp/issues/5547
       */
      @ParameterizedTest
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

         * originally reported in.
         */
        for (Future<?> future : futures.build()) {
          future.get();
        }
        executor.shutdown();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 32.7K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

      @BeforeEach
      fun setUp() {
        platform.assumeNotOpenJSSE()
        platform.assumeHttp2Support()
      }
    
      @AfterEach
      fun tearDown() {
        executorService.shutdown()
      }
    
      @Test
      @Throws(IOException::class)
      fun http1DoesntSupportDuplex() {
        val call =
          client.newCall(
            Request
              .Builder()
              .url(server.url("/"))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/SecureKeyManager.java

            try {
                // Cancel rotation task
                if (rotationTask != null) {
                    rotationTask.cancel(false);
                    rotationTask = null;
                }
    
                // Shutdown rotation scheduler
                rotationScheduler.shutdownNow();
    
                clearAllKeys();
            } finally {
                // Wipe KeyStore password
                if (keyStorePassword != null) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/exec/Crawler.java

            }
        }
    
        /**
         * Destroys the DI container and stops the timeout manager.
         * This method ensures proper cleanup of resources when the crawler shuts down.
         * It's called both during normal shutdown and in error conditions.
         */
        private static void destroyContainer() {
            if (running.getAndSet(false)) {
                TimeoutManager.getInstance().stop();
                if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 31K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            }
        }
    
        @Override
        @PreDestroy
        public void close() throws Exception {
            if (executorService != null) {
                try {
                    executorService.shutdown();
                    executorService.awaitTermination(60, TimeUnit.SECONDS);
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 24.8K bytes
    - Viewed (0)
Back to top