- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 724 for buffered (0.17 sec)
-
internal/grid/benchmark_test.go
select { case <-ctx.Done(): return nil case out <- toSend: } } return nil }, Subroute: "some-subroute", OutCapacity: 1, // Only one message buffered. InCapacity: 0, })) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
* * @throws IOException if an I/O error occurs while opening the writer */ public abstract Writer openStream() throws IOException; /** * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 6.1K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix: Support the `PATCH` method. * Fix: Support request bodies on `DELETE` method. * Fix: Drop the `okhttp-protocols` module. * Internal: Replaced internal byte array buffers with pooled buffers ("OkBuffer"). ## Version 1.3.0 _2014-01-11_ * New: Support for "PATCH" HTTP method in client and MockWebServer. * Fix: Drop `Content-Length` header when redirected from POST to GET.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSink.java
* * @throws IOException if an I/O error occurs while opening the stream */ public abstract OutputStream openStream() throws IOException; /** * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 5.5K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/FileBackedOutputStream.java
} } /** * Calls {@link #close} if not already closed, and then resets this object back to its initial * state, for reuse. If data was buffered to a file, it will be deleted. * * @throws IOException if an I/O error occurred while deleting the file buffer */ public synchronized void reset() throws IOException { try { close(); } finally { if (memory == null) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 8.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem_test.cc
ASSERT_EQ(TF_GetCode(status_), TF_OUT_OF_RANGE) << TF_Message(status_); result.resize(read); ASSERT_EQ(result, "6789") << "Result: " << result << "\n"; } TEST_F(GCSFilesystemTest, NewRandomAccessFile_Buffered) { tf_gcs_filesystem::InitTest(filesystem_, false, 10, 0, 0, 0, 0, status_); ASSERT_TF_OK(status_) << "Could not initialize filesystem. " << TF_Message(status_);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 12:04:23 GMT 2020 - 24.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
/** * Report and attempt to recover from a failure to communicate with a server. Returns true if * `e` is recoverable, or false if the failure is permanent. Requests with a body can only * be recovered if the body is buffered or if the failure occurred before the request has been * sent. */ private fun recover( e: IOException, call: RealCall, userRequest: Request, requestSendStarted: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
internal/dsync/drwmutex.go
// does not exist in enough quorum nodes. func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) { restClnts, _ := ds.GetLockers() // Create buffered channel of size equal to total number of nodes. ch := make(chan refreshResult, len(restClnts)) var wg sync.WaitGroup args := LockArgs{ UID: id, } for index, c := range restClnts {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/tier-journal.go
j := &TierJournal{ tierMemJournal: newTierMemJournal(1000), tierDiskJournal: newTierDiskJournal(), } return j } // Init initializes an in-memory journal built using a // buffered channel for new journal entries. It also initializes the on-disk // journal only to process existing journal entries made from previous versions. func (t *TierJournal) Init(ctx context.Context) error {
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0)