|
@@ -1,396 +0,0 @@
|
|
|
-/*
|
|
|
-Copyright 2013 CoreOS Inc.
|
|
|
-
|
|
|
-Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
-you may not use this file except in compliance with the License.
|
|
|
-You may obtain a copy of the License at
|
|
|
-
|
|
|
- http://www.apache.org/licenses/LICENSE-2.0
|
|
|
-
|
|
|
-Unless required by applicable law or agreed to in writing, software
|
|
|
-distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
-See the License for the specific language governing permissions and
|
|
|
-limitations under the License.
|
|
|
-*/
|
|
|
-
|
|
|
-package dbus
|
|
|
-
|
|
|
-import (
|
|
|
- "errors"
|
|
|
- "github.com/godbus/dbus"
|
|
|
-)
|
|
|
-
|
|
|
-func (c *Conn) initJobs() {
|
|
|
- c.jobListener.jobs = make(map[dbus.ObjectPath]chan string)
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) jobComplete(signal *dbus.Signal) {
|
|
|
- var id uint32
|
|
|
- var job dbus.ObjectPath
|
|
|
- var unit string
|
|
|
- var result string
|
|
|
- dbus.Store(signal.Body, &id, &job, &unit, &result)
|
|
|
- c.jobListener.Lock()
|
|
|
- out, ok := c.jobListener.jobs[job]
|
|
|
- if ok {
|
|
|
- out <- result
|
|
|
- delete(c.jobListener.jobs, job)
|
|
|
- }
|
|
|
- c.jobListener.Unlock()
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) startJob(job string, args ...interface{}) (<-chan string, error) {
|
|
|
- c.jobListener.Lock()
|
|
|
- defer c.jobListener.Unlock()
|
|
|
-
|
|
|
- ch := make(chan string, 1)
|
|
|
- var path dbus.ObjectPath
|
|
|
- err := c.sysobj.Call(job, 0, args...).Store(&path)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
- c.jobListener.jobs[path] = ch
|
|
|
- return ch, nil
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) runJob(job string, args ...interface{}) (string, error) {
|
|
|
- respCh, err := c.startJob(job, args...)
|
|
|
- if err != nil {
|
|
|
- return "", err
|
|
|
- }
|
|
|
- return <-respCh, nil
|
|
|
-}
|
|
|
-
|
|
|
-// StartUnit enqeues a start job and depending jobs, if any (unless otherwise
|
|
|
-// specified by the mode string).
|
|
|
-//
|
|
|
-// Takes the unit to activate, plus a mode string. The mode needs to be one of
|
|
|
-// replace, fail, isolate, ignore-dependencies, ignore-requirements. If
|
|
|
-// "replace" the call will start the unit and its dependencies, possibly
|
|
|
-// replacing already queued jobs that conflict with this. If "fail" the call
|
|
|
-// will start the unit and its dependencies, but will fail if this would change
|
|
|
-// an already queued job. If "isolate" the call will start the unit in question
|
|
|
-// and terminate all units that aren't dependencies of it. If
|
|
|
-// "ignore-dependencies" it will start a unit but ignore all its dependencies.
|
|
|
-// If "ignore-requirements" it will start a unit but only ignore the
|
|
|
-// requirement dependencies. It is not recommended to make use of the latter
|
|
|
-// two options.
|
|
|
-//
|
|
|
-// Result string: one of done, canceled, timeout, failed, dependency, skipped.
|
|
|
-// done indicates successful execution of a job. canceled indicates that a job
|
|
|
-// has been canceled before it finished execution. timeout indicates that the
|
|
|
-// job timeout was reached. failed indicates that the job failed. dependency
|
|
|
-// indicates that a job this job has been depending on failed and the job hence
|
|
|
-// has been removed too. skipped indicates that a job was skipped because it
|
|
|
-// didn't apply to the units current state.
|
|
|
-func (c *Conn) StartUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.StartUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// StopUnit is similar to StartUnit but stops the specified unit rather
|
|
|
-// than starting it.
|
|
|
-func (c *Conn) StopUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.StopUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// ReloadUnit reloads a unit. Reloading is done only if the unit is already running and fails otherwise.
|
|
|
-func (c *Conn) ReloadUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.ReloadUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// RestartUnit restarts a service. If a service is restarted that isn't
|
|
|
-// running it will be started.
|
|
|
-func (c *Conn) RestartUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.RestartUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// TryRestartUnit is like RestartUnit, except that a service that isn't running
|
|
|
-// is not affected by the restart.
|
|
|
-func (c *Conn) TryRestartUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.TryRestartUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// ReloadOrRestart attempts a reload if the unit supports it and use a restart
|
|
|
-// otherwise.
|
|
|
-func (c *Conn) ReloadOrRestartUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.ReloadOrRestartUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// ReloadOrTryRestart attempts a reload if the unit supports it and use a "Try"
|
|
|
-// flavored restart otherwise.
|
|
|
-func (c *Conn) ReloadOrTryRestartUnit(name string, mode string) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.ReloadOrTryRestartUnit", name, mode)
|
|
|
-}
|
|
|
-
|
|
|
-// StartTransientUnit() may be used to create and start a transient unit, which
|
|
|
-// will be released as soon as it is not running or referenced anymore or the
|
|
|
-// system is rebooted. name is the unit name including suffix, and must be
|
|
|
-// unique. mode is the same as in StartUnit(), properties contains properties
|
|
|
-// of the unit.
|
|
|
-func (c *Conn) StartTransientUnit(name string, mode string, properties ...Property) (string, error) {
|
|
|
- return c.runJob("org.freedesktop.systemd1.Manager.StartTransientUnit", name, mode, properties, make([]PropertyCollection, 0))
|
|
|
-}
|
|
|
-
|
|
|
-// KillUnit takes the unit name and a UNIX signal number to send. All of the unit's
|
|
|
-// processes are killed.
|
|
|
-func (c *Conn) KillUnit(name string, signal int32) {
|
|
|
- c.sysobj.Call("org.freedesktop.systemd1.Manager.KillUnit", 0, name, "all", signal).Store()
|
|
|
-}
|
|
|
-
|
|
|
-// getProperties takes the unit name and returns all of its dbus object properties, for the given dbus interface
|
|
|
-func (c *Conn) getProperties(unit string, dbusInterface string) (map[string]interface{}, error) {
|
|
|
- var err error
|
|
|
- var props map[string]dbus.Variant
|
|
|
-
|
|
|
- path := ObjectPath("/org/freedesktop/systemd1/unit/" + unit)
|
|
|
- if !path.IsValid() {
|
|
|
- return nil, errors.New("invalid unit name: " + unit)
|
|
|
- }
|
|
|
-
|
|
|
- obj := c.sysconn.Object("org.freedesktop.systemd1", path)
|
|
|
- err = obj.Call("org.freedesktop.DBus.Properties.GetAll", 0, dbusInterface).Store(&props)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- out := make(map[string]interface{}, len(props))
|
|
|
- for k, v := range props {
|
|
|
- out[k] = v.Value()
|
|
|
- }
|
|
|
-
|
|
|
- return out, nil
|
|
|
-}
|
|
|
-
|
|
|
-// GetUnitProperties takes the unit name and returns all of its dbus object properties.
|
|
|
-func (c *Conn) GetUnitProperties(unit string) (map[string]interface{}, error) {
|
|
|
- return c.getProperties(unit, "org.freedesktop.systemd1.Unit")
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) getProperty(unit string, dbusInterface string, propertyName string) (*Property, error) {
|
|
|
- var err error
|
|
|
- var prop dbus.Variant
|
|
|
-
|
|
|
- path := ObjectPath("/org/freedesktop/systemd1/unit/" + unit)
|
|
|
- if !path.IsValid() {
|
|
|
- return nil, errors.New("invalid unit name: " + unit)
|
|
|
- }
|
|
|
-
|
|
|
- obj := c.sysconn.Object("org.freedesktop.systemd1", path)
|
|
|
- err = obj.Call("org.freedesktop.DBus.Properties.Get", 0, dbusInterface, propertyName).Store(&prop)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return &Property{Name: propertyName, Value: prop}, nil
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) GetUnitProperty(unit string, propertyName string) (*Property, error) {
|
|
|
- return c.getProperty(unit, "org.freedesktop.systemd1.Unit", propertyName)
|
|
|
-}
|
|
|
-
|
|
|
-// GetUnitTypeProperties returns the extra properties for a unit, specific to the unit type.
|
|
|
-// Valid values for unitType: Service, Socket, Target, Device, Mount, Automount, Snapshot, Timer, Swap, Path, Slice, Scope
|
|
|
-// return "dbus.Error: Unknown interface" if the unitType is not the correct type of the unit
|
|
|
-func (c *Conn) GetUnitTypeProperties(unit string, unitType string) (map[string]interface{}, error) {
|
|
|
- return c.getProperties(unit, "org.freedesktop.systemd1."+unitType)
|
|
|
-}
|
|
|
-
|
|
|
-// SetUnitProperties() may be used to modify certain unit properties at runtime.
|
|
|
-// Not all properties may be changed at runtime, but many resource management
|
|
|
-// settings (primarily those in systemd.cgroup(5)) may. The changes are applied
|
|
|
-// instantly, and stored on disk for future boots, unless runtime is true, in which
|
|
|
-// case the settings only apply until the next reboot. name is the name of the unit
|
|
|
-// to modify. properties are the settings to set, encoded as an array of property
|
|
|
-// name and value pairs.
|
|
|
-func (c *Conn) SetUnitProperties(name string, runtime bool, properties ...Property) error {
|
|
|
- return c.sysobj.Call("org.freedesktop.systemd1.Manager.SetUnitProperties", 0, name, runtime, properties).Store()
|
|
|
-}
|
|
|
-
|
|
|
-func (c *Conn) GetUnitTypeProperty(unit string, unitType string, propertyName string) (*Property, error) {
|
|
|
- return c.getProperty(unit, "org.freedesktop.systemd1." + unitType, propertyName)
|
|
|
-}
|
|
|
-
|
|
|
-// ListUnits returns an array with all currently loaded units. Note that
|
|
|
-// units may be known by multiple names at the same time, and hence there might
|
|
|
-// be more unit names loaded than actual units behind them.
|
|
|
-func (c *Conn) ListUnits() ([]UnitStatus, error) {
|
|
|
- result := make([][]interface{}, 0)
|
|
|
- err := c.sysobj.Call("org.freedesktop.systemd1.Manager.ListUnits", 0).Store(&result)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- resultInterface := make([]interface{}, len(result))
|
|
|
- for i := range result {
|
|
|
- resultInterface[i] = result[i]
|
|
|
- }
|
|
|
-
|
|
|
- status := make([]UnitStatus, len(result))
|
|
|
- statusInterface := make([]interface{}, len(status))
|
|
|
- for i := range status {
|
|
|
- statusInterface[i] = &status[i]
|
|
|
- }
|
|
|
-
|
|
|
- err = dbus.Store(resultInterface, statusInterface...)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return status, nil
|
|
|
-}
|
|
|
-
|
|
|
-type UnitStatus struct {
|
|
|
- Name string // The primary unit name as string
|
|
|
- Description string // The human readable description string
|
|
|
- LoadState string // The load state (i.e. whether the unit file has been loaded successfully)
|
|
|
- ActiveState string // The active state (i.e. whether the unit is currently started or not)
|
|
|
- SubState string // The sub state (a more fine-grained version of the active state that is specific to the unit type, which the active state is not)
|
|
|
- Followed string // A unit that is being followed in its state by this unit, if there is any, otherwise the empty string.
|
|
|
- Path dbus.ObjectPath // The unit object path
|
|
|
- JobId uint32 // If there is a job queued for the job unit the numeric job id, 0 otherwise
|
|
|
- JobType string // The job type as string
|
|
|
- JobPath dbus.ObjectPath // The job object path
|
|
|
-}
|
|
|
-
|
|
|
-type LinkUnitFileChange EnableUnitFileChange
|
|
|
-
|
|
|
-// LinkUnitFiles() links unit files (that are located outside of the
|
|
|
-// usual unit search paths) into the unit search path.
|
|
|
-//
|
|
|
-// It takes a list of absolute paths to unit files to link and two
|
|
|
-// booleans. The first boolean controls whether the unit shall be
|
|
|
-// enabled for runtime only (true, /run), or persistently (false,
|
|
|
-// /etc).
|
|
|
-// The second controls whether symlinks pointing to other units shall
|
|
|
-// be replaced if necessary.
|
|
|
-//
|
|
|
-// This call returns a list of the changes made. The list consists of
|
|
|
-// structures with three strings: the type of the change (one of symlink
|
|
|
-// or unlink), the file name of the symlink and the destination of the
|
|
|
-// symlink.
|
|
|
-func (c *Conn) LinkUnitFiles(files []string, runtime bool, force bool) ([]LinkUnitFileChange, error) {
|
|
|
- result := make([][]interface{}, 0)
|
|
|
- err := c.sysobj.Call("org.freedesktop.systemd1.Manager.LinkUnitFiles", 0, files, runtime, force).Store(&result)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- resultInterface := make([]interface{}, len(result))
|
|
|
- for i := range result {
|
|
|
- resultInterface[i] = result[i]
|
|
|
- }
|
|
|
-
|
|
|
- changes := make([]LinkUnitFileChange, len(result))
|
|
|
- changesInterface := make([]interface{}, len(changes))
|
|
|
- for i := range changes {
|
|
|
- changesInterface[i] = &changes[i]
|
|
|
- }
|
|
|
-
|
|
|
- err = dbus.Store(resultInterface, changesInterface...)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return changes, nil
|
|
|
-}
|
|
|
-
|
|
|
-// EnableUnitFiles() may be used to enable one or more units in the system (by
|
|
|
-// creating symlinks to them in /etc or /run).
|
|
|
-//
|
|
|
-// It takes a list of unit files to enable (either just file names or full
|
|
|
-// absolute paths if the unit files are residing outside the usual unit
|
|
|
-// search paths), and two booleans: the first controls whether the unit shall
|
|
|
-// be enabled for runtime only (true, /run), or persistently (false, /etc).
|
|
|
-// The second one controls whether symlinks pointing to other units shall
|
|
|
-// be replaced if necessary.
|
|
|
-//
|
|
|
-// This call returns one boolean and an array with the changes made. The
|
|
|
-// boolean signals whether the unit files contained any enablement
|
|
|
-// information (i.e. an [Install]) section. The changes list consists of
|
|
|
-// structures with three strings: the type of the change (one of symlink
|
|
|
-// or unlink), the file name of the symlink and the destination of the
|
|
|
-// symlink.
|
|
|
-func (c *Conn) EnableUnitFiles(files []string, runtime bool, force bool) (bool, []EnableUnitFileChange, error) {
|
|
|
- var carries_install_info bool
|
|
|
-
|
|
|
- result := make([][]interface{}, 0)
|
|
|
- err := c.sysobj.Call("org.freedesktop.systemd1.Manager.EnableUnitFiles", 0, files, runtime, force).Store(&carries_install_info, &result)
|
|
|
- if err != nil {
|
|
|
- return false, nil, err
|
|
|
- }
|
|
|
-
|
|
|
- resultInterface := make([]interface{}, len(result))
|
|
|
- for i := range result {
|
|
|
- resultInterface[i] = result[i]
|
|
|
- }
|
|
|
-
|
|
|
- changes := make([]EnableUnitFileChange, len(result))
|
|
|
- changesInterface := make([]interface{}, len(changes))
|
|
|
- for i := range changes {
|
|
|
- changesInterface[i] = &changes[i]
|
|
|
- }
|
|
|
-
|
|
|
- err = dbus.Store(resultInterface, changesInterface...)
|
|
|
- if err != nil {
|
|
|
- return false, nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return carries_install_info, changes, nil
|
|
|
-}
|
|
|
-
|
|
|
-type EnableUnitFileChange struct {
|
|
|
- Type string // Type of the change (one of symlink or unlink)
|
|
|
- Filename string // File name of the symlink
|
|
|
- Destination string // Destination of the symlink
|
|
|
-}
|
|
|
-
|
|
|
-// DisableUnitFiles() may be used to disable one or more units in the system (by
|
|
|
-// removing symlinks to them from /etc or /run).
|
|
|
-//
|
|
|
-// It takes a list of unit files to disable (either just file names or full
|
|
|
-// absolute paths if the unit files are residing outside the usual unit
|
|
|
-// search paths), and one boolean: whether the unit was enabled for runtime
|
|
|
-// only (true, /run), or persistently (false, /etc).
|
|
|
-//
|
|
|
-// This call returns an array with the changes made. The changes list
|
|
|
-// consists of structures with three strings: the type of the change (one of
|
|
|
-// symlink or unlink), the file name of the symlink and the destination of the
|
|
|
-// symlink.
|
|
|
-func (c *Conn) DisableUnitFiles(files []string, runtime bool) ([]DisableUnitFileChange, error) {
|
|
|
- result := make([][]interface{}, 0)
|
|
|
- err := c.sysobj.Call("org.freedesktop.systemd1.Manager.DisableUnitFiles", 0, files, runtime).Store(&result)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- resultInterface := make([]interface{}, len(result))
|
|
|
- for i := range result {
|
|
|
- resultInterface[i] = result[i]
|
|
|
- }
|
|
|
-
|
|
|
- changes := make([]DisableUnitFileChange, len(result))
|
|
|
- changesInterface := make([]interface{}, len(changes))
|
|
|
- for i := range changes {
|
|
|
- changesInterface[i] = &changes[i]
|
|
|
- }
|
|
|
-
|
|
|
- err = dbus.Store(resultInterface, changesInterface...)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return changes, nil
|
|
|
-}
|
|
|
-
|
|
|
-type DisableUnitFileChange struct {
|
|
|
- Type string // Type of the change (one of symlink or unlink)
|
|
|
- Filename string // File name of the symlink
|
|
|
- Destination string // Destination of the symlink
|
|
|
-}
|
|
|
-
|
|
|
-// Reload instructs systemd to scan for and reload unit files. This is
|
|
|
-// equivalent to a 'systemctl daemon-reload'.
|
|
|
-func (c *Conn) Reload() error {
|
|
|
- return c.sysobj.Call("org.freedesktop.systemd1.Manager.Reload", 0).Store()
|
|
|
-}
|