- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for shutdownChan (0.12 sec)
-
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) -
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)