- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for goroutineID (0.69 sec)
-
pilot/pkg/xds/delta.go
// when the connection is no longer used. Closing the channel can cause subtle race conditions // with push. According to the spec: "It's only necessary to close a channel when it is important // to tell the receiving goroutines that all data have been sent." // Block until either a request is received or a push is triggered. // We need 2 go routines because 'read' blocks in Recv(). go s.receiveDelta(con, ids)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
// housekeeping routine. This test registers the pod, removes the unwanted pod, then calls into // HandlePodCleanups a few more times. We should only see one Destroy() event. podKiller runs // within a goroutine so a two second delay should be enough time to // mark the pod as killed (within this test case). kubelet.HandlePodCleanups(ctx) // assert that unwanted pods were killed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// notified of config changes, updates, periodic reconciliation, container runtime updates, and // evictions of all desired pods and will invoke reconciliation methods per pod in separate // goroutines. The podWorkers are authoritative in the kubelet for what pods are actually being // run and their current state: // // * syncing: pod should be running (syncPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)