- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 170 for Canceled (0.05 sec)
-
.github/workflows/mint.yml
name: Mint Tests on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: mint-test: runs-on: mint timeout-minutes: 120 steps:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2.9K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
} // fanOutPutObject takes an input source reader and fans out multiple PUT operations // based on the incoming fan-out request, a context cancellation by the caller // would ensure all fan-out operations are canceled. func fanOutPutObject(ctx context.Context, bucket string, objectAPI ObjectLayer, fanOutEntries []minio.PutObjectFanOutEntry, fanOutBuf []byte, opts fanOutOptions) ([]ObjectInfo, []error) { errs := make([]error, len(fanOutEntries))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.5K bytes - Viewed (0) -
cmd/callhome.go
// because of this loop. for { if !globalCallhomeConfig.Enabled() { return } if !runCallhome(ctx, objAPI) { // callhome was disabled or context was canceled return } // callhome running on a different node. // sleep for some time and try again. duration := max(time.Duration(r.Float64()*float64(globalCallhomeConfig.FrequencyDur())),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
cmd/metacache-walk.go
) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any. // The function tries to quit as fast as the context is canceled to avoid further drive IO func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { legacyFS := s.fsType != xfs && s.fsType != ext4 s.RLock() legacy := s.formatLegacy
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.6K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
requests couldn't be canceled by tag. This update avoids crashing when `onResponse()` throws an `IOException`. That failure will now be logged instead of notifying the thread's uncaught exception handler. We've added a new API, `Call.isCanceled()` to check if a call has been canceled. * New: Update `MultipartBuilder` to support content length.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
fail("Should have timed out trying to get the value."); } catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K 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
) call.cancel() assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("Canceled") } assertThat(listener.recordedEventTypes()).containsExactly( "Canceled", "CallStart", "CallFailed", ) } @Test fun cancelAsyncCall() { server.enqueue( MockResponse .Builder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* either from cancellation or because an input future has completed. If N futures are passed in, * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of * the input futures complete. If all the delegates are cancelled, all the input futures will be * too. * * @since 17.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
cmd/object-api-errors.go
// underlying storage layer. func toObjectErr(oerr error, params ...string) error { if oerr == nil { return nil } // Unwarp the error first err := unwrapAll(oerr) if err == context.Canceled { return context.Canceled } switch err.Error() { case errVolumeNotFound.Error(): apiErr := BucketNotFound{} if len(params) >= 1 { apiErr.Bucket = params[0] } return apiErr
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 09 02:05:14 UTC 2024 - 22.1K bytes - Viewed (0)