Вызов dbus-python внутри потока - PullRequest
4 голосов
/ 17 июня 2011

Я получаю segfaults при вызове метода dbus внутри потока.Это мой сценарий: у меня есть программа Service1, которая выставляет метод test.Вторая программа Service2 предоставляет метод expose.Поскольку этот метод выполняет серьезные числовые вычисления, я передаю некоторые параметры из expose для работающей программы чтения потоков.Этот поток, в свою очередь, вызывает метод test Service1, когда завершает свою работу.Я получаю ошибки в последнем вызове dbus.

Код:

# Service1.py
class Service1(Object):
    def __init__(self, bus):
        name = BusName('com.example.Service1', bus)
        path = '/'
       super(Service1, self).__init__(name, path)

    @method(dbus_interface='com.example.Service1',
        in_signature='s', out_signature='s')
    def test(self, test):
        print 'test being called'
        return test

dbus_loop = DBusGMainLoop()
dsession = SessionBus(mainloop=dbus_loop)
loop = gobject.MainLoop()
gobject.threads_init()

im = Service1(dsession)
loop.run()


# Service2.py
dbus_loop = DBusGMainLoop()
dsession = SessionBus(mainloop=dbus_loop)

class Service2(Object):
def __init__(self, bus):
    name = BusName('com.example.Service2', bus)
    super(Service2, self).__init__(name, '/')

    self.queue = Queue()
    self.db = bus.get_object('com.example.Service1', '/')
    self.dbi = dbus.Interface(self.db, dbus_interface='com.example.Service1')

@method(dbus_interface='com.example.Service2',
        in_signature='', out_signature='')
def expose(self):
    print 'calling expose'
    self.queue.put(('params',))

def reader(self):
    while True:
        val = self.queue.get()
        dd = self.dbi.test('test')
        print dd
        self.queue.task_done()


gobject.threads_init()
loop = gobject.MainLoop()

im = Service2(dsession)
reader = threading.Thread(target=im.reader)
reader.start()

loop.run()

Чтобы проверить, запустите Service1.py, Service2.py, а затем этот фрагмент:

dbus_loop = DBusGMainLoop()
session = SessionBus(mainloop=dbus_loop)
proxy = session.get_object('com.example.Service2', '/')
test_i = dbus.Interface(proxy, dbus_interface='com.example.Service2')
test_i.expose()

Service2.py должен произойти сбой после запуска этого кода несколько раз.Но почему?

Ответы [ 2 ]

5 голосов
/ 20 июля 2012

gobject.threads_init() недостаточно, вам нужно позвонить dbus.mainloop.glib.threads_init(), чтобы сделать поток dbus-glib безопасным.

2 голосов
/ 21 декабря 2011

В Service1.py, попробуйте позвонить gobject.threads_init() до , присвоив dbus_loop DBusGMainLoop().

...