spacepaste

Paste details

reply | raw

  1.  
  2. ffi.cdef("""
  3. struct ev_io { ...; }
  5. struct my_io {
  6. ev_io io;
  7. void *handle;
  8. ...;
  9. };
  10. """)
  12. ffi.set_source("_example", """
  14. static int (*python_callback)(void *handle, int revents);
  15. static void (*python_handle_error)(void *handle);
  17. static void my_io_callback(struct ev_loop *loop, ev_io *io, int revents)
  18. {
  19. /* invoke 'self.callback()' */
  20. void *handle = ((struct my_io *)io)->handle;
  21. if (python_callback(handle, revents) < 0) {
  22. /* in case of exception, call 'self.loop.handle_error()' */
  23. python_handle_error(handle);
  24. }
  25. ... more code to stop the event, like _run_callback() does ...
  26. }
  28. """)
  31. # this is done globally:
  33. @ffi.callback("int(void *handle, int revents)", error=-1)
  34. def python_callback(handle, revents):
  35. watcher = ffi.from_handle(handle)
  36. watcher.callback(*watcher.args)
  37. return 0
  39. lib.python_callback = python_callback
  42. # then this is done in class io's __init__:
  44. class io(watcher):
  45. def __init__(self, ...):
  46. self._handle = ffi.new_handle(self)
  47. self._watcher = ffi.new("my_io *")
  48. self._watcher.handle = self._handle
  49. # give the same C-level callback function to all of them
  50. self._watcher_init(self._watcher, lib.my_io_callback)
  51.  
Powered by spacepaste. Paste removal.