[XMc@s.dZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z m Z ddl mZmZmZmZddlZddlmZddlmZmZmZdd lmZmZdd lmZdd lmZd ejfd YZ dZ!d dgZ"dS(s A win32event based implementation of the Twisted main loop. This requires pywin32 (formerly win32all) or ActivePython to be installed. To install the event loop (and you should do this before any connections, listeners or connectors are added):: from twisted.internet import win32eventreactor win32eventreactor.install() Maintainer: Itamar Shtull-Trauring LIMITATIONS: 1. WaitForMultipleObjects and thus the event loop can only handle 64 objects. 2. Process running has some problems (see Process docstring). TODO: 1. Event loop handling of writes is *very* problematic (this is causing failed tests). Switch to doing it the correct way, whatever that means (see below). 2. Replace icky socket loopback waker with event based waker (use dummyEvent object) 3. Switch everyone to using Free Software so we don't have to deal with proprietary APIs. ALTERNATIVE SOLUTIONS: - IIRC, sockets can only be registered once. So we switch to a structure like the poll() reactor, thus allowing us to deal with write events in a decent fashion. This should allow us to pass tests, but we're still limited to 64 events. Or: - Instead of doing a reactor, we make this an addon to the select reactor. The WFMO event loop runs in a separate thread. This means no need to maintain separate code for networking, 64 event limit doesn't apply to sockets, we can run processes and other win32 stuff in default event loop. The only problem is that we're stuck with the icky socket based waker. Another benefit is that this could be extended to support >64 events in a simpler manner than the previous solution. The 2nd solution is probably what will get implemented. iN(t implements(tWSAEventSelecttFD_READtFD_CLOSEt FD_ACCEPTt FD_CONNECT(t CreateEventtMsgWaitForMultipleObjects(t WAIT_OBJECT_0t WAIT_TIMEOUTt QS_ALLINPUTt QS_ALLEVENTS(t posixbase(tlogt threadabletfailure(t IReactorFDSettIReactorProcess(tIReactorWin32Events(tProcesst Win32ReactorcBseZdZeeeeeddddZ dZ dZ dZ dZ dZdZdZd Zd Zd Zd Zd ZdZdZeZdiddddddZRS(s Reactor that uses Win32 event APIs. @ivar _reads: A dictionary mapping L{FileDescriptor} instances to a win32 event object used to check for read events for that descriptor. @ivar _writes: A dictionary mapping L{FileDescriptor} instances to a arbitrary value. Keys in this dictionary will be given a chance to write out their data. @ivar _events: A dictionary mapping win32 event object to tuples of L{FileDescriptor} instances and event masks. icCs/i|_i|_i|_tjj|dS(N(t_readst_writest_eventsR tPosixReactorBaset__init__(tself((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyRZs   cCs<tdddd}t|||||f|j|<|S(s9 Make a win32 event object for a socket. iN(RtNoneRR(Rtfdtactiontwhytevent((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyt_makeSocketEventascCs||f|j|||jkr:|j|dttBtBtB|j|tj}|r|jd |jdSnY|tkr|tt|kr|j||t\}}tj ||j||ndS( NtchanneltsystemRt iterationtreactoridig@@ii(R tmsgRtintRRttimetsleepR,tcallWithLoggert _runWritet dummyEventRR R R Rtlentwin32guitPumpWaitingMessagest callLatertstopt _runAction(RttimeouttcanDoMoreWritesRthandlestvaltexitR((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pytdoWaitForMultipleEventss2      "cCsd}y|j}Wn!tjd}tjnX|r|j||j|y|jtj |WqtjqXn|dkrdSdS(Nii( tdoWritetsystexc_infoR tdeferrR(R)tconnectionLostRtFailureR(RRtclosed((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyR8s   cCs`yt||}Wn!tjd}tjnX|r\|j|||dkndS(NiR#(tgetattrRGRHR RIt_disconnectSelectable(RRRRL((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyR?sc Cs|dk rtdn|dk r6tdn|rKtdn| dk rftdn|j||\}}t||||||S(sSpawn 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((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyt spawnProcesss    N((t__name__t __module__t__doc__RRRRRRR9RR R!R"R%R'R(R)R+R-R.RER8R?t doIterationRZ(((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyRHs&            "  cCs3tjdt}ddl}|j|dS(Nii(RtinitRtmaintinstallReactor(trR`((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pytinstalls   Rc(#R]R5RGtzope.interfaceRt win32fileRRRRRt win32eventRRRR R R R;ttwisted.internetR ttwisted.pythonR RRttwisted.internet.interfacesRRRttwisted.internet._dumbwin32procRRRRct__all__(((sF/usr/lib/python2.7/dist-packages/twisted/internet/win32eventreactor.pyt0s  ("