netstream.py 文件源码

def assign(self, sock, head = -1, block = False):
        self.close()
        self.block = block
        self.sock = sock
        self.sock.setblocking(self.block and 1 or 0)
        self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
        self.state = NET_STATE_ESTABLISHED
        if head >= 0 and head <= 14:
            self.__head_init(head)
        self.send_buf = ''
        self.recv_buf = ''
        return 0

    # update