Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 128 for step (1.35 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/gcs/GcsClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb1/SmbClientTest.java

            }
        }
    
        @Override
        protected void tearDown() throws Exception {
            if (sambaServer != null) {
                sambaServer.stop();
            }
            super.tearDown();
        }
    
        public void test_doGet() throws Exception {
            try (final ResponseData responseData = smbClient.doGet(baseUrl + "file1.txt")) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Sep 23 06:42:59 UTC 2025
    - 30K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

                fileCache.remove(path);
            }
        }
    
        /**
         * Shutdown the lease manager
         */
        public void shutdown() {
            log.info("Shutting down lease manager");
    
            // Stop cleanup executor
            if (cleanupExecutor != null) {
                cleanupExecutor.shutdown();
                try {
                    if (!cleanupExecutor.awaitTermination(5, TimeUnit.SECONDS)) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 20K bytes
    - Viewed (2)
  5. docs/smb3-features/06-witness-protocol-design.md

            assertNotNull(registration);
            assertEquals(WitnessRegistrationState.REGISTERED, registration.getState());
            
            client.close();
        } finally {
            mockService.stop();
        }
    }
    ```
    
    ### 7.2 Integration Tests
    ```java
    @Test
    @EnabledIfSystemProperty(named = "witness.test.enabled", matches = "true")
    public void testWitnessFailover() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/Crawler.java

         * 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()) {
                    logger.debug("Destroying LaContainer...");
                }
                SingletonLaContainerFactory.destroy();
                logger.info("Destroyed LaContainer.");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 40K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

            }
            generatorList.forEach(g -> {
                try {
                    g.destroy();
                } catch (final Exception e) {
                    logger.warn("Failed to stop thumbnail generator.", e);
                }
            });
        }
    
        /**
         * Gets the system property option string for thumbnail path configuration.
         *
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java

            }
        }
    
        @Override
        protected void tearDown() throws Exception {
            if (sambaServer != null) {
                sambaServer.stop();
            }
            super.tearDown();
        }
    
        public void test_doGet() throws Exception {
            try (final ResponseData responseData = smbClient.doGet(baseUrl + "file1.txt")) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Sep 23 06:42:59 UTC 2025
    - 31.9K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

            }
        }
    
        @AfterAll
        void teardownContainer() throws Exception {
            if (sambaContainer != null) {
                sambaContainer.stop();
            }
            if (tempDir != null && Files.exists(tempDir)) {
                // Clean up temporary directory
                deleteDirectory(tempDir);
            }
        }
    
        @BeforeEach
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
Back to top