]>
git.ipfire.org Git - collecty.git/blob - src/collecty/bus.py
2 ###############################################################################
4 # collecty - A system statistics collection daemon for IPFire #
5 # Copyright (C) 2015 IPFire development team #
7 # This program is free software: you can redistribute it and/or modify #
8 # it under the terms of the GNU General Public License as published by #
9 # the Free Software Foundation, either version 3 of the License, or #
10 # (at your option) any later version. #
12 # This program is distributed in the hope that it will be useful, #
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of #
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the #
15 # GNU General Public License for more details. #
17 # You should have received a copy of the GNU General Public License #
18 # along with this program. If not, see <http://www.gnu.org/licenses/>. #
20 ###############################################################################
23 import dbus
.mainloop
.glib
28 from constants
import *
32 log
= logging
.getLogger("collecty.bus")
35 # Initialise the glib main loop
36 dbus
.mainloop
.glib
.DBusGMainLoop(set_as_default
=True)
37 dbus
.mainloop
.glib
.threads_init()
39 class Bus(threading
.Thread
):
40 def __init__(self
, collecty
):
41 threading
.Thread
.__init
__(self
)
44 self
.collecty
= collecty
46 # Initialise the main loop
47 gobject
.threads_init()
48 self
.loop
= gobject
.MainLoop()
50 # Register the GraphGenerator interface
51 self
.generator
= GraphGenerator(self
.collecty
)
54 log
.debug(_("Bus thread has started"))
60 log
.debug(_("Stopping bus thread"))
65 # Return when this thread has finished
69 class GraphGenerator(dbus
.service
.Object
):
70 def __init__(self
, collecty
):
71 bus_name
= dbus
.service
.BusName(BUS_DOMAIN
, bus
=dbus
.SystemBus())
72 dbus
.service
.Object
.__init
__(self
, bus_name
, "/%s" % self
.__class
__.__name
__)
74 self
.collecty
= collecty
76 @dbus.service
.method(BUS_DOMAIN
, in_signature
="sa{sv}", out_signature
="ay")
77 def GenerateGraph(self
, template_name
, kwargs
):
79 Returns a graph generated from the given template and object.
81 graph
= self
.collecty
.generate_graph(template_name
, **kwargs
)
83 return dbus
.ByteArray(graph
or [])
85 @dbus.service
.method(BUS_DOMAIN
, in_signature
="", out_signature
="as")
86 def ListTemplates(self
):
88 Returns a list of all available templates
90 return [t
.name
for t
in self
.collecty
.templates
]