- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 994 for cancels (0.12 sec)
-
pkg/apis/batch/types.go
// 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 ConcurrencyPolicy ConcurrencyPolicy // 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 - 33K bytes - Viewed (0) -
src/internal/poll/fd_windows.go
if len(oob) != 0 { o.msg.Control.Buf = &oob[0] } } // execIO executes a single IO operation o. It submits and cancels // IO in the current thread for systems where Windows CancelIoEx API // is available. Alternatively, it passes the request onto // runtime netpoll and waits for completion or cancels request. func execIO(o *operation, submit func(o *operation) error) (int, error) { if o.fd.pd.runtimeCtx == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0) -
src/os/timeout_test.go
} if err := f.SetWriteDeadline(deadline); err != os.ErrNoDeadline { t.Errorf("SetWriteDeadline on file returned %v, wanted %v", err, os.ErrNoDeadline) } } // noDeadline is a zero time.Time value, which cancels a deadline. var noDeadline time.Time var readTimeoutTests = []struct { timeout time.Duration xerrs [2]error // expected errors in transition }{ // Tests that read deadlines work, even if there's data ready
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 17.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
inFinished: Boolean, ) { pushQueue.execute("$connectionName[$streamId] onHeaders") { val cancel = pushObserver.onHeaders(streamId, requestHeaders, inFinished) ignoreIoExceptions { if (cancel) writer.rstStream(streamId, ErrorCode.CANCEL) if (cancel || inFinished) { this.withLock { currentPushRequests.remove(streamId) } } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// 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 ConcurrencyPolicy ConcurrencyPolicy `json:"concurrencyPolicy,omitempty" protobuf:"bytes,3,opt,name=concurrencyPolicy,casttype=ConcurrencyPolicy"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
ctx, cancel := context.WithCancel(context.Background()) cancel() return ctx, cancel } func deadlinedContext() (context.Context, context.CancelFunc) { ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond) for ctx.Err() != context.DeadlineExceeded { time.Sleep(501 * time.Microsecond) } return ctx, cancel }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
common-protos/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: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 21.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/passes.h
llvm::cl::desc("Skip folding transpose operands in Ops which can support " "different layouts.")}; }; // Layout optimization assigns optimal data layout for layout sensitive // operations, and cancels all redundant transposes. void CreateLayoutOptimizationPipeline( OpPassManager& pm, // NOLINT - MLIR contract is pass by mutable reference. const LayoutOptimizationPipelineOptions& options);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 31.8K bytes - Viewed (0) -
src/image/jpeg/reader.go
// and it simplifies the applyBlack code below if we can assume that: // - for CMYK, the C and K channels have full samples, and if the M // and Y channels subsample, they subsample both horizontally and // vertically. // - for YCbCrK, the Y and K channels have full samples. switch i { case 0: if hv != 0x11 && hv != 0x22 { return errUnsupportedSubsamplingRatio }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 22.5K bytes - Viewed (0) -
src/net/http/client.go
} initialReqCancel := req.Cancel // the user's original Request.Cancel, if any var cancelCtx func() if timeBeforeContextDeadline(deadline, oldCtx) { req.ctx, cancelCtx = context.WithDeadline(oldCtx, deadline) } cancel := make(chan struct{}) req.Cancel = cancel doCancel := func() { // The second way in the func comment above: close(cancel) // The first way, used only for RoundTripper
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0)