def evt_read(self):
if self.__is_listen_socket:
self.tcp_accept()
return
if self.__is_async_socket_client and not self.is_conn_ok():
self.__conn_ev_flag = 1
return
while 1:
try:
recv_data = self.socket.recv(4096)
if not recv_data:
self.error()
break
self.reader._putvalue(self.handle_tcp_received_data(recv_data))
except BlockingIOError:
self.tcp_readable()
break
except ConnectionResetError:
self.error()
break
except ConnectionError:
self.error()
break
''''''
return
评论列表
文章目录