U W[#@s@dZddlZddlZddlZddlmZddlmZmZm Z m Z ddl m Z m Z ddlmZddlmZddlmZdd lmZdd lmZmZzdd lmZWn&ek rdZd Zed Yn XejfZdZdZ e!d\Z"Z#e $dZ%e $dZ&eej'ej(ej)ej*feGdddej+ej,eZ-ddZ.ddgZ/dS)z' Reactor that uses IO completion ports N) implementer)base interfacesmainerror)logfailure)Process)_ThreadedWin32EventsMixin) iocpsupport) WAIT_TIMEOUT)tcpudp)TLSMemoryBIOFactoryz|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 ddZ d-ddZ d.ddZedk rd/ddZd0ddZnd1ddZd2d dZd3d"d#Zd4d%d&Zd'idddd(dfd)d*Zd+d,ZdS)5 IOCPReactorNcCs"tj|t|_t|_dSN)r ReactorBase__init___iocpZCompletionPortportsethandlesselfrrF/usr/lib/python3/dist-packages/twisted/internet/iocpreactor/reactor.pyr9s  zIOCPReactor.__init__cCs|j|dSr)raddrZhandlerrraddActiveHandle?szIOCPReactor.addActiveHandlecCs|j|dSr)rdiscardrrrrremoveActiveHandleCszIOCPReactor.removeActiveHandlecCsd}|dkrt}ntttd|}|j|\}}}}|tkrBq|tkrt|tksVtt |j |j ||||d7}|t kr~q|jd\}}}}q8dS)z= Poll the IO completion port for new events. rNr) MAX_TIMEOUTminintrZgetEventr KEY_WAKEUP KEY_NORMALAssertionErrorrZcallWithLoggerowner_callEventCallbackEVENTS_PER_LOOP)rtimeoutZprocessed_eventsrcnumByteskeyevtrrr doIterationGs$  zIOCPReactor.doIterationcCs|j}d}z@||||t|dd}|s0t}n|dkr>t}|rHWdSWn td}tYnX|r| t |dS)NZ getFileHandler#) r*callbackgetattr _NO_GETHANDLE _NO_FILEDESCsysexc_inforerrZloseConnectionrZFailure)rr.r/r1r*ZwhyZhandfnrrrr+ss     zIOCPReactor._callEventCallbackcCsdSrrrrrr installWakerszIOCPReactor.installWakercCs|jdtddS)Nr)rZ postEventr'rrrrwakeUpszIOCPReactor.wakeUpcCs|j|tdSr)rZ addHandler(rrrrregisterHandleszIOCPReactor.registerHandlecCst||}|||Sr)socketr=fileno)rZafstypeZsktrrr createSockets zIOCPReactor.createSocket2cCst|||||}||S)zI @see: twisted.internet.interfaces.IReactorTCP.listenTCP )r PortstartListening)rrfactorybacklog interfaceprrr listenTCPszIOCPReactor.listenTCPcCs t||||||}||S)zJ @see: twisted.internet.interfaces.IReactorTCP.connectTCP )r Z ConnectorZconnect)rhostrrFr- bindAddresscrrr connectTCPszIOCPReactor.connectTCPcCs"||t|d|||}d|_|S)zQ @see: twisted.internet.interfaces.IReactorSSL.listenSSL FZTLS)rJrZ_typerrrFcontextFactoryrGrHrrr listenSSLs zIOCPReactor.listenSSLcCs|||t|d|||S)zR @see: twisted.internet.interfaces.IReactorSSL.connectSSL T)rOrrrLrrFrQr-rMrrr connectSSLs zIOCPReactor.connectSSLcCs tddS)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.NNotImplementedErrorrPrrrrRscCs tddS)z Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. rUNrVrSrrrrTs cCst|||||}||S)z Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )rrDrE)rrprotocolrH maxPacketSizerIrrr listenUDPszIOCPReactor.listenUDPFcCs t||||||}||S)z Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )rZ MulticastPortrE)rrrYrHrZZlistenMultiplerIrrrlistenMulticasts zIOCPReactor.listenMulticastrrc Cs^|dk rtd|dk r td|r,td| dk rr8Zzope.interfacerZtwisted.internetrrrrZtwisted.pythonrrZtwisted.internet._dumbwin32procr Z"twisted.internet.win32eventreactorr Ztwisted.internet.iocpreactorr rZ"twisted.internet.iocpreactor.constr r rZtwisted.protocols.tlsr ImportErrorZ_extraInterfaceswarnZ IReactorSSLr$r,ranger(r'ZConnectionFdescWentAwayr6r7Z IReactorTCPZ IReactorUDPZIReactorMulticastZIReactorProcessZ_SignalReactorMixinrrrl__all__rrrrsJ         Z