X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=systemctl.vala;h=4f017e02e7a0a82baca3ceec6596556a5ca6373c;hp=abeb0ac7a99844330081aa408900b08563622438;hb=edddf4ff8841951cdbb698f72a3f4f8554ce8d33;hpb=dcc47b179fed0ae67b0481b2454aea03947e712c diff --git a/systemctl.vala b/systemctl.vala index abeb0ac7a..4f017e02e 100644 --- a/systemctl.vala +++ b/systemctl.vala @@ -1,45 +1,35 @@ -using DBus; -using GLib; +/*** + This file is part of systemd. -[DBus (name = "org.freedesktop.systemd1")] -public interface Manager : DBus.Object { - - public struct UnitInfo { - string id; - string description; - string load_state; - string active_state; - ObjectPath unit_path; - uint32 job_id; - string job_type; - ObjectPath job_path; - } + Copyright 2010 Lennart Poettering - public struct JobInfo { - uint32 id; - string name; - string type; - string state; - ObjectPath job_path; - ObjectPath unit_path; - } + systemd is free software; you can redistribute it and/or modify it + under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. - public abstract UnitInfo[] ListUnits() throws DBus.Error; - public abstract JobInfo[] ListJobs() throws DBus.Error; + systemd is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. - public abstract ObjectPath LoadUnit(string name) throws DBus.Error; + You should have received a copy of the GNU General Public License + along with systemd; If not, see . +***/ - public abstract void ClearJobs() throws DBus.Error; -} +using DBus; +using GLib; static string type = null; static bool all = false; +static bool replace = false; +static bool session = false; public static int job_info_compare(void* key1, void* key2) { Manager.JobInfo *j1 = (Manager.JobInfo*) key1; Manager.JobInfo *j2 = (Manager.JobInfo*) key2; - return Posix.strcmp(j1->name, j2->name); + return j1->id < j2->id ? -1 : (j1->id > j2->id ? 1 : 0); } public static int unit_info_compare(void* key1, void* key2) { @@ -53,16 +43,47 @@ public static int unit_info_compare(void* key1, void* key2) { return Posix.strcmp(u1->id, u2->id); } +public void on_unit_new(string id, ObjectPath path) { + stdout.printf("Unit %s added.\n", id); +} + +public void on_job_new(uint32 id, ObjectPath path) { + stdout.printf("Job %u added.\n", id); +} + +public void on_unit_removed(string id, ObjectPath path) { + stdout.printf("Unit %s removed.\n", id); +} + +public void on_job_removed(uint32 id, ObjectPath path) { + stdout.printf("Job %u removed.\n", id); +} + static const OptionEntry entries[] = { - { "type", 't', 0, OptionArg.STRING, out type, "List only particular type of units", "TYPE" }, - { "all", 'a', 0, OptionArg.NONE, out all, "Show all units, including dead ones", null }, + { "type", 't', 0, OptionArg.STRING, out type, "List only particular type of units", "TYPE" }, + { "all", 'a', 0, OptionArg.NONE, out all, "Show all units, including dead ones", null }, + { "replace", 0, 0, OptionArg.NONE, out replace, "When installing a new job, replace existing conflicting ones", null }, + { "session", 0, 0, OptionArg.NONE, out session, "Connect to session bus", null }, + { "system", 0, OptionFlags.REVERSE, OptionArg.NONE, out session, "Connect to system bus", null }, { null } }; int main (string[] args) { - OptionContext context = new OptionContext(" -- Control systemd"); + OptionContext context = new OptionContext("[OPTION...] [COMMAND [ARGUMENT...]]"); context.add_main_entries(entries, null); + context.set_description( + "Commands:\n" + + " list-units List units\n" + + " list-jobs List jobs\n" + + " clear-jobs Cancel all jobs\n" + + " load [NAME...] Load one or more units\n" + + " cancel [JOB...] Cancel one or more jobs\n" + + " start [NAME...] Start on or more units\n" + + " stop [NAME...] Stop on or more units\n" + + " restart [NAME...] Restart on or more units\n" + + " reload [NAME...] Reload on or more units\n" + + " monitor Monitor unit/job changes\n"); try { context.parse(ref args); @@ -71,7 +92,7 @@ int main (string[] args) { } try { - Connection bus = Bus.get(BusType.SESSION); + Connection bus = Bus.get(session ? BusType.SESSION : BusType.SYSTEM); Manager manager = bus.get_object ( "org.freedesktop.systemd1", @@ -79,7 +100,7 @@ int main (string[] args) { "org.freedesktop.systemd1") as Manager; if (args[1] == "list-units" || args.length <= 1) { - var list = manager.ListUnits(); + var list = manager.list_units(); uint n = 0; Posix.qsort(list, list.length, sizeof(Manager.UnitInfo), unit_info_compare); @@ -109,19 +130,19 @@ int main (string[] args) { } else if (args[1] == "list-jobs") { - var list = manager.ListJobs(); + var list = manager.list_jobs(); Posix.qsort(list, list.length, sizeof(Manager.JobInfo), job_info_compare); - stdout.printf("%-45s %-17s %-7s\n", "UNIT", "TYPE", "STATE"); + stdout.printf("%4s %-45s %-17s %-7s\n", "JOB", "UNIT", "TYPE", "STATE"); foreach (var i in list) - stdout.printf("%-45s → %-15s %-7s\n", i.name, i.type, i.state); + stdout.printf("%4u %-45s → %-15s %-7s\n", i.id, i.name, i.type, i.state); stdout.printf("\n%u jobs listed.\n", list.length); } else if (args[1] == "clear-jobs") { - manager.ClearJobs(); + manager.clear_jobs(); } else if (args[1] == "load") { @@ -130,7 +151,77 @@ int main (string[] args) { return 1; } - manager.LoadUnit(args[2]); + for (int i = 2; i < args.length; i++) + manager.load_unit(args[i]); + + } else if (args[1] == "cancel") { + + if (args.length < 3) { + stderr.printf("Missing argument.\n"); + return 1; + } + + for (int i = 2; i < args.length; i++) { + uint32 id; + + if (args[i].scanf("%u", out id) != 1) { + stderr.printf("Failed to parse argument.\n"); + return 1; + } + + ObjectPath p = manager.get_job(id); + + Job j = bus.get_object ( + "org.freedesktop.systemd1", + p, + "org.freedesktop.systemd1.Job") as Job; + + j.cancel(); + } + + } else if (args[1] == "start" || + args[1] == "stop" || + args[1] == "reload" || + args[1] == "restart") { + + if (args.length < 3) { + stderr.printf("Missing argument.\n"); + return 1; + } + + for (int i = 2; i < args.length; i++) { + + ObjectPath p = manager.get_unit(args[i]); + + Unit u = bus.get_object( + "org.freedesktop.systemd1", + p, + "org.freedesktop.systemd1.Unit") as Unit; + + string mode = replace ? "replace" : "fail"; + + if (args[1] == "start") + u.start(mode); + else if (args[1] == "stop") + u.stop(mode); + else if (args[1] == "restart") + u.restart(mode); + else if (args[1] == "reload") + u.reload(mode); + } + + } else if (args[1] == "monitor") { + + manager.subscribe(); + + manager.unit_new += on_unit_new; + manager.unit_removed += on_unit_removed; + manager.job_new += on_job_new; + manager.job_removed += on_job_removed; + + MainLoop l = new MainLoop(); + l.run(); + } else { stderr.printf("Unknown command %s.\n", args[1]); return 1;