U dA@svdZddlZddlZddlZddlmZmZeedoBej d Z e ede Z eeeddd ZGd d d ZdS) zSelect / poll helperN)AnyOptionalpolljavaerror)excreturncCs$t|dr|jS|jr |jdSdS)Nerrnor)hasattrr args)rr :/tmp/pip-unpacked-wheel-oblwsawz/pymongo/socket_checker.py_errno_from_exceptions   rc@sFeZdZddddZd eeeeeeddd Zeed d d Z dS) SocketCheckerN)rcCs|trt|_nd|_dS)N) _HAVE_POLLselectr_poller)selfr r r __init__%s zSocketChecker.__init__Fr)sockreadwritetimeoutrc Cs z|jrtjtjB}|r(|tjBtjB}|r6|tjB}|j||z.|dkrRdn|d}|j |}t |WWS|j|Xn8|r|gng}|r|gng} t|| |g|}t |WSWqt t fk r} z"t| tjtjfkrWYqW5d} ~ XYqXqdS)zSelect for reads or writes with a timeout in seconds (or None). Returns True if the socket is readable/writable, False on timeout. Ni)rrPOLLERRPOLLHUPPOLLINPOLLPRIPOLLOUTregister unregisterrboolany _SelectErrorOSErrorrr ZEINTREAGAIN) rrrrrmaskZtimeout_resZrlistZwlistrr r r r,s*    zSocketChecker.select)rrc CsXz|j|ddWSttfk r*Yn*tk r>YdStk rRYdSXdS)z?Return True if we know socket has been closed, False otherwise.T)rN)r RuntimeErrorKeyError ValueError Exception)rrr r r socket_closedVszSocketChecker.socket_closed)FFr) __name__ __module__ __qualname__rrr rfloatrr+r r r r r$s *r)__doc__r rsystypingrrr platform startswithrgetattrr#r" BaseExceptionintrrr r r r s