Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 376 for cancelFn (0.04 sec)

  1. docs/distributed/DECOMMISSION.md

    ```
    
    ## Canceling a decommission
    
    Stop an on-going decommission in progress, mainly used in situations when the load may be too high and you may want to schedule the decommission at a later point in time.
    
    `mc admin decommission cancel` without an argument, lists out any on-going decommission in progress.
    
    ```
    λ mc admin decommission cancel alias/
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

            else -> JavaNetSocket(route.proxy)
          }
        this.rawSocket = rawSocket
    
        // Handle the race where cancel() precedes connectSocket(). We don't want to miss a cancel.
        if (canceled) {
          throw IOException("canceled")
        }
    
        rawSocket.soTimeout = socketReadTimeoutMillis
        try {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 19.3K bytes
    - Viewed (2)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>This differs from {@link #successfulAsList(ListenableFuture[])} in that it will return a
       * failed future if any of the items fails.
       *
       * <p>Canceling this future will attempt to cancel all the component futures, and if any of the
       * provided futures fails or is canceled, this one is, too.
       *
       * @param futures futures to combine
       * @return a future that provides a list of the results of the component futures
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  4. internal/dsync/dsync_test.go

    	ctx, cancel := context.WithCancel(t.Context())
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Make it run twice.
    	timer := time.NewTimer(testDrwMutexRefreshInterval * 2)
    
    	select {
    	case <-ctx.Done():
    		t.Fatal("Lock context canceled which is not expected")
    	case <-timer.C:
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  5. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

            }
          } catch (e: Exception) {
            val exception =
              when {
                canceled -> IOException("canceled", e)
                else -> e
              }
            listener.onFailure(this, exception, response)
            return
          }
          if (canceled) {
            listener.onFailure(this, IOException("canceled"), response)
          } else {
            listener.onClosed(this)
          }
        }
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 07:51:20 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        taskFaker.advanceUntil(500.ms)
        assertEvents(
          "take plan 2",
          "plan 0 cancel",
          "plan 1 cancel",
        )
    
        taskFaker.advanceUntil(510.ms)
        assertEvents(
          "plan 1 TCP connect canceled",
        )
    
        taskFaker.advanceUntil(520.ms)
        assertEvents(
          "plan 0 TCP connect canceled",
        )
      }
    
      @Test
      fun takeMultipleConnections() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

       * exception.
       *
       * @throws IllegalStateException when the call has already been executed.
       */
      fun enqueue(responseCallback: Callback)
    
      /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */
      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  9. internal/grid/grid_test.go

    				time.Sleep(10 * time.Millisecond)
    			default:
    				sendReq = false
    			}
    		}
    		cancel()
    		<-serverCanceled
    		t.Log("server cancel time:", time.Since(start))
    		clientEnd := <-clientCanceled
    		if !errors.Is(err, context.Canceled) {
    			t.Error("expected context.Canceled, got", err)
    		}
    		t.Log("client after", time.Since(clientEnd))
    	}
    	// local to remote, unbuffered
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

              ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = tcpConnectThrowable)
            }
            canceled -> {
              events += "plan $id TCP connect canceled"
              ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled"))
            }
            connectTcpNextPlan != null -> {
              events += "plan $id needs follow-up"
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 6.1K bytes
    - Viewed (0)
Back to top