add CancelJob()

dbus/methods.go

@@ -852,6 +852,11 @@ func (c *Conn) listJobsInternal(ctx context.Context) ([]JobStatus, error) {
 	return status, nil
 }
 
+// Cancel the specified job ID.
+func (c *Conn) CancelJobContext(ctx context.Context, id uint32) error {
+	return c.sysobj.CallWithContext(ctx, "org.freedesktop.systemd1.Manager.CancelJob", 0, id).Store()
+}
+
 // Freeze the cgroup associated with the unit.
 // Note that FreezeUnit and ThawUnit are only supported on systems running with cgroup v2.
 func (c *Conn) FreezeUnit(ctx context.Context, unit string) error {

dbus/methods_test.go

@@ -1689,3 +1689,38 @@ func TestFreezer(t *testing.T) {
 
 	runStopUnit(t, conn, TrUnitProp{target, nil})
 }
+
+func TestCancel(t *testing.T) {
+	target := "cancelme.service"
+	conn := setupConn(t)
+	defer conn.Close()
+
+	setupUnit(target, conn, t)
+	linkUnit(target, conn, t)
+
+	reschan := make(chan string)
+	_, err := conn.StartUnit(target, "replace", reschan)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	ctx := context.Background()
+	units, err := conn.ListUnitsByNamesContext(ctx, []string{target})
+	if err != nil {
+		t.Fatal("couldn't list units ", err)
+	}
+
+	if err := conn.CancelJobContext(ctx, units[0].JobId); err != nil {
+		t.Fatal("couldn't cancel job ", err)
+	}
+
+	units, err = conn.ListUnitsByNamesContext(ctx, []string{target})
+	if err != nil {
+		t.Fatal("couldn't list units after cancel ", err)
+	}
+
+	job := <-reschan
+	if job != "canceled" {
+		t.Fatal("Job is not canceled:", job)
+	}
+}

fixtures/cancelme.service

@@ -0,0 +1,6 @@
+[Unit]
+Description=cancel unit test
+
+[Service]
+ExecStartPre=/bin/sleep 400
+ExecStart=/bin/sleep 400