- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for canceler (0.04 sec)
-
cmd/batch-handlers.go
} return nil } // delete canceler from the map, cancel job if requested func (j *BatchJobPool) canceler(jobID string, cancel bool) error { if j == nil { return errInvalidArgument } j.jmu.Lock() defer j.jmu.Unlock() if canceler, ok := j.jobCancelers[jobID]; ok { if cancel { canceler() } } if cancel { delete(j.jobCancelers, jobID) } return nil
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Updates must be closed before we return. defer xioutil.SafeClose(updates) ctx, cancel := context.WithCancel(ctx) defer cancel() var wg sync.WaitGroup var mu sync.Mutex var results []dataUsageCache var firstErr error allBuckets, err := z.ListBuckets(ctx, BucketOptions{}) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* input future and that of the future returned by the chain function. That is, if the returned * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the * other two is cancelled, the returned {@code Future} will receive a callback in which it will * attempt to cancel itself. * * @param input The future to transform
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4. assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue(); step2Waiter.awaitReturned(); step4Waiter.awaitStarted(); // Step 1 is not cancelled because it was done. assertWithMessage("step1.statusFuture().isCancelled()")
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 75.4K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
canceling calls would cause the shared HTTP/2 connection to be unnecessarily released. This harmed connection reuse. * Fix: Ensure canceled and discarded HTTP/2 data is not permanently counted against the limited flow control window. We had a few bugs where window size accounting was broken when streams were canceled or reset.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
.Builder() .url(server.url("/")) .build(), ) call.cancel() assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("Canceled") } assertThat(listener.recordedEventTypes()).containsExactly( "Canceled", "CallStart", "CallFailed", ) } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
override fun dispatch(request: RecordedRequest): MockResponse { // This guarantees a deterministic sequence when handling the canceled request: // 1. Server reads request and dequeues first response // 2. Client cancels request // 3. Server tries to send response on the canceled stream // Otherwise, there is no guarantee for the sequence. For example, the server may use the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0) -
cmd/test-utils_test.go
setObjectLayer(newObjectLayerFn()) cancel() removeRoots(fsDirs) } } // ExecObjectLayerTestWithDirs - executes object layer tests. // Creates single node and Erasure ObjectLayer instance and runs test for both the layers. func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() if localMetacacheMgr != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* * If the server does not respond to each ping with a pong within `interval`, this client will * assume that connectivity has been lost. When this happens on a web socket the connection is * canceled and its listener is [notified][WebSocketListener.onFailure]. When it happens on an * HTTP/2 connection the connection is closed and any calls it is carrying * [will fail with an IOException][java.io.IOException].
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
cmd/api-errors.go
return ErrRequestTimedout } // Only return ErrClientDisconnected if the provided context is actually canceled. // This way downstream context.Canceled will still report ErrRequestTimedout if contextCanceled(ctx) && errors.Is(ctx.Err(), context.Canceled) { return ErrClientDisconnected } // Unwrap the error first err = unwrapAll(err) switch err {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 16 07:34:24 UTC 2025 - 93K bytes - Viewed (1)