Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 596 for DONE (0.02 sec)

  1. guava/src/com/google/common/hash/MessageDigestHashFunction.java

          checkNotDone();
          digest.update(bytes);
        }
    
        private void checkNotDone() {
          checkState(!done, "Cannot re-use a Hasher after calling hash() on it");
        }
    
        @Override
        public HashCode hash() {
          checkNotDone();
          done = true;
          return (bytes == digest.getDigestLength())
              ? HashCode.fromBytesNoCopy(digest.digest())
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  2. .github/workflows/multipart/migrate.sh

    	docker-compose -f docker-compose-site1.yaml rm -s -f || true
    	docker-compose -f docker-compose-site2.yaml rm -s -f || true
    	for volume in $(docker volume ls -q | grep minio); do
    		docker volume rm ${volume} || true
    	done
    
    	docker system prune -f || true
    	docker volume prune -f || true
    	docker volume rm $(docker volume ls -q -f dangling=true) || true
    }
    
    cleanup
    
    if [ ! -f ./mc ]; then
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerStatus.java

    /**
     * Enum representing the status of a crawler.
     * It can be INITIALIZING, RUNNING, or DONE.
     */
    public enum CrawlerStatus {
        /**
         * The crawler is initializing.
         */
        INITIALIZING,
    
        /**
         * The crawler is currently running.
         */
        RUNNING,
    
        /**
         * The crawler has completed its task.
         */
        DONE;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 997 bytes
    - Viewed (0)
  4. internal/lru/lru.go

    	if res.ttl != noEvictionTTL {
    		go func(done <-chan struct{}) {
    			ticker := time.NewTicker(res.ttl / numBuckets)
    			defer ticker.Stop()
    			for {
    				select {
    				case <-done:
    					return
    				case <-ticker.C:
    					res.deleteExpired()
    				}
    			}
    		}(res.done)
    	}
    	return &res
    }
    
    // Purge clears the cache completely.
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/hash/MacHashFunction.java

          checkNotDone();
          checkNotNull(bytes);
          mac.update(bytes);
        }
    
        private void checkNotDone() {
          checkState(!done, "Cannot re-use a Hasher after calling hash() on it");
        }
    
        @Override
        public HashCode hash() {
          checkNotDone();
          done = true;
          return HashCode.fromBytesNoCopy(mac.doFinal());
        }
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 3.6K 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.1K bytes
    - Viewed (1)
  7. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    // Caller should close the channel when done.
    // The returned function will return the results once there is enough or input is closed,
    // or the context is canceled.
    func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) {
    	resultsDone := make(chan metaCacheEntriesSorted)
    	// Copy so we can mutate
    	resCh := resultsDone
    	var done atomic.Bool
    	resErr := io.EOF
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  9. cmd/notification.go

    		wg.Add(1)
    		go func(ctx context.Context, peerChannel <-chan MetricV2, wg *sync.WaitGroup) {
    			defer wg.Done()
    			for {
    				select {
    				case m, ok := <-peerChannel:
    					if !ok {
    						return
    					}
    					select {
    					case ch <- m:
    					case <-ctx.Done():
    						return
    					}
    				case <-ctx.Done():
    					return
    				}
    			}
    		}(ctx, peerChannels[index], &wg)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  10. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top