python-netfilterqueue run2

gistfile1.txt

    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()