Gecko [ nbspublicschool.com ]

Name	Size	Permission
__init__.py	7.51 KB	-rw-r--r--
__init__.pyc	11.29 KB	-rw-r--r--
__init__.pyo	11.29 KB	-rw-r--r--
_pyabrt.so	10.93 KB	-rwxr-xr-x
config.py	50 B	-rw-r--r--
config.pyc	199 B	-rw-r--r--
config.pyo	199 B	-rw-r--r--
exception.py	175 B	-rw-r--r--
exception.pyc	929 B	-rw-r--r--
exception.pyo	929 B	-rw-r--r--
proxies.py	6.31 KB	-rw-r--r--
proxies.pyc	9.3 KB	-rw-r--r--
proxies.pyo	9.3 KB	-rw-r--r--
tools.py	546 B	-rw-r--r--
tools.pyc	775 B	-rw-r--r--
tools.pyo	775 B	-rw-r--r--
watch.py	1.91 KB	-rw-r--r--
watch.pyc	2.66 KB	-rw-r--r--
watch.pyo	2.66 KB	-rw-r--r--

Code Editor : watch.py

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, uuid, duphash):
        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()

${this.title}

Code Editor : watch.py