3 O6br@s\dZddlZddlZddlZeedo2ejjd Zeede Z ddZ Gdd d e Z dS) zSelect / poll helperNpolljavaerrorcCs$t|dr|jS|jr |jdSdS)Nerrnor)hasattrrargs)excr U/var/www/html/sandeepIITI/myenv/lib/python3.6/site-packages/pymongo/socket_checker.py_errno_from_exceptions   r c@s&eZdZddZd ddZddZd S) SocketCheckercCstrtj|_nd|_dS)N) _HAVE_POLLselectr_poller)selfr r r __init__%s zSocketChecker.__init__Frc Csxy|jrtjtjB}|r*|tjBtjB}|r8|tjB}|jj||z(|dkrTdn|d}|jj|}t |S|jj |Xn6|r|gng}|r|gng} tj|| |g|}t |SWqt t fk r} zt| tjtjfkrwWYdd} ~ XqXqWdS)zSelect for reads or writes with a timeout in seconds (or None). Returns True if the socket is readable/writable, False on timeout. Ni)rrPOLLERRPOLLHUPPOLLINPOLLPRIPOLLOUTregisterrbool unregisterany _SelectErrorIOErrorr rZEINTREAGAIN) rsockreadwritetimeoutmaskZtimeout_resZrlistZwlistrr r r r+s,    zSocketChecker.selectc CsRy|j|ddSttfk r(Yn&tk r:dStk rLdSXdS)zHReturn True if we know socket has been closed, False otherwise. T)rN)r RuntimeErrorKeyError ValueError Exception)rrr r r socket_closedRszSocketChecker.socket_closedN)FFr)__name__ __module__ __qualname__rrr(r r r r r #s 'r )__doc__rrsysrplatform startswithr getattrOSErrorrr objectr r r r r s