blob: ad3e82cba552f27cae8dc3f8577f620fd554d309 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
#!/usr/bin/env python
import dbus
import gobject
from dbus.mainloop.glib import DBusGMainLoop
import gtk
CC_IFACE = 'com.redhat.crash_catcher'
CC_PATH = '/com/redhat/crash_catcher'
class DBusManager(gobject.GObject):
""" Class to provide communication with daemon over dbus """
# and later with policyKit
def __init__(self):
gobject.GObject.__init__(self)
# signal emited when new crash is detected
gobject.signal_new ("crash", self ,gobject.SIGNAL_RUN_FIRST,gobject.TYPE_NONE,())
# binds the dbus to glib mainloop
DBusGMainLoop(set_as_default=True)
self.proxy = None
self.connect_to_daemon()
if self.proxy:
self.cc = dbus.Interface(self.proxy, dbus_interface=CC_IFACE)
#intr = dbus.Interface(proxy, dbus_interface='org.freedesktop.DBus.Introspectable')
self.proxy.connect_to_signal("Crash",self.crash_cb,dbus_interface=CC_IFACE)
else:
raise Exception("Proxy object doesn't exist!")
# disconnect callback
def disconnected(*args):
print "disconnect"
def crash_cb(self,*args):
#FIXME "got another crash, gui should reload!"
#for arg in args:
# print arg
#emit a signal
#print "crash"
self.emit("crash")
def connect_to_daemon(self):
bus = dbus.SystemBus()
if not bus:
raise Exception("Can't connect to dbus")
try:
self.proxy = bus.get_object(CC_IFACE, CC_PATH)
except Exception, e:
raise Exception(e.message + "\nPlease check if crash-catcher daemon is running.")
def getDumps(self):
row_dict = None
rows = []
for row in self.cc.GetCrashInfosMap(""):
row_dict = {}
for column in row:
row_dict[column] = row[column]
rows.append(row_dict);
return rows
|
