diff options
Diffstat (limited to '')
| -rw-r--r-- | src/bus.py | 6 | ||||
| -rw-r--r-- | src/native_bus.pyx | 9 |
2 files changed, 13 insertions, 2 deletions
@@ -120,7 +120,10 @@ class Bus: ''' Close the bus ''' - from native_bus import bus_close_wrapped, bus_deallocate + try: + from native_bus import bus_close_wrapped, bus_deallocate + except: + return if self.bus is not None: if bus_close_wrapped(self.bus) == -1: raise self.__oserror() @@ -153,6 +156,7 @@ class Bus: 0: stop listening 1: continue listening -1: an error has occurred + NB! The received message will not be decoded from UTF-8 @param user_data See description of `callback` ''' from native_bus import bus_read_wrapped diff --git a/src/native_bus.pyx b/src/native_bus.pyx index 016fa3c..b6f3127 100644 --- a/src/native_bus.pyx +++ b/src/native_bus.pyx @@ -200,6 +200,12 @@ def bus_write_wrapped(bus : int, message : str) -> int: return bus_write(<long>bus, cmessage) +cdef int bus_callback_wrapper(const char *message, user_data): + cdef bytes bs = message + callback, user_data = tuple(<object>user_data) + return <int>callback(bs, user_data) + + def bus_read_wrapped(bus : int, callback : callable, user_data) -> int: ''' Listen (in a loop, forever) for new message on a bus @@ -217,5 +223,6 @@ def bus_read_wrapped(bus : int, callback : callable, user_data) -> int: -1: an error has occurred @return 0 on success, -1 on error ''' - return bus_read(<long>bus, <int (*)(const char *, void *)><void *>callback, <void *>user_data) + user = (callback, user_data) + return bus_read(<long>bus, <int (*)(const char *, void *)>&bus_callback_wrapper, <void *>user) |