- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 483 for stop (0.03 sec)
-
internal/kms/config.go
client.Endpoints = endpoints // Keep the default key in the KES cache to prevent availability issues // when MinIO restarts go func() { timer := time.NewTicker(10 * time.Second) defer timer.Stop() defaultKey := env.Get(EnvKESDefaultKey, "") for { select { case <-ctx.Done(): return case <-timer.C: client.DescribeKey(ctx, defaultKey) } } }()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 11:46:39 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/tier.go
return time.Duration(r.Float64() * 5 * float64(time.Second)) } // To avoid all MinIO nodes reading the tier config object at the same // time. t := time.NewTimer(tierCfgRefresh + randInterval()) defer t.Stop() for { select { case <-ctx.Done(): return case <-t.C: err := config.Reload(ctx, objAPI) if err != nil { tierLogIf(ctx, err) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K bytes - Viewed (0) -
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) -
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) -
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/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)