- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 994 for cancels (0.14 sec)
-
staging/src/k8s.io/api/batch/v1beta1/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: Tue Mar 07 11:58:57 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers.go
timer := clock.AfterFunc(delay, fWithErrorLogging) return &TimedWorker{ WorkItem: args, CreatedAt: createdAt, FireAt: fireAt, Timer: timer, } } // Cancel cancels the execution of function by the `TimedWorker` func (w *TimedWorker) Cancel() { if w != nil { w.Timer.Stop() } } // TimedWorkerQueue keeps a set of TimedWorkers that are still wait for execution. type TimedWorkerQueue struct { sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
src/context/context.go
// Calling cancel with nil sets the cause to Canceled. // // Example use: // // ctx, cancel := context.WithCancelCause(parent) // cancel(myError) // ctx.Err() // returns context.Canceled // context.Cause(ctx) // returns myError func WithCancelCause(parent Context) (ctx Context, cancel CancelCauseFunc) { c := withCancel(parent) return c, func(cause error) { c.cancel(true, Canceled, cause) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
src/os/signal/signal_plan9_test.go
// into subsequent TestSignal() causing failure. // Sleep for a while to reduce the possibility of the failure. time.Sleep(10 * time.Millisecond) } // Test that Stop cancels the channel's registrations. func TestStop(t *testing.T) { if testing.Short() { t.Skip("skipping in short mode") } sigs := []string{ "alarm", "hangup", } for _, sig := range sigs {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Mar 14 17:56:50 UTC 2021 - 3.6K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/resolver/KotlinBuildScriptModelRepositoryTest.kt
*/ package org.gradle.kotlin.dsl.resolver import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.Deferred import kotlinx.coroutines.async import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.channels.trySendBlocking import kotlinx.coroutines.runBlocking import kotlinx.coroutines.withTimeout import kotlinx.coroutines.withTimeoutOrNull import org.gradle.kotlin.dsl.tooling.models.EditorReport
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 6.3K bytes - Viewed (0) -
pilot/pkg/model/controller.go
// // The controller guarantees the following consistency requirement: registry // view in the controller is as AT LEAST as fresh as the moment notification // arrives, but MAY BE more fresh (e.g. "delete" cancels an "add" event). For // example, an event for a service creation will see a service registry without // the service if the event is immediately followed by the service deletion // event. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 25 06:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
cmd/consolelogger.go
if ok { if (lg.Entry != log.Entry{}) { logs = append(logs, lg.Entry) } } } }) sys.RUnlock() return } // Cancel - cancels the target func (sys *HTTPConsoleLoggerSys) Cancel() { } // Type - returns type of the target func (sys *HTTPConsoleLoggerSys) Type() types.TargetType { return types.TargetConsole }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
else -> Socket(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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
internal/cachevalue/cache.go
t.Once.Do(func() { t.ttl = ttl t.updateFn = update t.opts = opts }) } // GetWithCtx will return a cached value or fetch a new one. // passes a caller context, if caller context cancels nothing // is cached. // If the Update function returns an error the value is forwarded as is and not cached. func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) { v := t.val.Load() ttl := t.ttl
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DistributionInstaller.java
return install.createDist(wrapperConfiguration); } /** * Cancels the current installation, if running. */ public void cancel() { synchronized (lock) { cancelled = true; lock.notifyAll(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 9.8K bytes - Viewed (0)