- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 4,869 for Done (0.2 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
Thread.interrupted(); } /** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.9K bytes - Viewed (0) -
cmd/peer-rest-client.go
// Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return default: // There was error in the REST request, retry after sometime as probably the peer is down. time.Sleep(5 * time.Second) } } }() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/os_other.go
maxEntries = opts.count } done := false remaining := opts.count for !done { // Read up to max number of entries. fis, err := d.Readdir(maxEntries) if err != nil { if err == io.EOF { break } return nil, osErrToFileErr(err) } if opts.count > -1 { if remaining <= len(fis) { fis = fis[:remaining] done = true } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 4K bytes - Viewed (0) -
src/main/assemblies/files/fess
if expr "$link" : '/.*' > /dev/null; then SCRIPT="$link" else SCRIPT=`dirname "$SCRIPT"`/"$link" fi done # determine fess home FESS_HOME=`dirname "$SCRIPT"`/.. # make FESS_HOME absolute FESS_HOME=`cd "$FESS_HOME"; pwd` # If an include wasn't specified in the environment, then search for one... if [ "x$FESS_INCLUDE" = "x" ]; then # Locations (in order) to use when searching for an include file.
Shell Script - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && bucketName != "" { if ev.S3.Bucket.Name != bucketName {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/grid/grid_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func (es *expiryState) enqueueTierJournalEntry(je jentry) { wrkr := es.getWorkerCh(je.OpHash()) if wrkr == nil { es.stats.missedTierJournalTasks.Add(1) return } select { case <-GlobalContext.Done(): case wrkr <- je: default: es.stats.missedTierJournalTasks.Add(1) } } // enqueueFreeVersion enqueues a free version to be deleted func (es *expiryState) enqueueFreeVersion(oi ObjectInfo) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
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.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.1K bytes - Viewed (0) -
cni/pkg/repair/repair.go
} rc, err := NewRepairController(client, cfg) if err != nil { repairLog.Fatalf("Fatal error constructing repair controller: %+v", err) } go rc.Run(ctx.Done()) client.RunAndWait(ctx.Done()) } // Set up Kubernetes client using kubeconfig (or in-cluster config if no file provided) func clientSetup() (kube.Client, error) { config, err := kube.DefaultRestConfig("", "") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
maven-artifact/src/main/java/org/apache/maven/artifact/versioning/VersionRange.java
Iterator<Restriction> i1 = r1.iterator(); Iterator<Restriction> i2 = r2.iterator(); Restriction res1 = i1.next(); Restriction res2 = i2.next(); boolean done = false; while (!done) { if (res1.getLowerBound() == null || res2.getUpperBound() == null || res1.getLowerBound().compareTo(res2.getUpperBound()) <= 0) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 07:40:37 GMT 2024 - 18.9K bytes - Viewed (0)