@@ -1207,26 +1207,26 @@ def check(): # Check that connection is alive
12071207 if exc .errno == errno .EBADF :
12081208 return errno .ECONNRESET
12091209 return exc .errno
1210+
1211+ if os .name == 'nt' :
1212+ flag = socket .MSG_PEEK
1213+ self ._socket .setblocking (False )
12101214 else :
1211- if os .name == 'nt' :
1212- flag = socket .MSG_PEEK
1213- self ._socket .setblocking (False )
1214- else :
1215- flag = socket .MSG_DONTWAIT | socket .MSG_PEEK
1216- retbytes = self ._sys_recv (sock_fd , buf , 1 , flag )
1217-
1218- err = 0
1219- if os .name != 'nt' :
1220- err = ctypes .get_errno ()
1221- else :
1222- err = ctypes .get_last_error ()
1223- self ._socket .setblocking (True )
1224-
1225- if (retbytes < 0 ) and err in (errno .EAGAIN , errno .EWOULDBLOCK , WWSAEWOULDBLOCK ):
1226- ctypes .set_errno (0 )
1227- return errno .EAGAIN
1228- else :
1229- return errno .ECONNRESET
1215+ flag = socket .MSG_DONTWAIT | socket .MSG_PEEK
1216+ retbytes = self ._sys_recv (sock_fd , buf , 1 , flag )
1217+
1218+ err = 0
1219+ if os .name != 'nt' :
1220+ err = ctypes .get_errno ()
1221+ else :
1222+ err = ctypes .get_last_error ()
1223+ self ._socket .setblocking (True )
1224+
1225+ if (retbytes < 0 ) and err in (errno .EAGAIN , errno .EWOULDBLOCK , WWSAEWOULDBLOCK ):
1226+ ctypes .set_errno (0 )
1227+ return errno .EAGAIN
1228+
1229+ return errno .ECONNRESET
12301230
12311231 last_errno = check ()
12321232 if self .connected and last_errno == errno .EAGAIN :
@@ -1561,7 +1561,7 @@ def _join_v17(self, server_uuid):
15611561 yield resp
15621562 if resp .code >= REQUEST_TYPE_ERROR :
15631563 return
1564- elif resp .code == REQUEST_TYPE_OK :
1564+ if resp .code == REQUEST_TYPE_OK :
15651565 if state == JoinState .HANDSHAKE :
15661566 state = JoinState .INITIAL
15671567 elif state == JoinState .INITIAL :
0 commit comments