Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def run2(self):
- "Version of the run method which uses normal socket.recv so that gevent can monkeypatch it"
- import socket
- cdef int fd = nfq_fd(self.h)
- s = socket.fromfd(fd, socket.AF_UNIX, socket.SOCK_STREAM)
- while True:
- d = s.recv(BufferSize)
- d_len = len(d)
- if d_len >= 0:
- nfq_handle_packet(self.h, d, d_len)
- else:
- break
- s.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement