- Sort Score
- Num 10 results
- Language All
Results 291 - 300 of 374 for cancelCh (0.1 seconds)
-
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
logger.error("ThumbnailGenerator terminated unexpectedly.", t); exitCode = Constants.EXIT_FAIL; } finally { if (systemMonitorTask != null) { systemMonitorTask.cancel(); } destroyContainer(); } System.exit(exitCode); } private static void destroyContainer() { TimeoutManager.getInstance().stop();
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 9.4K bytes - Click Count (0) -
docs/metrics/prometheus/list.md
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 43.4K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java
} finally { if (accessTimeout != null) { accessTimeoutTarget.stop(); if (!accessTimeoutTask.isCanceled()) { accessTimeoutTask.cancel(); } } } return data; } /** * Sets the URL of the API endpoint. * @param url The URL to set. */Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 12.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
"ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait. }) private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet. * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 10K bytes - Click Count (0) -
internal/grid/msg.go
OpMuxConnectError // OpDisconnectClientMux instructs a client to disconnect a mux OpDisconnectClientMux // OpDisconnectServerMux instructs a server to disconnect (cancel) a server mux OpDisconnectServerMux // OpMuxClientMsg contains a message to a client Mux OpMuxClientMsg // OpMuxServerMsg contains a message to a server Mux OpMuxServerMsg
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jul 25 21:07:21 GMT 2024 - 7.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
* State#RUNNING}. Services that need to cancel startup work can override {@link #doCancelStart}. */ @ForOverride protected abstract void doStop(); /** * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override theCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 20.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
logger.error("SuggestCreator terminated unexpectedly.", t); exitCode = Constants.EXIT_FAIL; } finally { if (systemMonitorTask != null) { systemMonitorTask.cancel(); } destroyContainer(); } logger.info("Finished SuggestCreator."); System.exit(exitCode); } private static void destroyContainer() {
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 11.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the suggest creator process.
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the thumbnail generator process.
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 11.7K bytes - Click Count (0) -
cmd/object-api-utils_test.go
// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req) ctx, cancel := context.WithCancel(GlobalContext) defer cancel() // Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 24.1K bytes - Click Count (0)