Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SystemBus (0.21 sec)

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

    }
    
    // DBusCon has functions that can be used to interact with systemd and logind over dbus.
    type DBusCon struct {
    	SystemBus dBusConnector
    }
    
    func NewDBusCon() (*DBusCon, error) {
    	conn, err := dbus.SystemBus()
    	if err != nil {
    		return nil, err
    	}
    
    	return &DBusCon{
    		SystemBus: conn,
    	}, nil
    }
    
    // InhibitLock is a lock obtained after creating an systemd inhibitor by calling InhibitShutdown().
    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/systemd/inhibit_linux_test.go

    	var fakeFd uint32 = 42
    
    	bus := DBusCon{
    		SystemBus: &fakeSystemDBus{
    			fakeDBusObject: &fakeDBusObject{
    				bodyValue: fakeFd,
    			},
    		},
    	}
    
    	fdLock, err := bus.InhibitShutdown()
    	assert.Equal(t, InhibitLock(fakeFd), fdLock)
    	assert.NoError(t, err)
    }
    
    func TestReloadLogindConf(t *testing.T) {
    	bus := DBusCon{
    		SystemBus: &fakeSystemDBus{
    			fakeDBusObject: &fakeDBusObject{},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 29 19:50:06 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go

    			}
    		}
    	}()
    
    	m.setMetrics()
    	return nil
    }
    
    func (m *managerImpl) start() (chan struct{}, error) {
    	systemBus, err := systemDbus()
    	if err != nil {
    		return nil, err
    	}
    	m.dbusCon = systemBus
    
    	currentInhibitDelay, err := m.dbusCon.CurrentInhibitDelay()
    	if err != nil {
    		return nil, err
    	}
    
    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