Method recv

src/network/asyncore_pollchoose.py:659–677

(self, buffer_size)

                raise

    def recv(self, buffer_size):
        try:
            data = self.socket.recv(buffer_size)
            if not data:
                # a closed connection is indicated by signaling
                # a read condition, and having recv() return 0.
                self.handle_close()
                return b''
            else:
                return data
        except socket.error as why:
            # winsock sometimes raises ENOTCONN
            if why.args[0] in (EAGAIN, EWOULDBLOCK, WSAEWOULDBLOCK):
                return b''
            if why.args[0] in _DISCONNECTED:
                self.handle_close()
                return b''
            else:
                raise

    def close(self):
        self.connected = False