o i%@s`UdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z ddlmZddlmZmZmZddlmZdd lmZdd lmZmZzdd lmZWneyrdZd Z eee j!d fe"d<e#dYnweZe j!fZ dZ$dZ%e&d\Z'Z(e )dZ*e )dZ+ee j,e j-e j.e j/ge RGddde j0eZ1ddZ2ddgZ3dS)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 awayc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ de j de jde j fddZd0ddZd1ddZedurNd0ddZ d1d d!Zn d0d"dZ d1d#d!Zd2d%d&Z 'd3d(d)Zd*idddd+dfd,d-Zd.d/ZdS)4 IOCPReactorNcCs"tj|t|_t|_dSN)r ReactorBase__init___iocpZCompletionPortportsethandlesselfrrjC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/internet/iocpreactor/reactor.pyr<s   zIOCPReactor.__init__cC|j|dSr)raddrhandlerrr addActiveHandleAzIOCPReactor.addActiveHandlecCr!r)rdiscardr#rrr removeActiveHandleDr&zIOCPReactor.removeActiveHandlecCsd}|dur t}n tttd|}|j|\}}}} |tkr#dS|tkr<|tks-Jt |j |j ||||d7}|t krBdS|jd\}}}}q)z= Poll the IO completion port for new events. rNr) MAX_TIMEOUTminintrZgetEventr KEY_WAKEUP KEY_NORMALrZcallWithLoggerowner_callEventCallbackEVENTS_PER_LOOP)rtimeoutZprocessed_eventsrcnumByteskeyevtrrr doIterationGs$ zIOCPReactor.doIterationcCs|j}d}z ||||t|dd}|st}n|dkrt}|r$WdSWnty8td}t Ynw|rE| t |dSdS)NZ getFileHandler)) r/callbackgetattr _NO_GETHANDLE _NO_FILEDESC BaseExceptionsysexc_inforerrZloseConnectionrZFailure)rr3r4r6r/whyZhandfnrrr r0ss&     zIOCPReactor._callEventCallbackcCsdSrrrrrr installWakerszIOCPReactor.installWakercCs|jdtddS)Nr)rZ postEventr-rrrr wakeUpszIOCPReactor.wakeUpcCs|j|tdSr)rZ addHandler.r#rrr registerHandleszIOCPReactor.registerHandleafstypereturncCst||}|||Sr)socketrDfileno)rrErFZsktrrr createSockets zIOCPReactor.createSocket2cCt|||||}||S)zI @see: twisted.internet.interfaces.IReactorTCP.listenTCP N)r PortstartListening)rrfactorybacklog interfaceprrr listenTCPszIOCPReactor.listenTCPcCs t||||||}||S)zJ @see: twisted.internet.interfaces.IReactorTCP.connectTCP N)r Z Connectorconnect)rhostrrPr2 bindAddresscrrr connectTCPszIOCPReactor.connectTCPcCs"||t|d|||}d|_|S)zQ @see: twisted.internet.interfaces.IReactorSSL.listenSSL FZTLSN)rTr_typerrrPcontextFactoryrQrRrrr listenSSLs zIOCPReactor.listenSSLcCs|||t|d|||S)zR @see: twisted.internet.interfaces.IReactorSSL.connectSSL TN)rZrrrWrrPr]r2rXrrr connectSSLs zIOCPReactor.connectSSLcCtd)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.NNotImplementedErrorr\rrr r^scCra)z Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. rbNrcr_rrr r`s cCrM)z Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. N)r rNrO)rrprotocolrR maxPacketSizerSrrr listenUDPszIOCPReactor.listenUDPFcCs t||||||}||S)z Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. N)r Z MulticastPortrO)rrrfrRrgZlistenMultiplerSrrr listenMulticasts  zIOCPReactor.listenMulticastrrc CsN|durtd|durtd|rtd| durtdt||||||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 ) rZprocessProtocol executableargsenvpathuidgidZusePTYZchildFDsrrr spawnProcessszIOCPReactor.spawnProcesscCst|j}|j|Sr)listrclear)rresrrr removeAlls  zIOCPReactor.removeAll)rKrL)rUN)rLre)rLreF)__name__ __module__ __qualname__rrr%r(r7r0rBrCrDrH AddressFamily SocketKindrJrTrZrr^r`rhrirqrurrrr r2sL,       rcCst}t|dSr)rrZinstallReactor)rrrr installsr|)4__doc__rHr>warningstypingrrZzope.interfacerZtwisted.internetrrrrZtwisted.internet._dumbwin32procr Ztwisted.internet.iocpreactorr rr r Z"twisted.internet.iocpreactor.constr Z"twisted.internet.win32eventreactorrZtwisted.pythonrrZtwisted.protocols.tlsrZ_TLSMemoryBIOFactory ImportErrorrZ IReactorSSL__annotations__warnr*r1ranger.r-ZConnectionFdescWentAwayr;r<Z IReactorTCPZ IReactorUDPZIReactorMulticastZIReactorProcessrrr|__all__rrrr sP         b