Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for processShutdownEvent (0.36 sec)

  1. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    				nodeShuttingDownNow:              tt.fields.nodeShuttingDownNow,
    				clock:                            tt.fields.clock,
    			}
    			if err := m.processShutdownEvent(); (err != nil) != tt.wantErr {
    				t.Errorf("managerImpl.processShutdownEvent() error = %v, wantErr %v", err, tt.wantErr)
    			}
    
    			underlier, ok := logger.GetSink().(ktesting.Underlier)
    			if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  2. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go

    				m.nodeShuttingDownNow = isShuttingDown
    				m.nodeShuttingDownMutex.Unlock()
    
    				if isShuttingDown {
    					// Update node status and ready condition
    					go m.syncNodeStatus()
    
    					m.processShutdownEvent()
    				} else {
    					m.aquireInhibitLock()
    				}
    			}
    		}
    	}()
    	return stop, nil
    }
    
    func (m *managerImpl) aquireInhibitLock() error {
    	lock, err := m.dbusCon.InhibitShutdown()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 08:02:40 UTC 2022
    - 15.5K bytes
    - Viewed (0)
Back to top