- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 307 for STOP (0.02 sec)
-
src/main/java/org/codelibs/fess/exec/Crawler.java
System.exit(exitCode); } } 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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24K bytes - Viewed (0) -
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); } }); } public String getThumbnailPathOption() { return "-D" + Constants.FESS_THUMBNAIL_PATH + "=" + baseDir.getAbsolutePath(); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 21.5K bytes - Viewed (0) -
docs/en/docs/deployment/docker.md
#### Directory Structure You should now have a directory structure like: ``` . ├── app │ ├── __init__.py │ └── main.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 28.5K bytes - Viewed (0) -
src/archive/tar/reader.go
} // Set the final guess at the format. if format.has(FormatUSTAR) && format.has(FormatPAX) { format.mayOnlyBe(FormatUSTAR) } hdr.Format = format return hdr, nil // This is a file, so stop } } } // handleRegularFile sets up the current file reader and padding such that it // can only read the following logical data section. It will properly handle
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/test-utils_test.go
if !v.hasEnded() { v.stop() } } globalAllHealState.Unlock() } // Init background heal state if globalBackgroundHealState == nil { globalBackgroundHealState = newHealState(GlobalContext, false) } else { globalBackgroundHealState.Lock() for _, v := range globalBackgroundHealState.healSeqMap { if !v.hasEnded() { v.stop() } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
cmd/endpoint.go
var foundLocal bool resolvedList := make([]bool, len(endpoints)) // Mark the starting time startTime := time.Now() keepAliveTicker := time.NewTicker(500 * time.Millisecond) defer keepAliveTicker.Stop() for { // Break if the local endpoint is found already Or all the endpoints are resolved. if foundLocal || (epsResolved == len(endpoints)) { break }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 34.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
} } private void forceStop() { systemHelper.setForceStop(true); for (final Crawler crawler : crawlerList) { crawler.stop(); } } public long getExecuteTime() { return executeTime; } public List<String> getSessionIdList() { return sessionIdList; }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24.2K bytes - Viewed (0) -
cmd/metrics-resource.go
resourceMetricsMapMu.Lock() resourceMetricsMap = map[MetricSubsystem]ResourceMetrics{} resourceMetricsMapMu.Unlock() metricsTimer := time.NewTimer(resourceMetricsCollectionInterval) defer metricsTimer.Stop() collectLocalResourceMetrics() for { select { case <-GlobalContext.Done(): return case <-metricsTimer.C: collectLocalResourceMetrics() // Reset the timer for next cycle.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
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.isCanceled()) { accessTimeoutTask.cancel(); } } } }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Oct 12 01:41:37 UTC 2024 - 25.7K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
func monitorLocalDisksAndHeal(ctx context.Context, z *erasureServerPools) { // Perform automatic disk healing when a disk is replaced locally. diskCheckTimer := time.NewTimer(defaultMonitorNewDiskInterval) defer diskCheckTimer.Stop() for { select { case <-ctx.Done(): return case <-diskCheckTimer.C: healDisks := globalBackgroundHealState.getHealLocalDiskEndpoints() if len(healDisks) == 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0)