Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 366 for stopFn (0.28 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

     * The class provides methods to interrupt the thread and stop the timeout target.
     *
     * <p>
     * The class uses a logger to log debug messages.
     * It also uses an AtomicBoolean to track whether the thread is running.
     * </p>
     *
     * <p>
     * The expired method is called when a timeout occurs.
     * It interrupts the running thread up to a maximum number of times.
     * The stop method is called to stop the timeout target.
     * </p>
     */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                thread.start();
                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManager started.");
                }
            }
        }
    
        /**
         * Stops the process.
         */
        public synchronized void stop() {
            if (thread != null) {
                thread.interrupt();
                thread = null;
                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManager stopped.");
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  3. src/bufio/scan.go

    //
    // Scanning stops if the function returns an error, in which case some of
    // the input may be discarded. If that error is [ErrFinalToken], scanning
    // stops with no error. A non-nil token delivered with [ErrFinalToken]
    // will be the last token, and a nil token with [ErrFinalToken]
    // immediately stops the scanning.
    //
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed May 21 18:05:26 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  4. src/bufio/example_test.go

    			return 0, data, bufio.ErrFinalToken
    		}
    		// If the token is "STOP", stop the scanning and ignore the rest.
    		if string(data[:i]) == "STOP" {
    			return i + 1, nil, bufio.ErrFinalToken
    		}
    		// Otherwise, return the token before the comma.
    		return i + 1, data[:i], nil
    	}
    	const input = "1,2,STOP,4,"
    	scanner := bufio.NewScanner(strings.NewReader(input))
    	scanner.Split(onComma)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/timer/TimeoutTask.java

         *
         * @return whether the task is stopped
         */
        public boolean isStopped() {
            return status == STOPPED;
        }
    
        /**
         * Stops the timer.
         */
        public void stop() {
            if (status != ACTIVE) {
                throw new ClIllegalStateException(String.valueOf(status));
            }
            status = STOPPED;
        }
    
        /**
         * Restarts the timer.
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

        }
    
        /**
         * Stops a scheduled job by ID.
         *
         * @param id the ID of the scheduled job to stop
         * @return JSON response indicating success or failure
         */
        // PUT /api/admin/scheduler/{id}/stop
        @Execute(urlPattern = "{}/@word")
        public JsonResponse<ApiResult> put$stop(final String id) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sun Nov 23 12:34:02 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/Stopwatch.java

        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
       * @throws IllegalStateException if the stopwatch is already stopped.
       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbCopyUtilTest.java

            verify(out, timeout(1000)).write(payload, 0, 3);
    
            // Stop the thread by sending n = -1
            synchronized (w) {
                w.write(new byte[0], -1, out);
            }
    
            w.join(2000);
            assertFalse(w.isAlive(), "WriterThread should stop after -1 sentinel");
        }
    
        @Test
        @DisplayName("WriterThread surfaces SmbException via checkException")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            }
        }
    
        /**
         * Forces all crawlers to stop immediately.
         * Sets the force stop flag and stops all active crawler instances.
         */
        private void forceStop() {
            systemHelper.setForceStop(true);
            if (crawlerList != null) {
                for (final Crawler crawler : crawlerList) {
                    crawler.stop();
                }
            }
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java

            });
            return redirect(getClass());
        }
    
        /**
         * Stops a running scheduled job.
         *
         * @param form the edit form containing the ID of the job to stop
         * @return HTML response redirecting to the list page after stopping
         */
        @Execute
        @Secured({ ROLE })
        public HtmlResponse stop(final EditForm form) {
            verifyCrudMode(form.crudMode, CrudMode.DETAILS, this::asListHtml);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 21.8K bytes
    - Viewed (0)
Back to top