Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for pausedWorkers (0.39 sec)

  1. pkg/kubelet/pod_workers_test.go

    	}
    	<-ch
    }
    
    func (w *timeIncrementingWorkers) drainUnpausedWorkers() {
    	pausedWorkers := make(map[types.UID]struct{})
    	for {
    		for uid := range pausedWorkers {
    			delete(pausedWorkers, uid)
    		}
    		stillWorking := false
    
    		// ignore held workers
    		w.lock.Lock()
    		for uid := range w.holds {
    			pausedWorkers[uid] = struct{}{}
    		}
    		w.lock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
Back to top