Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for shutdownChan (0.12 sec)

  1. pkg/kubelet/nodeshutdown/systemd/inhibit_linux.go

    	if err != nil {
    		return nil, err
    	}
    
    	busChan := make(chan *dbus.Signal, 1)
    	bus.SystemBus.Signal(busChan)
    
    	shutdownChan := make(chan bool, 1)
    
    	go func() {
    		for {
    			event, ok := <-busChan
    			if !ok {
    				close(shutdownChan)
    				return
    			}
    			if event == nil || len(event.Body) == 0 {
    				klog.ErrorS(nil, "Failed obtaining shutdown event, PrepareForShutdown event was empty")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  2. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    		return nil
    	}
    	syncNodeStatus := func() {}
    
    	var shutdownChan chan bool
    	var shutdownChanMut sync.Mutex
    	var connChan = make(chan struct{}, 1)
    
    	lock.Lock()
    	systemDbus = func() (dbusInhibiter, error) {
    		defer func() {
    			connChan <- struct{}{}
    		}()
    		ch := make(chan bool)
    		shutdownChanMut.Lock()
    		shutdownChan = ch
    		shutdownChanMut.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
Back to top