Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for drain (0.05 sec)

  1. android/guava-tests/test/com/google/common/collect/QueuesTest.java

      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
          TimeUnit unit,
          boolean interruptibly)
          throws InterruptedException {
        return interruptibly
            ? Queues.drain(q, buffer, maxElements, timeout, unit)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/Queues.java

      @GwtIncompatible // BlockingQueue
      public static <E> int drain(
          BlockingQueue<E> q, Collection<? super E> buffer, int numElements, Duration timeout)
          throws InterruptedException {
        // TODO(b/126049426): Consider using saturateToNanos(timeout) instead.
        return drain(q, buffer, numElements, timeout.toNanos(), NANOSECONDS);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Queues.java

      public static <E> int drain(
          BlockingQueue<E> q, Collection<? super E> buffer, int numElements, Duration timeout)
          throws InterruptedException {
        // TODO(b/126049426): Consider using saturateToNanos(timeout) instead.
        return drain(q, buffer, numElements, timeout.toNanos(), NANOSECONDS);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    		}
    		h.mutex.Unlock()
    	case <-h.ctx.Done():
    		h.mutex.Lock()
    		h.endTime = UTCNow()
    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         */
        int threshold;
    
        /** The per-segment table. */
        volatile @Nullable AtomicReferenceArray<E> table;
    
        /**
         * A counter of the number of reads since the last write, used to drain queues on a small
         * fraction of read operations.
         */
        final AtomicInteger readCount = new AtomicInteger();
    
        Segment(MapMakerInternalMap<K, V, E, S> map, int initialCapacity) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    		Timeout:   10 * time.Second,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	if err == nil {
    		// Drain the connection.
    		xhttp.DrainBody(resp.Body)
    	}
    	if resp != nil {
    		amzid := resp.Header.Get(xhttp.AmzRequestHostID)
    		if _, ok := globalNodeNamesHex[amzid]; ok {
    			return BucketRemoteIdenticalToSource{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.30.md

    - Fixed a bug where `kubectl` drain would consider a pod as having been deleted if an error occurs while calling the API. ([#122574](https://github.com/kubernetes/kubernetes/pull/122574), [@brianpursley](https://github.com/brianpursley))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Jun 18 18:59:10 UTC 2025
    - 398.1K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.31.md

      - filename
      - force
      - grace-period
      - kustomize
      - recursive
      - timeout
      - wait
      
      Drop support for the deprecated --delete-local-data from kubectl drain, users should use --delete-emptydir-data, instead. ([#125842](https://github.com/kubernetes/kubernetes/pull/125842), [@soltysh](https://github.com/soltysh)) [SIG CLI]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 19:49:57 UTC 2025
    - 429.6K bytes
    - Viewed (0)
  9. tensorflow/BUILD

    # TODO(b/173549186): Move Google-internal TF code out of learning/brain
    package_group(
        name = "internal",
        packages = [
            "//devtools/python/indexer/...",
            "//learning/brain/keras/...",
            "//learning/brain/mlir/...",
            "//learning/brain/tfrt/...",
            "//learning/lib/ami/simple_ml/...",
            "//learning/pathways/...",
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Aug 28 19:11:51 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  10. docs/de/docs/how-to/custom-docs-ui-assets.md

    Das kann nützlich sein, wenn Sie beispielsweise in einem Land leben, in dem bestimmte URLs eingeschränkt sind.
    
    ### Die automatischen Dokumentationen deaktivieren
    
    Der erste Schritt besteht darin, die automatischen Dokumentationen zu deaktivieren, da diese standardmäßig das Standard-CDN verwenden.
    
    Um diese zu deaktivieren, setzen Sie deren URLs beim Erstellen Ihrer `FastAPI`-App auf `None`:
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Apr 28 18:31:44 UTC 2025
    - 8.9K bytes
    - Viewed (0)
Back to top