Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for goroutineID (0.69 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top