Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 341 - 350 of 432 for canceler (1.08 seconds)

  1. src/main/webapp/js/admin/plugins/daterangepicker/daterangepicker.js

            this.locale = {
                direction: 'ltr',
                format: moment.localeData().longDateFormat('L'),
                separator: ' - ',
                applyLabel: 'Apply',
                cancelLabel: 'Cancel',
                weekLabel: 'W',
                customRangeLabel: 'Custom Range',
                daysOfWeek: moment.weekdaysMin(),
                monthNames: moment.monthsShort(),
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 64.8K bytes
    - Click Count (0)
  2. cmd/data-usage-cache.go

    		// Abandon if more than time.Minute, so we don't hold up scanner.
    		// drive timeout by default is 2 minutes, we do not need to wait longer.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    		if err != nil {
    			switch err.(type) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        }
      }
    
      private static final class RuntimeExceptionThrowingFuture<V> implements Future<V> {
        final CountDownLatch allowGetToComplete = new CountDownLatch(1);
    
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          throw new AssertionFailedError();
        }
    
        @Override
        public V get() throws InterruptedException {
          /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Play it back.
        connect(peer, PushObserver.CANCEL, Http2Connection.Listener.REFUSE_INCOMING_STREAMS)
    
        // Verify the peer received what was expected.
        val rstStream = peer.takeFrame()
        assertThat(rstStream.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(rstStream.streamId).isEqualTo(2)
        assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL)
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  5. internal/grid/msg.go

    	OpMuxConnectError
    
    	// OpDisconnectClientMux instructs a client to disconnect a mux
    	OpDisconnectClientMux
    
    	// OpDisconnectServerMux instructs a server to disconnect (cancel) a server mux
    	OpDisconnectServerMux
    
    	// OpMuxClientMsg contains a message to a client Mux
    	OpMuxClientMsg
    
    	// OpMuxServerMsg contains a message to a server Mux
    	OpMuxServerMsg
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jul 25 21:07:21 GMT 2024
    - 7.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java

        return output;
      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @LazyInit @Nullable ListenableFuture<? extends V> inputFuture;
      @LazyInit @Nullable Class<X> exceptionType;
      @LazyInit @Nullable F fallback;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Sep 11 18:28:58 GMT 2025
    - 9K bytes
    - Click Count (0)
  7. cmd/handler-utils.go

    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    			if err != nil && !errors.Is(err, context.Canceled) {
    				proxyLogIf(GlobalContext, err)
    			}
    			if returnErr {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			}
    		},
    	})
    
    	r.URL.Scheme = "http"
    	if globalIsTLS {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  8. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 16 07:34:24 GMT 2025
    - 93K bytes
    - Click Count (3)
  9. docs/sts/tls.md

    *Applications that use direct S3 API will work fine, however interactive users uploading content using (when POSTing to the presigned URL an app generates) a popup becomes visible on browser to provide client certs, you would have to manually cancel and continue. This may be annoying to use but there is no workaround for now.*
    
    ## Explore Further
    
    - [MinIO Admin Complete Guide](https://docs.min.io/community/minio-object-store/reference/minio-mc-admin.html)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 6K bytes
    - Click Count (1)
  10. okhttp/api/jvm/okhttp.api

    	public fun cacheMiss (Lokhttp3/Call;)V
    	public fun callEnd (Lokhttp3/Call;)V
    	public fun callFailed (Lokhttp3/Call;Ljava/io/IOException;)V
    	public fun callStart (Lokhttp3/Call;)V
    	public fun canceled (Lokhttp3/Call;)V
    	public fun connectEnd (Lokhttp3/Call;Ljava/net/InetSocketAddress;Ljava/net/Proxy;Lokhttp3/Protocol;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (0)
Back to Top