³ò àŸÔPc @€s dZddklZddkZddkZeiƒddkZddkZddkZddk Z eiƒZ ei ƒZ e adefd„ƒYZeƒZddd„Zddd„Zd„Zd „Zddd „Zd „Zd „Zd „Zd„ZdS(sÏ This module lets you execute things later within the primary gamethread. It provides access to queues and delayed command management such that you can interact safely with the server from external threads. iÿÿÿÿ(twith_statementNtTimeSortedQueuecB€sxeZdefd„ƒYZd„Zd„Zd d d d„Zd„Zd„Z d„Z d„Z d „Z d „Z RS( tTimeNodecB€seZd„Zd„ZRS(cC€s%||_t|ƒ|_||_dS(N(tnametfloattgotimetcmd(tselfRRR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt__init__s cC€s>|i|ijodSn |i|ijodSndSdS(Niÿÿÿÿii(R(Rtb((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt__cmp__s (t__name__t __module__RR (((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyRs cC€sg|_tiƒ|_dS(N(tnodest threadingtLocktlock(R((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyR!s cC€s:|ii}iƒzti|i|ƒWd|~QXdS(N(Rt__exit__t __enter__tbisecttinsortR (Rtnodet_[1]((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytaddNode$scC€sMt|tƒp |f}n|i|i||||phf|ƒƒdS(N(t isinstancettupleRR(RRRtargstkwR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytadd's cC€sD|ii}iƒz!|io|idSndSWd|~QXdS(Ni(RRRR tNone(RR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytgetFirst+s cC€s.|ii}iƒz |iSWd|~QXdS(N(RRRR (RR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytgetList1sc€sTˆpdSn|ii}iƒz"t‡fd†|iƒ|_Wd|~QXdS(Nc€s |iˆjS((R(ti(R(sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt7s(RRRtfilterR (RRR((RsQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt removeByName4scC€sK|ii}iƒz(||ijo|ii|ƒnWd|~QXdS(N(RRRR tremove(RtitemR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyR$8scC€s5|ii}iƒzt|iƒ SWd|~QXdS(N(RRRtboolR (RR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytempty<sc C€sk|ii}iƒzHxA|iD]6}tidd|i|itiƒ|i fƒq!WWd|~QXdS(Nis#[%8s] in %s seconds from now, %s ( RRRR testdbgmsgRRttimeR(RRR ((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt printQueue?s (N(R R tobjectRRRRRRRR#R$R'R+(((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyRs       cC€s+tƒtitiƒ||||ƒdS(sä Executes a Python function at a later time. Requires a map to be started on the server (and ticks to be firing). Args can be passed in as a tuple, or as keyword argments. This is like a Python-based es_delayed. N(tregisterTickerttimeqRR*(tsecondsRRR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytdelayedKscC€s.tƒtitiƒ|||||ƒdS(s{ Executes a Python function at a later time. Requires a map to be started on the server (and ticks to be firing). Args can be passed in as a tuple, or as keyword argments. This is like a Python-based es_delayed. Use delayedname if you want to provide an identifier that can be used with cancelDelayed(identifier) to stop the execution before it happens. N(R-R.RR*(R/RRRR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt delayednameTs cC€sti|ƒdS(sH Cancel a command by name that was scheduled with delayedname() N(R.R#(R((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt cancelDelayed`scC€stiƒdS(s2 Print the contents of the delayed queue. N(R.R+(((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt listDelayedfscC€sEtƒt|tƒp |f}nti|||phfƒdS(sã Queue a command to be run on the very next tick. Requires a map be started on the server (and ticks to be firing). Args can be passed in as a tuple, or as keyword argments. This is like a Python-based es_soon. N(R-RRtqtput(tfunctiontaR((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytqueuels cC€sEti}iƒz%tptatiitƒnWd|~QXdS(sl Internal use recommended. Registers a ticklistener for the gamethread usage if one isn't registered. N( t register_lockRRttickregtTrueR(taddonstregisterTickListenerttick(R((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyR-|scC€sEti}iƒz%totatiitƒnWd|~QXdS(sk Internal use recommended. Unregisters a ticklistener for the gamethread usage if one is configured. N( R9RRR:tFalseR(R<tunregisterTickListenerR>(R((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pytunregisterTicker‡scC€s8|i\}}}ti|ƒz|||ŽWdXdS(si Internal use recommended. Helper function to execute and then remove an item from the gameq N(RR.R$(RR6R7R((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyt _executenode“s  cC€sãx4tiƒp&tiƒ\}}}|||ŽqWtiƒ}|optiƒ}|i|joPt|ƒtti ƒƒ}x1|D]%}|i|jot|ƒq‰Pq‰Wqºntiƒotiƒo t ƒndS(s# Internal use recommended. N( R4R'tgetR.RR*RRBtlistRRA(R6R7Rtfirsttnowttasksttask((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyR> s     ((((t__doc__t __future__RR(tpsycotfullR*tQueueRRR4RR9R?R:R,RR.RR0R1R2R3R8R-RARBR>(((sQ/home/saberrider/srcds/css/cstrike/addons/eventscripts/_libs/python/gamethread.pyss,         1