Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 426 for doneCh (0.04 sec)

  1. cmd/admin-handlers_test.go

    	return &adminErasureTestBed{
    		erasureDirs: erasureDirs,
    		objLayer:    objLayer,
    		router:      adminRouter,
    		done:        cancel,
    	}, nil
    }
    
    // TearDown - method that resets the test bed for subsequent unit
    // tests to start afresh.
    func (atb *adminErasureTestBed) TearDown() {
    	atb.done()
    	removeRoots(atb.erasureDirs)
    	resetTestGlobals()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/GcFinalization.java

        do {
          System.runFinalization();
          if (predicate.isDone()) {
            return;
          }
          CountDownLatch done = new CountDownLatch(1);
          createUnreachableLatchFinalizer(done);
          await(done);
          if (predicate.isDone()) {
            return;
          }
        } while (System.nanoTime() - deadline < 0);
        throw formatRuntimeException(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	for i := range resyncParallelRoutines {
    		wg.Add(1)
    		workers[i] = make(chan ReplicateObjectInfo, 100)
    		i := i
    		go func(ctx context.Context, idx int) {
    			defer wg.Done()
    			for roi := range workers[idx] {
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    				default:
    				}
    				traceFn := s.trace(tgt.ResetID, fmt.Sprintf("%s/%s (%s)", opts.bucket, roi.Name, roi.VersionID))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/graph/TraverserTest.java

        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'b');
    
        // Iterate again to see if calculation is done again
        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'a', 'b', 'b');
      }
    
      @Test
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/graph/TraverserTest.java

        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'b');
    
        // Iterate again to see if calculation is done again
        assertEqualCharNodes(Iterables.limit(result, 2), "ab");
        assertThat(graph.requestedNodes).containsExactly('a', 'a', 'a', 'b', 'b');
      }
    
      @Test
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  6. docs/features/caching.md

    Deleting the cache when it is no longer needed can be done.  However this may delete the purpose of the cache
    which is designed to persist between app restarts.
    
    ```kotlin
    cache.delete()
    ```
     
    ## Pruning the Cache
    
    Pruning the entire Cache to clear space temporarily can be done using evictAll.
    
    ```kotlin
    cache.evictAll()
    ```
    
    Removing individual items can be done using the urls iterator.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                        crawler.awaitTermination(crawlingExecutionInterval);
                        if (crawler.getCrawlerContext().getStatus() == CrawlerStatus.DONE && !Constants.DONE.equals(crawlerStatusList.get(i))) {
                            crawlerStatusList.set(i, Constants.DONE);
                            final String sid = crawler.getCrawlerContext().getSessionId();
                            indexUpdater.addFinishedSessionId(sid);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

    /**
     * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code
     * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
     * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}.
     *
     * <p>Few users should use this class. It is intended primarily for those who are implementing an
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. buildscripts/disable-root.sh

    nr_servers=4
    
    addr="localhost"
    args=""
    for ((i = 0; i < $((nr_servers)); i++)); do
    	args="$args $scheme://$addr:$((9100 + i))/${HOME}/tmp/dist/path1/$i"
    done
    
    echo $args
    
    for ((i = 0; i < $((nr_servers)); i++)); do
    	(minio server --address ":$((9100 + i))" $args 2>&1 >/tmp/log$i.txt) &
    done
    
    sleep 10s
    
    if [ ! -f ./mc ]; then
    	wget --quiet -O ./mc https://dl.minio.io/client/mc/release/linux-amd64/./mc &&
    		chmod +x mc
    fi
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. docs/site-replication/run-ssec-object-replication-with-compression.sh

    echo "done"
    
    if [ ! -f ./mc ]; then
    	echo -n "Downloading MinIO client ..."
    	wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc &&
    		chmod +x mc
    	echo "done"
    fi
    
    export MC_HOST_minio1=https://minio:minio123@localhost:9001
    export MC_HOST_minio2=https://minio:minio123@localhost:9002
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top