Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for drain (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. docs/az/docs/index.md

    * Redaktor dəstəyi ilə:
        * Avtomatik tamamlama.
        * Tip yoxlanması.
    * Məlumatların Təsdiqlənməsi:
        * Məlumat etibarsız olduqda avtomatik olaraq aydın xətalar göstərir.
        * Hətta çox dərin JSON obyektlərində belə doğrulama aparır.
    * Daxil olan məlumatları <abbr title="Çevrilmə: serialization, parsing, marshalling olaraq da bilinir">çevirmək</abbr> üçün aşağıdakı məlumat növlərindən istifadə edilir:
        * JSON.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 22.7K bytes
    - Viewed (0)
  9. docs/de/docs/tutorial/security/index.md

    
    /// tip | Tipp
    
    Auch die Integration anderer Authentifizierungs-/Autorisierungsanbieter wie Google, Facebook, X (Twitter), GitHub, usw. ist möglich und relativ einfach.
    
    Das komplexeste Problem besteht darin, einen Authentifizierungs-/Autorisierungsanbieter wie solche aufzubauen, aber **FastAPI** reicht Ihnen die Tools, das einfach zu erledigen, während Ihnen die schwere Arbeit abgenommen wird.
    
    ///
    
    ## **FastAPI** Tools
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/math/Stats.java

        return count;
      }
    
      /**
       * Returns the <a href="http://en.wikipedia.org/wiki/Arithmetic_mean">arithmetic mean</a> of the
       * values. The count must be non-zero.
       *
       * <p>If these values are a sample drawn from a population, this is also an unbiased estimator of
       * the arithmetic mean of the population.
       *
       * <h3>Non-finite values</h3>
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 24.8K bytes
    - Viewed (0)
Back to top