def _fill_recv_buf(self):
self.ssl_write = None
start_len = len(self.recv_buf)
while True:
try:
nbuf = self.sock.recv(16384)
if len(nbuf) == 0:
break
else:
self.recv_buf += nbuf
except SSL.WantReadError:
start_len = -1
break
except SSL.WantWriteError:
self.ssl_write = True
break
except:
break
if len(self.recv_buf) == start_len:
self.close()
评论列表
文章目录