- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for drain (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)