- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for canceling (0.18 sec)
-
internal/dsync/dsync_test.go
select { case <-ctx.Done(): t.Fatal("Lock context canceled which is not expected") case <-timer.C: } // Should be safe operation in all cases dm.Unlock(context.Background()) } // Test canceling context while quorum servers report lock not found func TestFailedRefreshLock(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 11K bytes - Viewed (0) -
src/context/x_test.go
} if got := Cause(ccc); got != Canceled { t.Errorf("after CancelCauseFunc Cause(ccc) = %v, want %v", got, Canceled) } // Test that if we associate a custom context with a child, // then canceling the custom context cancels the child. ccc = &customCauseContext{ done: make(chan struct{}), } ctx, cancelFunc := WithCancel(ccc) ccc.setCancelChild(cancelFunc) ccc.cancel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
if !allTolerated { logger.V(2).Info("Not all taints are tolerated after update for pod on node", "pod", podNamespacedName.String(), "node", klog.KRef("", nodeName)) // We're canceling scheduled work (if any), as we're going to delete the Pod right away. tc.cancelWorkWithEvent(logger, podNamespacedName) tc.taintEvictionQueue.AddWork(ctx, NewWorkArgs(podNamespacedName.Name, podNamespacedName.Namespace), now, now)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// ReleaseOnCancel should be set true if the lock should be released // when the run context is canceled. If you set this to true, you must // ensure all code guarded by this lease has successfully completed // prior to canceling the context, or you may have two processes // simultaneously acting on the critical path. ReleaseOnCancel bool // Name is the name of the resource lock for debugging Name string }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
src/log/slog/handler.go
// Handle handles the Record. // It will only be called when Enabled returns true. // The Context argument is as for Enabled. // It is present solely to provide Handlers access to the context's values. // Canceling the context should not affect record processing. // (Among other things, log messages may be necessary to debug a // cancellation-related problem.) // // Handle methods that produce output should observe the following rules:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 18:18:13 UTC 2023 - 17.5K bytes - Viewed (0) -
CHANGELOG.md
* Fix: Don't crash with a `InaccessibleObjectException` when detecting the platform trust manager on Java 17+. * Fix: Don't crash if a cookie's value is a lone double quote character. * Fix: Don't crash when canceling an event source created by `EventSources.processResponse()`. * New: `Cache` now has a public constructor that takes an [okio.FileSystem]. This should make it possible to implement decorators for cache encryption or compression.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:31:39 UTC 2024 - 21.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* implement shutdown and termination behavior. * * <p>The implementation deviates from the {@code ExecutorService} specification with regards to * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
includes potential security problems (newline characters) as well as simple non-ASCII characters (including international characters and emoji). * **Call canceling is more reliable.** We had a bug where a socket being connected wasn't being closed when the application used `Call.cancel()`. * **Changing a HttpUrl’s scheme now tracks the default port.** We had a bug
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* implement shutdown and termination behavior. * * <p>The implementation deviates from the {@code ExecutorService} specification with regards to * the {@code shutdownNow} method. First, "best-effort" with regards to canceling running tasks is * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
`MockWebServer`. * Fix: Honor the `MockResponse` header delay in MockWebServer. * Fix: Don't release HTTP/2 connections that have multiple canceled calls. We had a bug where canceling calls would cause the shared HTTP/2 connection to be unnecessarily released. This harmed connection reuse. * Fix: Ensure canceled and discarded HTTP/2 data is not permanently counted against the limited
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0)