Advertisement
Guest User

Untitled

a guest
Jun 28th, 2016
62
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.45 KB | None | 0 0
  1. def run2(self):
  2. "Version of the run method which uses normal socket.recv so that gevent can monkeypatch it"
  3. import socket
  4. cdef int fd = nfq_fd(self.h)
  5. s = socket.fromfd(fd, socket.AF_UNIX, socket.SOCK_STREAM)
  6. while True:
  7. d = s.recv(BufferSize)
  8. d_len = len(d)
  9. if d_len >= 0:
  10. nfq_handle_packet(self.h, d, d_len)
  11. else:
  12. break
  13. s.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement