U n5{i%@s`UdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z ddlmZddlmZmZmZddlmZdd lmZdd lmZmZzdd lmZWn<ek rdZd Z eee j!d fe"d<e#dYnXeZe j!fZ dZ$dZ%e&d\Z'Z(e )dZ*e )dZ+ee j,e j-e j.e j/fe Gddde 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 e j e je j dddZd.ddZd/ddZedk rd0ddZd1ddZnd2d dZd3d!dZd4d#d$Zd5d&d'Zd(idddd)dfd*d+Zd,d-ZdS)6 IOCPReactorNcCs"tj|t|_t|_dSN)r ReactorBase__init___iocpZCompletionPortportsethandlesselfrrH/tmp/pip-unpacked-wheel-mnhg7r0q/twisted/internet/iocpreactor/reactor.pyr<s  zIOCPReactor.__init__cCs|j|dSr)raddrhandlerrr addActiveHandleAszIOCPReactor.addActiveHandlecCs|j|dSr)rdiscardr"rrr removeActiveHandleDszIOCPReactor.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(tk rrtd}t YnX|r| t |dS)NZ getFileHandler') r.callbackgetattr _NO_GETHANDLE _NO_FILEDESC BaseExceptionsysexc_inforerrZloseConnectionrZFailure)rr2r3r5r.whyZhandfnrrr r/ss     zIOCPReactor._callEventCallbackcCsdSrrrrrr installWakerszIOCPReactor.installWakercCs|jdtddS)Nr)rZ postEventr+rrrr wakeUpszIOCPReactor.wakeUpcCs|j|tdSr)rZ addHandler,r"rrr registerHandleszIOCPReactor.registerHandle)afstypereturncCst||}|||Sr)socketrCfileno)rrDrEZsktrrr 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 Connectorconnect)rhostrrNr1 bindAddresscrrr connectTCPszIOCPReactor.connectTCPcCs"||t|d|||}d|_|S)zQ @see: twisted.internet.interfaces.IReactorSSL.listenSSL FZTLS)rRr_typerrrNcontextFactoryrOrPrrr listenSSLs zIOCPReactor.listenSSLcCs|||t|d|||S)zR @see: twisted.internet.interfaces.IReactorSSL.connectSSL T)rXrrrUrrNr[r1rVrrr 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.NNotImplementedErrorrZrrr r\scCs tddS)z Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. r_Nr`r]rrr r^s cCst|||||}||S)z Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )r rLrM)rrprotocolrP maxPacketSizerQrrr listenUDPszIOCPReactor.listenUDPFcCs t||||||}||S)z Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )r Z MulticastPortrM)rrrcrPrdZlistenMultiplerQrrr listenMulticasts zIOCPReactor.listenMulticastrrc CsN|dk rtd|dk r td|r,td| dk rsL        b