Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for addTimeoutTarget (0.3 sec)

  1. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance()
                        .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(),
                                true);
    
                final int totalCount = process(options);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            final ExtractData data = new ExtractData();
            final HttpPost httpPost = new HttpPost(url);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/exec/Crawler.java

                systemMonitorTask = TimeoutManager.getInstance()
                        .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getCrawlerSystemMonitorIntervalAsInteger(),
                                true);
    
                if (options.hotThread != null) {
                    hotThreadMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new HotThreadMonitorTarget(), options.hotThread, true);
                }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 31K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/JobHelper.java

         */
        public TimeoutTask startMonitorTask(final JobLog jobLog) {
            final TimeoutTarget target = new MonitorTarget(jobLog);
            return TimeoutManager.getInstance().addTimeoutTarget(target, monitorInterval, true);
        }
    
        /**
         * Sets the monitor interval for job monitoring.
         *
         * @param monitorInterval the monitor interval in seconds
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/io/FileUtil.java

         *
         * @param file
         *            The file to delete.
         */
        public static void deleteInBackground(final File file) {
            if (file != null) {
                TimeoutManager.getInstance().addTimeoutTarget(() -> {
                    try {
                        Files.deleteIfExists(file.toPath());
                    } catch (final IOException e) {
                        throw new IORuntimeException(e);
                    }
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/ExecJob.java

         */
        protected TimeoutTask createTimeoutTask() {
            if (timeout <= 0) {
                return null;
            }
            return TimeoutManager.getInstance().addTimeoutTarget(() -> {
                logger.warn("Process is terminated due to {} second exceeded.", timeout);
                ComponentUtil.getProcessHelper().destroyProcess(sessionId);
                processTimeout = true;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                    }
                };
                Runtime.getRuntime().addShutdownHook(shutdownCallback);
    
                systemMonitorTask = TimeoutManager.getInstance()
                        .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(),
                                true);
    
                exitCode = process(options);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 22.5K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17.9K bytes
    - Viewed (2)
Back to top