>Mc@sdZddlZddlZddlZddlmZddlmZmZm Z m Z ddl m Z m Z ddlmZddlmZddlmZdd lmZmZydd lmZWn*ek rdZdZejd n XejfZdd lmZd Z dZ!e"d\Z#Z$e j%dZ&e j%dZ'dej(ej)fdYZ*dZ+ddgZ,dS(s' Reactor that uses IO completion ports iN(t implements(tbaset interfacestmainterror(tlogtfailure(tProcess(t iocpsupport(t WAIT_TIMEOUT(ttcptudp(tTLSMemoryBIOFactorys|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor will not support SSL APIs.(tsetiiis#Handler has no getFileHandle methodsFiledescriptor went awayt IOCPReactorcBs2eZeejejejejedZ dZ dZ dZ dZdZdZdZdZdZd d d Zd dd Zedk rd d dZd ddZnd d dZd ddZd ddZd dedZdiddddddZdZRS(cCs/tjj|tj|_t|_dS(N(Rt ReactorBaset__init__t_iocptCompletionPorttportR thandles(tself((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyR8scCs|jj|dS(N(Rtadd(Rthandle((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytaddActiveHandle>scCs|jj|dS(N(Rtdiscard(RR((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytremoveActiveHandleBscCsd}|dkrt}ntttd|}|jj|\}}}}x|tkrePn|tkr|tkst t j |j |j ||||d7}n|tkrPn|jjd\}}}}qUdS(s= Poll the IO completion port for new events. iiiN(tNonet MAX_TIMEOUTtmintintRtgetEventR t KEY_WAKEUPt KEY_NORMALtAssertionErrorRtcallWithLoggertownert_callEventCallbacktEVENTS_PER_LOOP(Rttimeouttprocessed_eventstrctbytestkeytevt((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt doIterationFs        cCs|j}d}yZ|j|||t|dd}|sFt}n|dkr^t}n|rhdSWn!tjd}tj nX|r|j t j |ndS(Nt getFileHandleii( R$Rtcallbacktgetattrt _NO_GETHANDLEt _NO_FILEDESCtsystexc_infoRterrtloseConnectionRtFailure(RR)R*R,R$twhythandfn((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyR%rs    cCsdS(N((R((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt installWakerscCs|jjdtddS(Ni(Rt postEventR R(R((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytwakeUpscCs|jj|tdS(N(Rt addHandleR!(RR((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytregisterHandlescCs)tj||}|j|j|S(N(tsocketR>tfileno(Rtaftstypetskt((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt createSocketsi2tcCs)tj|||||}|j|S(sI @see: twisted.internet.interfaces.IReactorTCP.listenTCP (R tPorttstartListening(RRtfactorytbacklogt interfacetp((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt listenTCPs icCs,tj||||||}|j|S(sJ @see: twisted.internet.interfaces.IReactorTCP.connectTCP (R t Connectortconnect(RthostRRHR't bindAddresstc((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt connectTCPs cCs"|j|t|t|||S(sQ @see: twisted.internet.interfaces.IReactorSSL.listenSSL (RLR tFalse(RRRHtcontextFactoryRIRJ((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt listenSSLscCs%|j||t|t|||S(sR @see: twisted.internet.interfaces.IReactorSSL.connectSSL (RRR tTrue(RRORRHRTR'RP((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt connectSSLscCstddS(s Non-implementation of L{IReactorSSL.listenSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. s|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor does not support SSL APIs.N(tNotImplementedError(RRRHRTRIRJ((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyRUscCstddS(s Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. s|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor does not support SSL APIs.N(RX(RRORRHRTR'RP((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyRWsi cCs)tj|||||}|j|S(s Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. (R RFRG(RRtprotocolRJt maxPacketSizeRK((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt listenUDPs cCs,tj||||||}|j|S(s Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. (R t MulticastPortRG(RRRYRJRZtlistenMultipleRK((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytlistenMulticasts   ic Cs|dk rtdn|dk r6tdn|rKtdn| dk rftdn|j||\}}t||||||S(s" Spawn a process. s,Setting UID is unsupported on this platform.s,Setting GID is unsupported on this platform.s&PTYs are unsupported on this platform.sGCustom child file descriptor mappings are unsupported on this platform.N(Rt ValueErrort_checkProcessArgsR( RtprocessProtocolt executabletargstenvtpathtuidtgidtusePTYtchildFDs((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt spawnProcesss    cCs t|j}|jj|S(N(tlistRtclear(Rtres((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyt removeAlls N((t__name__t __module__RRt IReactorTCPt IReactorUDPtIReactorMulticasttIReactorProcesst_extraInterfacesRRRRRR-R%R:R<R>RDRLRRR RURWR[RSR^RjRn(((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyR1s4     ,             cCst}tj|dS(N(RRtinstallReactor(tr((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pytinstall s Rx((-t__doc__twarningsR?R3tzope.interfaceRttwisted.internetRRRRttwisted.pythonRRttwisted.internet._dumbwin32procRttwisted.internet.iocpreactorRRt"twisted.internet.iocpreactor.constR R R ttwisted.protocols.tlsR t ImportErrorRRutwarnt IReactorSSLttwisted.python.compatR RR&trangeR!R tConnectionFdescWentAwayR1R2t_SignalReactorMixinRRRxt__all__(((sH/usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/reactor.pyts4$"