- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 75 for canceling (0.22 sec)
-
pkg/controller/tainteviction/timed_workers.go
func (q *TimedWorkerQueue) CancelWork(logger klog.Logger, key string) bool { q.Lock() defer q.Unlock() worker, found := q.workers[key] result := false if found { logger.V(4).Info("Cancelling TimedWorkerQueue item", "item", key, "time", time.Now()) if worker != nil { result = true worker.Cancel() } delete(q.workers, key) } return result }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
location.Scheme = "https" location.Host = host location.Path = req.URL.Path location.RawQuery = req.URL.Query().Encode() newReq, cancelFn := apiserverproxyutil.NewRequestForProxy(location, req) newReq.Header.Add(PeerProxiedHeader, "true") defer cancelFn() proxyRoundTripper := transport.NewAuthProxyRoundTripper(user.GetName(), user.GetGroups(), user.GetExtra(), h.proxyTransport)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
internal/grid/connection.go
Msg: m.Payload, Err: nil, }) } if m.Flags&FlagEOF != 0 { if v.cancelFn != nil && m.Flags&FlagPayloadIsErr == 0 { // We must obtain the lock before calling cancelFn // Otherwise others may pick up the error before close is called. v.respMu.Lock() v.cancelFn(errStreamEOF) v.closeLocked() v.respMu.Unlock() } else { v.close() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/net/http/serve_test.go
if err != nil { t.Errorf("Proxy copy error: %v", err) return } t.Cleanup(func() { bresp.Body.Close() }) // Try to cause a race. Canceling the client request will cause the client // transport to close req2.Body. Returning from the server handler will // cause the server to close req.Body. Since they are the same underlying
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
t.Errorf("expected context %t, has context %t", e, a) } else { expected.ctx, status.ctx = nil, nil } if e, a := expected.cancelFn != nil, status.cancelFn != nil; e != a { t.Errorf("expected cancelFn %t, has cancelFn %t", e, a) } else { expected.cancelFn, status.cancelFn = nil, nil } } if e, a := expected, status; !reflect.DeepEqual(e, a) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
select { case podUpdates <- struct{}{}: default: } if (becameTerminating || wasGracePeriodShortened) && status.cancelFn != nil { klog.V(3).InfoS("Cancelling current pod sync", "pod", klog.KRef(ns, name), "podUID", uid, "workType", status.WorkType()) status.cancelFn() return } } // calculateEffectiveGracePeriod sets the initial grace period for a newly terminating pod or allows a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFuture.java
int index = i++; future.addListener( () -> { try { if (future.isCancelled()) { // Clear futures prior to cancelling children. This sets our own state but lets // the input futures keep running, as some of them may be used elsewhere. futures = null; cancel(false);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
int index = i++; future.addListener( () -> { try { if (future.isCancelled()) { // Clear futures prior to cancelling children. This sets our own state but lets // the input futures keep running, as some of them may be used elsewhere. futures = null; cancel(false);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (0)