- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for addTimeoutTarget (0.12 sec)
-
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
cb.query().setJobStatus_Equal(Constants.RUNNING); cb.query().setTarget_Equal(myName); }); } TimeoutManager.getInstance().addTimeoutTarget(() -> { if (logger.isDebugEnabled()) { logger.debug("Updating scheduled jobs. time:{}", schedulerTime); } final long now = systemHelper.getCurrentTimeAsLong();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
logger.debug("role: {}", roleSet); } final String[] roles = roleSet.toArray(new String[roleSet.size()]); if (!subRoleSet.isEmpty()) { TimeoutManager.getInstance().addTimeoutTarget(() -> { sAMAccountGroupNameSet.stream().forEach(groupName -> { getSAMAccountGroupName(bindDn, groupName).ifPresent(sAMAccountGroupName -> {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 82K bytes - Viewed (0)