- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 364 for cancel0 (0.12 sec)
-
security/pkg/pki/ca/ca_test.go
const rootCertFile = "" rootCertCheckInverval := time.Hour rsaKeySize := 2048 client := fake.NewSimpleClientset() // succeed creating a self-signed cert ctx0, cancel0 := context.WithTimeout(context.Background(), time.Millisecond*50) defer cancel0() _, err := NewSelfSignedIstioCAOptions(ctx0, 0, caCertTTL, defaultCertTTL, rootCertCheckInverval, maxCertTTL, org, false, false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 08:51:27 UTC 2023 - 29.1K bytes - Viewed (0) -
src/context/x_test.go
checkValues("after timeout") } else { cancel := cancels[r.Intn(len(cancels))] cancel() select { case <-ctx.Done(): default: errorf("ctx should be canceled") } checkValues("after cancel") } } func TestWithCancelCanceledParent(t *testing.T) { parent, pcancel := WithCancelCause(Background()) cause := fmt.Errorf("Because!") pcancel(cause) c, _ := WithCancel(parent)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K 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) -
internal/grid/muxclient.go
return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests) return &Stream{responses: responseCh, Requests: requests, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
CountdownTimer timer = Time.startCountdownTimer(cancelTimeoutMs); LOGGER.debug("Cancel requested: will wait for daemon to become idle."); try { cancellationToken.cancel(); } catch (Exception ex) { LOGGER.error("Cancel processing failed. Will continue.", ex); } lock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K 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) -
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) -
pkg/kubelet/cm/dra/plugin/noderesources.go
c.mutex.Lock() defer c.mutex.Unlock() if active := c.activePlugins[driverName]; active != nil { active.cancel(errors.New("plugin has re-registered")) } active := &activePlugin{} cancelCtx, cancel := context.WithCancelCause(c.ctx) active.cancel = cancel c.activePlugins[driverName] = active c.queue.Add(driverName) c.wg.Add(1) go func() { defer c.wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
*/ override fun cancel() { if (canceled) return // Already canceled. canceled = true exchange?.cancel() for (plan in plansToCancel) { plan.cancel() } eventListener.canceled(this) } override fun isCanceled(): Boolean = canceled override fun execute(): Response {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0)