No asynchronous response when service is stopped

[ndeubert]

I noticed when using this code:

func isChanged(prev *dbus.UnitStatus, curr *dbus.UnitStatus) bool {
	if prev.ActiveState != curr.ActiveState {
		return true
	}
	return false
}

func (o *Object) filterUnit(unit string) bool {
	if unit == o.cfg.PlatCfg.ServiceName1|| unit == o.cfg.PlatCfg.ServiceName2{
		return false
	}
	return true
}
...
o.asyncstatus, o.asyncerr = o.conn.SubscribeUnitsCustom(1*time.Second, 1, isChanged, o.filterUnit)

I do not get any events from the asyncstatus channel when the service is stopped in a terminal with sudo systemctl stop service1 like I do when I start a service with id, err := o.conn.StartUnitContext(o.ctx, svcName, "replace", o.async) or sudo systemctl start service1

Even if I stop the service programmatically with id, usererr := o.conn.StopUnitContext(o.ctx, o.cfg.PlatCfg.ServiceName1, "replace", o.async) I only see "done" on the async channel.

If I want to find out about these events do I need to use the dbus interface directly? Do I need to poll myself or use o.asyncstatus, o.asyncerr = o.conn.SubscribeUnits(1 * time.Second) and check if it goes away?. If I kill the process manually then I do get a "failed" event on the asyncstatus channel. I didn't see any mention of this being expected behavior in the documentation, but it seems odd not to be supported given the rest of the behavior. Thanks.

[vlw]

I have same issue :(

	updates, errors := conn.SubscribeUnitsCustom(0, 10, isChanged, filterUnit)

	go func() {
		for err := range errors {
			log.Printf("Error: %s", err)
		}
	}()

	for update := range updates {
		for sName, status := range update {
			if status != nil {
				log.Printf("Service %s ActiveState changed to: %s\n", sName, status.ActiveState)
			} else {
				log.Printf("Service %s: no status\n", sName)
			}
		}
	}

log when I start/stop service many times:

2024/03/19 01:39:34 Service s-kek-1.service ActiveState changed to: active 2024/03/19 01:39:57 Service s-kek-1.service ActiveState changed to: deactivating 2024/03/19 01:39:57 Service s-kek-1.service: no status 2024/03/19 01:40:02 Service s-kek-1.service ActiveState changed to: active 2024/03/19 01:40:07 Service s-kek-1.service: no status 2024/03/19 01:40:12 Service s-kek-1.service ActiveState changed to: active

sometimes I see "deactivating" but always see "no status" when service stopped

BTW I see all logs in dbus monitor: dbus-monitor --system "type='signal',interface='org.freedesktop.DBus.Properties',member='PropertiesChanged',path='/org/freedesktop/systemd1/unit/s_2dkek_2d1_2eservice'" | awk '/string "ActiveState"/ { getline; print $0 }' terminal output:

         variant             string "active"
         variant             string "active"
         variant             string "deactivating"
         variant             string "inactive"
         variant             string "inactive"
         variant             string "inactive"
         variant             string "active"
         variant             string "active"
         variant             string "active"

[vlw]

@ndeubert solution found!

package main

import (
	"fmt"
	"github.com/godbus/dbus/v5"
	"log"
	"strings"
)

func main() {
	conn, err := dbus.SystemBus()
	if err != nil {
		log.Fatalf("Failed to connect to System Bus: %v", err)
	}

	var rules = "type='signal',interface='org.freedesktop.DBus.Properties',member='PropertiesChanged',arg0namespace='org.freedesktop.systemd1.Unit'"
	conn.BusObject().Call("org.freedesktop.DBus.AddMatch", 0, rules)
	fmt.Println("Subscribed to PropertiesChanged signals for systemd units")

	c := make(chan *dbus.Signal, 10)
	conn.Signal(c)

	for v := range c {
		handleSignal(v)
	}
}

func handleSignal(v *dbus.Signal) {
	if len(v.Body) >= 3 {
		var unitPath dbus.ObjectPath
		var changedProps map[string]dbus.Variant
		//var iface string

		//iface = v.Body[0].(string)
		changedProps = v.Body[1].(map[string]dbus.Variant)
		unitPath = v.Path

		//fmt.Printf("Signal from interface %s for unit %s\n", iface, unitPath)

		for propName, propValue := range changedProps {
			if propName == "ActiveState" {
				//fmt.Println("ActiveState changed")
				unitName := strings.Replace(string(unitPath), "/org/freedesktop/systemd1/unit/", "", 1)
				unitName = strings.Replace(unitName, "_2e", ".", -1)
				unitName = strings.Replace(unitName, "_2d", "-", -1)
				unitName = strings.Replace(unitName, "_5f", "_", -1)
				fmt.Printf("Unit: %s, ActiveState: %s\n", unitName, propValue.Value().(string))
			}
		}
	}
}

Output:

Subscribed to PropertiesChanged signals for systemd units
Unit: php8.3-fpm.service, ActiveState: active
Unit: php8.3-fpm.service, ActiveState: active
Unit: php8.3-fpm.service, ActiveState: active
Unit: php8.3-fpm.service, ActiveState: active
Unit: php8.3-fpm.service, ActiveState: active
Unit: php8.3-fpm.service, ActiveState: active
Unit: user-1157.slice, ActiveState: inactive
Unit: user-1157.slice, ActiveState: active
Unit: user-runtime-dir_401157.service, ActiveState: inactive
Unit: user-runtime-dir_401157.service, ActiveState: activating
Unit: user-1157.slice, ActiveState: active
Unit: user-runtime-dir_401157.service, ActiveState: active
Unit: user-runtime-dir_401157.service, ActiveState: active
Unit: user_401157.service, ActiveState: inactive
Unit: user_401157.service, ActiveState: activating
Unit: user_401157.service, ActiveState: activating
Unit: user_401157.service, ActiveState: active
Unit: user_401157.service, ActiveState: active
Unit: user_401157.service, ActiveState: active
Unit: session-18886.scope, ActiveState: inactive
Unit: session-18886.scope, ActiveState: active
Unit: session-18886.scope, ActiveState: active
Unit: session-18886.scope, ActiveState: inactive
Unit: user-1158.slice, ActiveState: inactive
Unit: user-1158.slice, ActiveState: active
Unit: user-runtime-dir_401158.service, ActiveState: inactive
Unit: user-runtime-dir_401158.service, ActiveState: activating
Unit: user-1158.slice, ActiveState: active
Unit: user-runtime-dir_401158.service, ActiveState: active
Unit: user-runtime-dir_401158.service, ActiveState: active
Unit: user_401158.service, ActiveState: inactive

[ndeubert]

Ah cool. thank you for following up