FM / problem

/usr/lib64/python2.6/site-packages/problem/

/usr/lib64/python2.6/site-packages/problem

Name	Size	Mode	Actions
config.py	42	0644	edit dl rm
config.pyc	191	0644	edit dl rm
config.pyo	191	0644	edit dl rm
exception.py	175	0644	edit dl rm
exception.pyc	929	0644	edit dl rm
exception.pyo	929	0644	edit dl rm
proxies.py	6457	0644	edit dl rm
proxies.pyc	9572	0644	edit dl rm
proxies.pyo	9572	0644	edit dl rm
tools.py	546	0644	edit dl rm
tools.pyc	777	0644	edit dl rm
tools.pyo	777	0644	edit dl rm
watch.py	1944	0644	edit dl rm
watch.pyc	2706	0644	edit dl rm
watch.pyo	2706	0644	edit dl rm
_pyabrt.so	10208	0755	edit dl rm
__init__.py	7693	0644	edit dl rm
__init__.pyc	11614	0644	edit dl rm
__init__.pyo	11614	0644	edit dl rm

Edit: /usr/lib64/python2.6/site-packages/problem/watch.py (1944B)

import os
import logging

import problem

class ProblemWatcher(object):
    ''' New problem signal handler attached to DBus signal

Use ``auth=True`` if authentication should be attempted for
    new problem that doesn't belong to current user. If not
    set such a problem is ignored.

'''

def __init__(self, auth):
        import dbus
        import gobject
        from dbus.mainloop.glib import DBusGMainLoop

gobject.threads_init()

bus = dbus.SystemBus(
            mainloop=DBusGMainLoop(),
            private=True)

self.bus = bus
        self.auth = auth
        self.callbacks = []

# local context required!?
        # http://rmarko.fedorapeople.org/random/high_five.jpg
        evt_match = self.bus.add_signal_receiver(
            self._new_problem_handler,
            signal_name='Crash', path='/org/freedesktop/problems')

# add second listener for the old path
        evt_match_old_path = self.bus.add_signal_receiver(
            self._new_problem_handler,
            signal_name='Crash', path='/com/redhat/abrt')

self.loop = gobject.MainLoop()

def _new_problem_handler(self, comp, ddir, uid):
        logging.debug('New problem notification received')
        if int(uid) != os.getuid() and not self.auth:
            logging.debug('Auth disabled, ignoring crash with'
                          ' uid: {0}'.format(uid))
            return

prob = problem.tools.problemify(ddir, problem.proxies.get_proxy())
        for cb in self.callbacks:
            cb(prob)

def add_callback(self, fun):
        ''' Add callback to be called when new problem occurs.

Each callback function receives ``Problem`` instance

'''

self.callbacks.append(fun)

def run(self):
        ''' Start event listener loop '''

self.loop.run()

def quit(self):
        ''' Stop event listener loop '''

self.loop.quit()

import os import logging import problem class ProblemWatcher(object): ''' New problem signal handler attached to DBus signal Use ``auth=True`` if authentication should be attempted for new problem that doesn't belong to current user. If not set such a problem is ignored. ''' def __init__(self, auth): import dbus import gobject from dbus.mainloop.glib import DBusGMainLoop gobject.threads_init() bus = dbus.SystemBus( mainloop=DBusGMainLoop(), private=True) self.bus = bus self.auth = auth self.callbacks = [] # local context required!? # http://rmarko.fedorapeople.org/random/high_five.jpg evt_match = self.bus.add_signal_receiver( self._new_problem_handler, signal_name='Crash', path='/org/freedesktop/problems') # add second listener for the old path evt_match_old_path = self.bus.add_signal_receiver( self._new_problem_handler, signal_name='Crash', path='/com/redhat/abrt') self.loop = gobject.MainLoop() def _new_problem_handler(self, comp, ddir, uid): logging.debug('New problem notification received') if int(uid) != os.getuid() and not self.auth: logging.debug('Auth disabled, ignoring crash with' ' uid: {0}'.format(uid)) return prob = problem.tools.problemify(ddir, problem.proxies.get_proxy()) for cb in self.callbacks: cb(prob) def add_callback(self, fun): ''' Add callback to be called when new problem occurs. Each callback function receives ``Problem`` instance ''' self.callbacks.append(fun) def run(self): ''' Start event listener loop ''' self.loop.run() def quit(self): ''' Stop event listener loop ''' self.loop.quit()