+ 4O|jMRt^RIHt^RIt^RIt^RIHtHtHt] !]R4t ] !]R] 4t RRlt!RR 4tR#) zSelect / poll helper) annotationsN)AnyOptionalcastpollerrorc V^8dQhRRRR/#)exc BaseExceptionreturnz Optional[int])formats"OC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\pymongo/socket_checker.py __annotate__rs}c\VR4'd\\VP4#VP'd"\\VP^,4#R#)errnoN)hasattrrintrargs)r s&r_errno_from_exceptionrsAsGC## xxxC!%% rc>]tRt^"tRRltR RRlltRRltRtR#) SocketCheckercV^8dQhRR/#)r r Noner )rs"rrSocketChecker.__annotate__#s  $ rc hV\'d\P!4VnR#RVnR#)N) _HAVE_POLLselectr_poller)selfs&r__init__SocketChecker.__init__#s :!;;=DLDLrc ,V^8dQhRRRRRRRRRR/#) r sockrreadboolwritetimeoutzOptional[float]r r )rs"rrr*s4(((#(48(KZ( (rc LVP'd\P\P,pV'd-V\P,\P ,pV'dV\P ,pVPPW4VfRMVR,pVPPV4p\V4VPPV4#V'dV.M.pV'dV.M.p \P!WV.V4p\V4# TPPT4i;i \\3d<p \T 4\P \P"39dRp ? EKhRp ? ii;i)zSelect for reads or writes with a timeout in seconds (or None). Returns True if the socket is readable/writable, False on timeout. Ni)r rPOLLERRPOLLHUPPOLLINPOLLPRIPOLLOUTregisterrr' unregisterany _SelectErrorOSErrorrrEINTREAGAIN) r!r%r&r(r)masktimeout_resrlistwlistr s &&&&& rrSocketChecker.select*s* <<<!>>FNN:D#fmm3fnnD#fnn4LL))$5 6,3?4$"ll//9 $Cy //5&*TFE&+TFE --tfgFCs8O //5!'* (-%++u||1LL sXE,E3E62E)4D7E9E E(E7EEF#(.FFF#c V^8dQhRRRR/#)r r%rr r'r )rs"rrrTs#$rc VPVRR7# \\3dh\dR#\dR#i;i)z?Return True if we know socket has been closed, False otherwise.T)r&)r RuntimeErrorKeyError ValueError Exception)r!r%s&&r socket_closedSocketChecker.socket_closedTsM ;;t$;/ /h'     sAAAAA)r N)FF)__name__ __module__ __qualname____firstlineno__r"rrC__static_attributes__r rrrr"s (Trr)__doc__ __future__rrrtypingrrrrrgetattrr4r3rrr rrrOsD" && VV $ vw0 DDr