Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 303 for stopfn (5.87 sec)

  1. docs/distributed/DECOMMISSION.md

    ```
    λ mc admin decommission status alias/ http://minio{1...2}/data{1...4}
    ERROR: This pool is not scheduled for decommissioning currently.
    ```
    
    ## Canceling a decommission
    
    Stop an on-going decommission in progress, mainly used in situations when the load may be too high and you may want to schedule the decommission at a later point in time.
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  2. docs/contribute/code_of_conduct.md

    personally. The committee will then review the incident, follow up with any additional questions,
    and make a decision as to how to respond.
    
    Anyone asked to stop unacceptable behavior is expected to comply immediately. If an individual
    engages in unacceptable behavior, the Square Code of Conduct committee may take any action they deem
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

            int activeCrawlerNum = 0;
            try {
                while (startedCrawlerNum < crawlerList.size()) {
                    // Force to stop crawl
                    if (systemHelper.isForceStop()) {
                        for (final Crawler crawler : crawlerList) {
                            crawler.stop();
                        }
                        break;
                    }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/base/Suppliers.java

       * <p>When the underlying delegate throws an exception then this memoizing supplier will keep
       * delegating calls until it returns valid data.
       *
       * @param duration the length of time after a value is created that it should stop being returned
       *     by subsequent {@code get()} calls
       * @param unit the unit that {@code duration} is expressed in
       * @throws IllegalArgumentException if {@code duration} is not positive
       * @since 2.0
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  5. cmd/bucket-targets.go

    	return clnt
    }
    
    // heartBeat performs liveness check on remote endpoints.
    func (sys *BucketTargetSys) heartBeat(ctx context.Context) {
    	hcTimer := time.NewTimer(defaultHealthCheckDuration)
    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    			for _, ep := range sys.hc {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                }
                destroyContainer();
            }
    
            System.exit(exitCode);
        }
    
        private static void destroyContainer() {
            TimeoutManager.getInstance().stop();
            synchronized (SingletonLaContainerFactory.class) {
                SingletonLaContainerFactory.destroy();
            }
        }
    
        private static int process(final Options options) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/ds/AbstractDataStore.java

        }
    
        /**
         * Get the name of this data store.
         * @return The name of this data store.
         */
        protected abstract String getName();
    
        @Override
        public void stop() {
            alive = false;
        }
    
        @Override
        public void store(final DataConfig config, final IndexUpdateCallback callback, final DataStoreParams initParamMap) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is
       * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing
       * tasks. Second, the returned list will always be empty, as any submitted task is considered to
       * have started execution. This applies also to tasks given to {@code invokeAll} or {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/testers/NavigableMapNavigationTester.java

            b = entries.get(1);
            c = entries.get(2);
          }
        }
      }
    
      /** Resets the contents of navigableMap to have entries a, c, for the navigation tests. */
      @SuppressWarnings("unchecked") // Needed to stop Eclipse whining
      private void resetWithHole() {
        Entry<K, V>[] entries = (Entry<K, V>[]) new Entry<?, ?>[] {a, c};
        super.resetMap(entries);
        navigableMap = (NavigableMap<K, V>) getMap();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top