o 'h@s|dZddlmZddlZddlZddlZddlmZmZm Z e edo)ej d Z eedeZdd d ZGdddZdS)zSelect / poll helper) annotationsN)AnyOptionalcastpolljavaerrorexc BaseExceptionreturn Optional[int]cCs0t|dr tt|jS|jrtt|jdSdS)Nerrnor)hasattrrintr args)r rR/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/socket_checker.py_errno_from_exceptions  rc@s.eZdZdddZ ddddZdddZdS) SocketCheckerr NonecCs |tr t|_dSd|_dS)N) _HAVE_POLLselectr_poller)selfrrr__init__&s zSocketChecker.__init__FrsockrreadboolwritetimeoutOptional[float]c Cs za|jrGtjtjB}|r|tjBtjB}|r|tjB}|j||z|dur*dn|d}|j|}t |W|j |WS|j |w|rL|gng}|rS|gng} t|| |g|}t |WSt t fy} zt| tjtjfvr|WYd} ~ qd} ~ ww)zSelect for reads or writes with a timeout in seconds (or None). Returns True if the socket is readable/writable, False on timeout. TNi)rrPOLLERRPOLLHUPPOLLINPOLLPRIPOLLOUTregisterrr unregisterany _SelectErrorOSErrorrr EINTREAGAIN) rrrrrmasktimeout_resrlistwlistr rrrr-s0     zSocketChecker.selectc CsJz|j|ddWSttfytyYdSty$YdSw)z?Return True if we know socket has been closed, False otherwise.T)r)r RuntimeErrorKeyError ValueError Exception)rrrrr socket_closedWs  zSocketChecker.socket_closedN)r r)FFr) rrrrrrrr r r)rrr r)__name__ __module__ __qualname__rrr6rrrrr%s   *r)r r r r )__doc__ __future__rr rsystypingrrrrplatform startswithrgetattrr*r)rrrrrrs