- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 994 for cancels (0.12 sec)
-
staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go
"suspend": "This flag tells the controller to suspend subsequent executions, it does not apply to already started executions. Defaults to false.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 27.5K bytes - Viewed (0) -
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() } } delete(j.jobCancelers, jobID) return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/generated.proto
// Valid values are: // // - "Allow" (default): allows CronJobs to run concurrently; // - "Forbid": forbids concurrent runs, skipping next run if previous run hasn't finished yet; // - "Replace": cancels currently running job and replaces it with a new one // +optional optional string concurrencyPolicy = 3; // This flag tells the controller to suspend subsequent executions, it does
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 29.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitStarted(); // Everything should still be open. 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.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitStarted(); // Everything should still be open. 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.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
src/context/afterfunc_test.go
ctx0 := &afterFuncContext{} ctx1, cancel := context.WithTimeout(ctx0, veryLongDuration) defer cancel() ctx0.cancel(context.Canceled) <-ctx1.Done() } func TestCustomContextAfterFuncAfterFunc(t *testing.T) { ctx0 := &afterFuncContext{} donec := make(chan struct{}) stop := context.AfterFunc(ctx0, func() { close(donec) }) defer stop() ctx0.cancel(context.Canceled) <-donec }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 16:58:52 UTC 2023 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Note: The only way this CAS could fail is if cancel() has raced with us. That is ok. boolean unused = ATOMIC_HELPER.casValue(this, valueToSet, failure); } return true; } localValue = value; // we lost the cas, fall through and maybe cancel } // The future has already been set to something. If it is cancellation we should cancel the // incoming future.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Note: The only way this CAS could fail is if cancel() has raced with us. That is ok. boolean unused = ATOMIC_HELPER.casValue(this, valueToSet, failure); } return true; } localValue = value; // we lost the cas, fall through and maybe cancel } // The future has already been set to something. If it is cancellation we should cancel the // incoming future.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
src/context/example_test.go
defer cancel1(errors.New("ctx1 canceled")) ctx2, cancel2 := context.WithCancelCause(context.Background()) mergedCtx, mergedCancel := mergeCancel(ctx1, ctx2) defer mergedCancel() cancel2(errors.New("ctx2 canceled")) <-mergedCtx.Done() fmt.Println(context.Cause(mergedCtx)) // Output: // ctx2 canceled
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 21 20:24:28 UTC 2023 - 6.7K bytes - Viewed (0)