mbus.py 文件源码

def start(self):
        packer = msgpack.Packer()
        unpacker = msgpack.Unpacker()
        buf = bytearray(1000000)
        mv = memoryview(buf)
        while True:
            # fixme: switch to buffer object
            #buf = self._sock.recv(1024*1024)
            amt = self._sock.recv_into(buf, 1000000)
            if not buf:
                # fixme: HANDLE THIS
                break

            #print len(buf), buf

            unpacker.feed(mv[:amt])
            for m in unpacker:
                rep = self._rep_handler(m)
                self._sock.sendall(packer.pack(rep)) # fixme: handle error