֛h%J%SrSSKrSSKrSSKrSSKJrJr SSKJr SSK J r J r J r J r SSKJr SSKJrJrJr SSKJr SS KJr SS KJrJr SS KJr \r\ R>4r Sr$Sr%\&"S5ur'r(\ RR"S5r*\ RR"S5r+\"\ RX\ RZ\ R\\ R^/\ Q76"SS\ R`\55r1Sr2SS/r3g!\!a0 SrS r \\\ R>S 4\"S'\RF"S5 Nf=f)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\rSrSrSrSrSrSrSrSr Sr S r S r S \ RS \ RS \ R4SjrSSjrSSjr\b SSjrSSjrO SSjrSSjrSSjrSSjrS0SSSSS4SjrSrSrg) IOCPReactor2Nc[RRU5 [R"5Ul[ 5UlgN)r ReactorBase__init___iocpCompletionPortportsethandlesselfs hC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/iocpreactor/reactor.pyrIOCPReactor.__init__<s/ !!$'((* u c:URRU5 gr)r"addr$handles r%addActiveHandleIOCPReactor.addActiveHandleAs  r'c:URRU5 gr)r"discardr*s r%removeActiveHandleIOCPReactor.removeActiveHandleDs V$r'cSnUc[nO[[[SU-55nURR U5up4pVU[ :XagU[ :wa>U[:Xde[R"URURX4U5 US- nU[:agURR S5up4pVM~)z- Poll the IO completion port for new events. rNr) MAX_TIMEOUTminintr getEventr KEY_WAKEUP KEY_NORMALrcallWithLoggerowner_callEventCallbackEVENTS_PER_LOOP)r$timeoutprocessed_eventsrcnumByteskeyevts r% doIterationIOCPReactor.doIterationGs2 ?!G+s4'>':;G!%!3!3G!<c\!j j(((""IIt66c!A% ?2%)YY%7%7%: "B#r'cURnSnURXU5 [USS5nU(d[nOU"5S:Xa[nU(agU(a&UR[R"U55 gg![ a0 [ R"5Sn[R"5 Ngf=f)N getFileHandler3) r;callbackgetattr _NO_GETHANDLE _NO_FILEDESC BaseExceptionsysexc_inforerrloseConnectionrFailure)r$r@rArCr;whyhandfns r%r<IOCPReactor._callEventCallbackss   LLs +UOT:F#R"   !5 6  ,,.#C GGI sAB7B?>B?cgrrr#s r% installWakerIOCPReactor.installWakers r'cFURRS[S5 g)Nr)r postEventr8r#s r%wakeUpIOCPReactor.wakeUps Az40r'cDURRU[5 gr)r addHandler9r*s r%registerHandleIOCPReactor.registerHandles FJ/r'afstypereturncp[R"X5nURUR55 U$r)socketr_fileno)r$rarbskts r% createSocketIOCPReactor.createSockets+mmB& CJJL) r'cV[R"XX4U5nUR5 U$)z9 @see: twisted.internet.interfaces.IReactorTCP.listenTCP )r PortstartListening)r$r factorybacklog interfaceps r% listenTCPIOCPReactor.listenTCPs' HHTG = r'cV[R"XX4XP5nUR5 U$)z: @see: twisted.internet.interfaces.IReactorTCP.connectTCP )r Connectorconnect)r$hostr rmr> bindAddresscs r% connectTCPIOCPReactor.connectTCPs$ MM$g J r'cRURU[USU5UU5nSUlU$)z9 @see: twisted.internet.interfaces.IReactorSSL.listenSSL FTLS)rqr_typer$r rmcontextFactoryrnros r% listenSSLIOCPReactor.listenSSLs5>>#NE7C D DJKr'c BURUU[USU5UU5$)z: @see: twisted.internet.interfaces.IReactorSSL.connectSSL T)ryrr$rvr rmrr>rws r% connectSSLIOCPReactor.connectSSLs- ??#ND'B  r'c[S5e)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.NotImplementedErrorr~s r%rrs & r'c[S5e)z Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. rrrs r%rrs& r'cV[R"XX4U5nUR5 U$)zx Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )r rkrl)r$r protocolro maxPacketSizerps r% listenUDPIOCPReactor.listenUDPs' HHTYt D r'cV[R"XX4X5nUR5 U$)z Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )r MulticastPortrl)r$r rrorlistenMultiplerps r%listenMulticastIOCPReactor.listenMulticasts.    Id  r'rrc Ub [S5eUb [S5eU(a [S5eU b [S5e[XX#XE5$)z Spawn a process. z,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% spawnProcessIOCPReactor.spawnProcesss^ ?KL L ?KL L EF F  ! tjJJr'cd[UR5nURR5 U$r)listr"clear)r$ress r% removeAllIOCPReactor.removeAlls%4<<   r')r"r )r)N)r )rrF)__name__ __module__ __qualname____firstlineno__r rr,r0rDr<rWr[r_re AddressFamily SocketKindrhrqryrrrrrrr__static_attributes__rr'r%rr2s D !%*;X7$ 10&&/5/@/@ & PT  PT PU(    K8r'rcD[5n[R"U5 gr)rr installReactor)rs r%installrs Ar'r)4__doc__rerNwarningstypingrrzope.interfacertwisted.internetrrrr twisted.internet._dumbwin32procr twisted.internet.iocpreactorr rr r "twisted.internet.iocpreactor.constr"twisted.internet.win32eventreactorrtwisted.pythonrrtwisted.protocols.tlsr_TLSMemoryBIOFactory IReactorSSLr ImportError__annotations__warnr4r=ranger9r8ConnectionFdescWentAwayrKrL IReactorTCP IReactorUDPIReactorMulticastIReactorProcessrrr__all__rr'r%rsH   &::3GG;H' 1Q/"..0 q J--.ST ,,-GH       ^$""$=^^B ) $KBDeD!7!78#=>C MM C sC,,3D"!D"