Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 329 for closes (0.03 sec)

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

         */
        ResponseData execute(RequestData data);
    
        /**
         * Closes the crawler client and releases any resources associated with it.
         * This default implementation does nothing.
         *
         * @throws Exception if an error occurs during closing
         */
        @Override
        default void close() throws Exception {
            // nothing
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

     * is deleted when the stream is closed.
     */
    public class TemporaryFileInputStream extends InputStream {
        private static final Logger logger = LogManager.getLogger(TemporaryFileInputStream.class);
    
        private final File tempFile;
    
        private final FileInputStream fileInputStream;
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java

                logger.warn("clientConnectionManager is null.");
                return;
            }
    
            try {
                // Close expired connections
                clientConnectionManager.closeExpiredConnections();
                // Close idle connections
                clientConnectionManager.closeIdleConnections(idleConnectionTimeout, TimeUnit.MILLISECONDS);
            } catch (final Exception e) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            if (smbAuthentications != null) {
                for (final SmbAuthentication smbAuthentication : smbAuthentications) {
                    holder.add(smbAuthentication);
                }
            }
            smbAuthenticationHolder = holder;
        }
    
        /**
         * Closes the SMB client, releasing resources.
         */
        @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java

            this.clientMap = clientMap;
        }
    
        /**
         * Closes all clients in the factory.
         */
        @Override
        public void close() {
            clientMap.values().stream().distinct().forEach(client -> {
                try {
                    client.close();
                } catch (final Exception e) {
                    logger.warn("Failed to close {}.", client.getClass().getCanonicalName(), e);
                }
            });
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/ResponseData.java

            requestData.setMethod(method);
            requestData.setUrl(url);
            return requestData;
        }
    
        /**
         * Closes the response data, deleting temporary files if any.
         * @throws IOException if an I/O error occurs.
         */
        @Override
        public void close() throws IOException {
            if (isTemporaryFile) {
                FileUtil.deleteInBackground(responseBodyFile);
            }
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

                }
            }
        }
    
        /**
         * Closes the underlying CrawlerClient and releases any resources associated with it.
         *
         * @throws Exception if an error occurs during the close operation
         */
        @Override
        public void close() throws Exception {
            client.close();
        }
    
        /**
         * Returns the underlying CrawlerClient.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            dataService.delete(sessionId);
            urlFilter.clear();
        }
    
        /**
         * Closes the crawler, releasing resources.
         * This method is called automatically when the crawler is used in a try-with-resources statement.
         */
        @Override
        public void close() {
            clientFactory.close();
        }
    
        /**
         * Adds an include filter for URLs.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

                }
            }
        }
    
        /**
         * Destroys the client and closes connections.
         */
        @PreDestroy
        public void destroy() {
            if (client != null) {
                try {
                    client.close();
                } catch (final OpenSearchException e) {
                    logger.warn("Failed to close client.", e);
                }
                logger.info("Disconnected to {}", address);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

            final TimeUnit timeUnit = TimeUnit.valueOf(getInitParameter(TIME_TO_LIVE_TIME_UNIT_PROPERTY, "MINUTES", String.class));
            final int maxTotal = getInitParameter(MAX_TOTAL_CONNECTION_PROPERTY, 200, Integer.class);
            final int defaultMaxPerRoute = getInitParameter(DEFAULT_MAX_CONNECTION_PER_ROUTE_PROPERTY, 20, Integer.class);
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 52.2K bytes
    - Viewed (0)
Back to top