- Sort Score
- Num 10 results
- Language All
Results 421 - 430 of 453 for blocks (0.07 seconds)
-
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* the queue exceeds that value, the queue automatically removes its greatest element according to * its comparator (which might be the element that was just added). This is different from * conventional bounded queues, which either block or reject new elements when full. * * <p>This implementation is based on the <a * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 33.9K bytes - Click Count (0) -
api/go1.11.txt
pkg crypto/cipher, func NewGCMWithTagSize(Block, int) (AEAD, error) pkg crypto/rsa, method (*PrivateKey) Size() int pkg crypto/rsa, method (*PublicKey) Size() int pkg crypto/tls, method (*ConnectionState) ExportKeyingMaterial(string, []uint8, int) ([]uint8, error) pkg database/sql, method (IsolationLevel) String() string pkg database/sql, type DBStats struct, Idle int pkg database/sql, type DBStats struct, InUse int
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Aug 22 03:48:56 GMT 2018 - 25K bytes - Click Count (0) -
docs/en/docs/async.md
When you declare a *path operation function* with normal `def` instead of `async def`, it is run in an external threadpool that is then awaited, instead of being called directly (as it would block the server).
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:56:21 GMT 2025 - 24K bytes - Click Count (0) -
internal/s3select/csv/reader_contrib_test.go
}, } for i, c := range cases { t.Run(c.file, func(t *testing.T) { var err error var record sql.Record var result bytes.Buffer input := openTestFile(t, c.file) // Get above block size. input = append(input, input...) args := ReaderArgs{ FileHeaderInfo: use, RecordDelimiter: c.recordDelimiter, FieldDelimiter: c.fieldDelimiter,Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 38.4K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
this.clientAuth = CLIENT_AUTH_REQUIRED } /** * Awaits the next HTTP request, removes it, and returns it. Callers should use this to verify the * request was sent as intended. This method will block until the request is available, possibly * forever. * * @return the head of the request queue */ @Throws(InterruptedException::class) public fun takeRequest(): RecordedRequest = requestQueue.take()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 02 20:36:00 GMT 2025 - 40.3K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteSource.java
* that provide streams that are: * * <ul> * <li><b>Finite:</b> Many operations, such as {@link #size()} and {@link #read()}, will either * block indefinitely or fail if the source creates an infinite stream. * <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.7K bytes - Click Count (0) -
cmd/bucket-handlers_test.go
// if object upload fails stop the test. if err != nil { t.Fatalf("Put Object %s: Error uploading object: <ERROR> %v", name, err) } } // The following block will create a bucket policy with delete object to 'public/*'. This is // to test a mixed response of a successful & failure while deleting objects in a single requestCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 39.8K bytes - Click Count (0) -
guava/src/com/google/common/cache/LocalCache.java
} } /** A reference to a value. */ interface ValueReference<K, V> { /** Returns the value. Does not block or throw exceptions. */ @Nullable V get(); /** * Waits for a value that may still be loading. Unlike get(), this method can block (in the case * of FutureValueReference). * * @throws ExecutionException if the loading thread throws an exception
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 19:35:11 GMT 2025 - 148.9K bytes - Click Count (0) -
cmd/data-usage-cache.go
case InsufficientReadQuorum, StorageErr: return true, nil } return false, err } err = d.deserialize(r) r.Close() return err != nil, nil } // Caches are read+written without locks, retries := 0 for retries < 5 { retry, err := load(name, time.Minute) if err != nil { return toObjectErr(err, dataUsageBucket, name) } if !retry { break }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
* * ``` * http://google.com/foo * GET * 2 * Accept-Language: fr-CA * Accept-Charset: UTF-8 * HTTP/1.1 200 OK * 3 * Content-Type: image/png * Content-Length: 100 * Cache-Control: max-age=600 * ``` * * A typical HTTPS file looks like this: * * ```Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Oct 03 17:41:45 GMT 2025 - 26.8K bytes - Click Count (0)