tf$UdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z ddlmZddlmZmZmZddlmZdd lmZdd lmZmZ dd lmZeZe jfZ n7#e!$r/dZd Z eee jd fe"d<ej#dYnwxYwdZ$dZ%e&d\Z'Z(e j)dZ*e j)dZ+ee j,e j-e j.e j/ge RGdde j0eZ1dZ2ddgZ3dS)z' Reactor that uses IO completion ports N)TupleType) implementer)baseerror interfacesmain)Process) iocpsupporttcpudp) WAIT_TIMEOUT)_ThreadedWin32EventsMixin)failurelog)TLSMemoryBIOFactory._extraInterfacesz|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor will not support SSL APIs.iz#Handler has no getFileHandle methodzFiledescriptor went awayceZdZdZdZdZdZdZdZdZ dZ d Z d Z dd Z ddZe ddZ ddZn ddZ ddZddZ ddZdidddddfdZdZdS) IOCPReactorNctj|tj|_t |_dSN)r ReactorBase__init___iocpCompletionPortportsethandlesselfs c/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/internet/iocpreactor/reactor.pyrzIOCPReactor.__init__<s8 !!$'''(** uu c:|j|dSr)r!addr#handles r$addActiveHandlezIOCPReactor.addActiveHandleAs      r%c:|j|dSr)r!discardr(s r$removeActiveHandlezIOCPReactor.removeActiveHandleDs V$$$$$r%cd}|t}n%tttd|z}|j|\}}}} |t krdS|t kr4|tksJtj |j |j ||||dz }|tkrdS|jd\}}}}y)z= Poll the IO completion port for new events. rNr) MAX_TIMEOUTminintrgetEventr KEY_WAKEUP KEY_NORMALrcallWithLoggerowner_callEventCallbackEVENTS_PER_LOOP)r#timeoutprocessed_eventsrcnumByteskeyevts r$ doIterationzIOCPReactor.doIterationGs2 ?!GG+s4'>':':;;G!%!3!3G!>#NE7CC D DJKr%c R|||t|d|||S)zR @see: twisted.internet.interfaces.IReactorSSL.connectSSL T)rprr#rmrrdrur:rns r$ connectSSLzIOCPReactor.connectSSLs5 ??#ND'BB  r%c td)z Non-implementation of L{IReactorSSL.listenSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. |pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor does not support SSL APIs.NotImplementedErrorrts r$rvzIOCPReactor.listenSSLs & r%c td)z Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. r{r|rxs r$ryzIOCPReactor.connectSSLs& r% c^tj|||||}||S)z Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )r rbrc)r#rprotocolrf maxPacketSizergs r$ listenUDPzIOCPReactor.listenUDPs2 HT8Y t D D r%Fc`tj||||||}||S)z Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )r MulticastPortrc)r#rrrfrlistenMultiplergs r$listenMulticastzIOCPReactor.listenMulticasts<   (I}dN   r%rrc |td|td|rtd| tdt||||||S)z" Spawn a process. Nz,Setting UID is unsupported on this platform.z,Setting GID is unsupported on this platform.z&PTYs are unsupported on this platform.zGCustom child file descriptor mappings are unsupported on this platform.) ValueErrorr ) r#processProtocol executableargsenvpathuidgidusePTYchildFDss r$ spawnProcesszIOCPReactor.spawnProcesss{ ?KLL L ?KLL L  GEFF F  ! t_j$TJJJr%c`t|j}|j|Sr)listr!clear)r#ress r$ removeAllzIOCPReactor.removeAlls*4<    r%)r_r`)riN)r`r)r`rF)__name__ __module__ __qualname__rrr*r-r@r8rQrTrWr^rhrprrvryrrrrrr%r$rr2s D !!!%%%*;*;*;X777$   111000 &    PT         PT    PU(    KKKK8r%rcJt}tj|dSr)rr installReactor)rs r$installrs" Ar%r)4__doc__rYrIwarningstypingrrzope.interfacertwisted.internetrrrr twisted.internet._dumbwin32procr twisted.internet.iocpreactorr rr r "twisted.internet.iocpreactor.constr"twisted.internet.win32eventreactorrtwisted.pythonrrtwisted.protocols.tlsr_TLSMemoryBIOFactory IReactorSSLr ImportError__annotations__warnr0r9ranger5r4ConnectionFdescWentAwayrFrG IReactorTCP IReactorUDPIReactorMulticastIReactorProcessrrr__all__rr%r$rsi   &&&&&&::::::::::::333333GGGGGGGGGG;;;;;;HHHHHH'''''''' 1QQQQQQ/".0BDeD!78#=>CCCHM C  q J--.STT ,u,-GHH      \\\\\$"$=\\\~ ) $sA 1BB