Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 302 for stopfn (0.08 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  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-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)
  10. 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