- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for drawn (0.17 sec)
-
android/guava/src/com/google/common/math/DoubleMath.java
} } /** * Returns the <a href="http://en.wikipedia.org/wiki/Arithmetic_mean">arithmetic mean</a> of * {@code values}. * * <p>If these values are a sample drawn from a population, this is also an unbiased estimator of * the arithmetic mean of the population. * * @param values a nonempty series of values
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 07 17:50:39 GMT 2024 - 18.9K bytes - Viewed (0) -
android/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> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 22K bytes - Viewed (0) -
internal/logger/target/http/http.go
select { case currentGlobalBuffer <- v: default: } } if mainWorker { drain: for { select { case v, ok := <-h.logCh: if !ok { break drain } currentGlobalBuffer <- v default: break drain } } } }() var entry interface{} var ok bool var err error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/http/close.go
package http import ( "io" xioutil "github.com/minio/minio/internal/ioutil" ) // DrainBody close non nil response with any response Body. // convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K bytes - Viewed (0) -
manifests/charts/ztunnel/values.yaml
defaultConfig: proxyMetadata: {} # This value defines: # 1. how many seconds kube waits for ztunnel pod to gracefully exit before forcibly terminating it (this value) # 2. how many seconds ztunnel waits to drain its own connections (this value - 1 sec) # Default K8S value is 30 seconds terminationGracePeriodSeconds: 30 # Revision is set as 'version' label and part of the resource names when installing multiple control planes.
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
assertTrue(segment.recencyQueue.isEmpty()); for (int i = 0; i < DRAIN_THRESHOLD / 2; i++) { map.get(keyOne); } assertFalse(segment.recencyQueue.isEmpty()); for (int i = 0; i < DRAIN_THRESHOLD * 2; i++) { map.get(keyOne); assertTrue(segment.recencyQueue.size() <= DRAIN_THRESHOLD); } // get over many different keys
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
assertTrue(segment.recencyQueue.isEmpty()); for (int i = 0; i < DRAIN_THRESHOLD / 2; i++) { map.get(keyOne); } assertFalse(segment.recencyQueue.isEmpty()); for (int i = 0; i < DRAIN_THRESHOLD * 2; i++) { map.get(keyOne); assertTrue(segment.recencyQueue.size() <= DRAIN_THRESHOLD); } // get over many different keys
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
*/ @CanIgnoreReturnValue @J2ktIncompatible @GwtIncompatible // BlockingQueue @SuppressWarnings("GoodTime") // should accept a java.time.Duration public static <E> int drain( BlockingQueue<E> q, Collection<? super E> buffer, int numElements, long timeout, TimeUnit unit) throws InterruptedException { Preconditions.checkNotNull(buffer);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0) -
internal/grid/stream.go
func (s *Stream) Results(next func(b []byte) error) (err error) { done := false defer func() { if s.cancel != nil { s.cancel(err) } if !done { // Drain channel. for range s.responses { } } }() doneCh := s.ctx.Done() for { select { case <-doneCh: if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) { return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/bitrot-streaming.go
h hash.Hash shardSize int64 hashBytes []byte } func (b *streamingBitrotReader) Close() error { if b.rc == nil { return nil } if closer, ok := b.rc.(io.Closer); ok { // drain the body for connection reuse at network layer. xhttp.DrainBody(struct { io.Reader io.Closer }{ Reader: b.rc, Closer: closeWrapper(func() error { return nil }), }) return closer.Close()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0)