Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 170 for Canceled (0.05 sec)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top