Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 374 for cancelCh (0.05 seconds)

  1. 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)
  2. docs/metrics/prometheus/list.md

    | `minio_s3_requests_5xx_errors_total`          | Total number S3 requests with (5xx) errors.              |
    | `minio_s3_requests_canceled_total`            | Total number S3 requests canceled by the client.         |
    | `minio_s3_requests_errors_total`              | Total number S3 requests with (4xx and 5xx) errors.      |
    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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 the
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top