403Webshell
Server IP : 61.19.30.66  /  Your IP : 216.73.216.15
Web Server : Apache/2.2.22 (Ubuntu)
System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64
User : www-data ( 33)
PHP Version : 5.3.10-1ubuntu3.48
Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,
MySQL : ON  |  cURL : OFF  |  WGET : ON  |  Perl : ON  |  Python : ON  |  Sudo : ON  |  Pkexec : OFF
Directory :  /usr/lib/python2.7/dist-packages/twisted/protocols/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyc
ó
0”Nc@s¨dZddlZddlZddlmZmZddlmZmZm	Z	ddl
mZddlm
Z
ddlmZd„Zd	efd
„ƒYZde	fd„ƒYZd
efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd „ƒYZd!d#d"„ƒYZdS($s]
Resource limiting policies.

@seealso: See also L{twisted.protocols.htb} for rate limiting.
iÿÿÿÿN(tdirectlyProvidest
providedBy(t
ServerFactorytProtocolt
ClientFactory(terror(tILoggingContext(tlogcCs>tj|ƒr|jƒ}n|jj}d||jjfS(sY
    Compute a log prefix for a wrapper and the object it wraps.

    @rtype: C{str}
    s%s (%s)(RRt	logPrefixt	__class__t__name__(twrappertwrappedR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt_wrappedLogPrefixstProtocolWrappercBs’eZdZdZd„Zd„Zd„Zd„Zd„Zd„Z	d„Z
d	„Zd
„Zd„Z
d„Zd
„Zd„Zd„ZRS(s…
    Wraps protocol instances and acts as their transport as well.

    @ivar wrappedProtocol: An L{IProtocol<twisted.internet.interfaces.IProtocol>}
        provider to which L{IProtocol<twisted.internet.interfaces.IProtocol>}
        method calls onto this L{ProtocolWrapper} will be proxied.

    @ivar factory: The L{WrappingFactory} which created this
        L{ProtocolWrapper}.
    icCs||_||_dS(N(twrappedProtocoltfactory(tselfRR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt__init__3s	cCst||jƒS(so
        Use a customized log prefix mentioning both the wrapped protocol and
        the current one.
        (R
R(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR8scCsGt|t|ƒƒtj||ƒ|jj|ƒ|jj|ƒdS(sä
        When a connection is made, register this wrapper with its factory,
        save the real transport, and connect the wrapped protocol to this
        L{ProtocolWrapper} to intercept any transport calls it makes.
        N(RRRtmakeConnectionRtregisterProtocolR(Rt	transport((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR@scCs|jj|ƒdS(N(Rtwrite(Rtdata((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRNscCs|jj|ƒdS(N(Rt
writeSequence(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRRscCsd|_|jjƒdS(Ni(t
disconnectingRtloseConnection(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRVs	cCs
|jjƒS(N(RtgetPeer(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRcCs
|jjƒS(N(RtgetHost(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR_scCs|jj||ƒdS(N(RtregisterProducer(Rtproducert	streaming((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRcscCs|jjƒdS(N(RtunregisterProducer(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR gscCs|jjƒdS(N(Rt
stopConsuming(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR!kscCst|j|ƒS(N(tgetattrR(Rtname((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt__getattr__oscCs|jj|ƒdS(N(RtdataReceived(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%uscCs$|jj|ƒ|jj|ƒdS(N(RtunregisterProtocolRtconnectionLost(Rtreason((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR'ys(R
t
__module__t__doc__RRRRRRRRRRR R!R$R%R'(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%s 
													tWrappingFactorycBsneZdZeZd„Zd„Zd„Zd„Zd„Z	d„Z
d„Zd„Zd	„Z
d
„ZRS(sE
    Wraps a factory and its protocols, and keeps track of them.
    cCs||_i|_dS(N(twrappedFactoryt	protocols(RR,((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR†s	cCst||jƒS(sY
        Generate a log prefix mentioning both the wrapped factory and this one.
        (R
R,(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR‹scCs|jjƒtj|ƒdS(N(R,tdoStartR(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR.’s
cCs|jjƒtj|ƒdS(N(R,tdoStopR(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR/—s
cCs|jj|ƒdS(N(R,tstartedConnecting(Rt	connector((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR0œscCs|jj||ƒdS(N(R,tclientConnectionFailed(RR1R(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR2 scCs|jj||ƒdS(N(R,tclientConnectionLost(RR1R(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR3¤scCs|j||jj|ƒƒS(N(tprotocolR,t
buildProtocol(Rtaddr((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5¨scCsd|j|<dS(s8
        Called by protocol to register itself.
        iN(R-(Rtp((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR¬scCs|j|=dS(s8
        Called by protocols when they go away.
        N(R-(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR&³s(R
R)R*RR4RRR.R/R0R2R3R5RR&(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR+s									tThrottlingProtocolcBs_eZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z	d„Z
d	„ZRS(
sProtocol for ThrottlingFactory.cCs*|jjt|ƒƒtj||ƒdS(N(RtregisterWrittentlenRR(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRÀscCs9|jjttjtt|ƒƒƒtj||ƒdS(N(	RR9treducetoperatortaddtmapR:RR(Rtseq((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRÄs%cCs*|jjt|ƒƒtj||ƒdS(N(RtregisterReadR:RR%(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%ÈscCs ||_tj|||ƒdS(N(RRR(RRR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRÌs	cCs|`tj|ƒdS(N(RRR (R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR ÐscCs|jjƒdS(N(RtpauseProducing(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt
throttleReadsÕscCs|jjƒdS(N(RtresumeProducing(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytunthrottleReadsØscCs#t|dƒr|jjƒndS(NR(thasattrRRA(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytthrottleWritesÛscCs#t|dƒr|jjƒndS(NR(RERRC(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytunthrottleWritesßs(R
R)R*RRR%RR RBRDRFRG(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR8»s								tThrottlingFactorycBsŒeZdZeZejd
d
d„Zd„Z	d„Z
d„Zd„Zd„Z
d„Zd„Zd	„Zd
„Zd„Zd„ZRS(s‹
    Throttles bandwidth and number of connections.

    Write bandwidth will only be throttled if there is a producer
    registered.
    cCsntj||ƒd|_||_||_||_d|_d|_d|_	d|_
d|_d|_dS(Ni(
R+RtconnectionCounttmaxConnectionCountt	readLimitt
writeLimittreadThisSecondtwrittenThisSecondtNonetunthrottleReadsIDtcheckReadBandwidthIDtunthrottleWritesIDtcheckWriteBandwidthID(RR,RJRKRL((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRîs									cCs ddlm}|j||ƒS(sG
        Wrapper around L{reactor.callLater} for test purpose.
        iÿÿÿÿ(treactor(ttwisted.internetRTt	callLater(RtperiodtfuncRT((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRVýscCs|j|7_dS(sH
        Called by protocol to tell us more bytes were written.
        N(RN(Rtlength((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR9scCs|j|7_dS(sE
        Called by protocol to tell us more bytes were read.
        N(RM(RRY((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR@scCsv|j|jkrQ|jƒt|jƒ|jd}|j||jƒ|_nd|_|jd|jƒ|_dS(s:
        Checks if we've passed bandwidth limits.
        gð?iiN(	RMRKRBtfloatRVRDRPtcheckReadBandwidthRQ(RtthrottleTime((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR[s
		cCsv|j|jkrQ|jƒt|jƒ|jd}|j||jƒ|_nd|_|jd|jƒ|_dS(Ngð?ii(	RNRLRFRZRVRGRRtcheckWriteBandwidthRS(RR\((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR] s
		cCs9tjd|ƒx!|jjƒD]}|jƒq!WdS(s2
        Throttle reads on all protocols.
        sThrottling reads on %sN(RtmsgR-tkeysRB(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRB+scCsBd|_tjd|ƒx!|jjƒD]}|jƒq*WdS(s9
        Stop throttling reads on all protocols.
        sStopped throttling reads on %sN(RORPRR^R-R_RD(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRD4s	cCs9tjd|ƒx!|jjƒD]}|jƒq!WdS(s3
        Throttle writes on all protocols.
        sThrottling writes on %sN(RR^R-R_RF(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRF>scCsBd|_tjd|ƒx!|jjƒD]}|jƒq*WdS(s:
        Stop throttling writes on all protocols.
        sStopped throttling writes on %sN(RORRRR^R-R_RG(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRGGs	cCs|jdkrJ|jdk	r+|jƒn|jdk	rJ|jƒqJn|j|jkr{|jd7_tj||ƒSt	j
dƒdSdS(NiisMax connection count reached!(RIRKROR[RLR]RJR+R5RR^(RR6((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5Qs

cCs±tj||ƒ|jd8_|jdkr­|jdk	rM|jjƒn|jdk	rl|jjƒn|jdk	r‹|jjƒn|jdk	r­|jjƒq­ndS(Nii(	R+R&RIRPROtcancelRQRRRS(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR&`sN(R
R)R*R8R4tsystmaxintRORRVR9R@R[R]RBRDRFRGR5R&(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRHäs				
				
			
	tSpewingProtocolcBseZd„Zd„ZRS(cCs%tjd|ƒtj||ƒdS(NsReceived: %r(RR^RR%(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%pscCs%tjd|ƒtj||ƒdS(NsSending: %r(RR^RR(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRts(R
R)R%R(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRcos	tSpewingFactorycBseZeZRS((R
R)RcR4(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRdzstLimitConnectionsByPeercBs)eZdZd„Zd„Zd„ZRS(icCs
i|_dS(N(tpeerConnections(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytstartFactoryƒscCsS|d}|jj|dƒ}||jkr2dS|d|j|<tj||ƒS(Nii(RftgettmaxConnectionsPerPeerROR+R5(RR6tpeerHostRI((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5†s
cCsG|jƒd}|j|cd8<|j|dkrC|j|=ndS(Nii(RRf(RR7Rj((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR&Žs(R
R)RiRgR5R&(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRes		tLimitTotalConnectionsFactorycBs;eZdZdZdZdZd„Zd„Zd„Z	RS(sþ
    Factory that limits the number of simultaneous connections.

    @type connectionCount: C{int}
    @ivar connectionCount: number of current connections.
    @type connectionLimit: C{int} or C{None}
    @cvar connectionLimit: maximum number of connections.
    @type overflowProtocol: L{Protocol} or C{None}
    @cvar overflowProtocol: Protocol to use for new connections when
        connectionLimit is exceeded.  If C{None} (the default value), excess
        connections will be closed immediately.
    icCsz|jdks!|j|jkr0|jƒ}n|jdkrCdS|jƒ}||_t||ƒ}|jd7_|S(Ni(tconnectionLimitRORIR4toverflowProtocolRR(RR6RR4((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5¦s	cCsdS(N((RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR·scCs|jd8_dS(Ni(RI(RR7((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR&ºsN(
R
R)R*RIRORlRmR5RR&(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRk•s		tTimeoutProtocolcBsbeZdZd„Zd
d„Zd„Zd„Zd„Zd„Z	d„Z
d„Zd	„ZRS(sN
    Protocol that automatically disconnects when the connection is idle.
    cCs-tj|||ƒd|_|j|ƒdS(sã
        Constructor.

        @param factory: An L{IFactory}.
        @param wrappedProtocol: A L{Protocol} to wrapp.
        @param timeoutPeriod: Number of seconds to wait for activity before
            timing out.
        N(RRROttimeoutCallt
setTimeout(RRRt
timeoutPeriod((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRÄs		cCsD|jƒ|dk	r"||_n|jj|j|jƒ|_dS(sÊ
        Set a timeout.

        This will cancel any existing timeouts.

        @param timeoutPeriod: If not C{None}, change the timeout period.
            Otherwise, use the existing value.
        N(t
cancelTimeoutRORqRRVttimeoutFuncRo(RRq((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRpÒs	
cCsA|jr=y|jjƒWntjk
r0nXd|_ndS(sg
        Cancel the timeout.

        If the timeout was already cancelled, this does nothing.
        N(RoR`Rt
AlreadyCalledRO(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRrás	cCs#|jr|jj|jƒndS(sQ
        Reset the timeout, usually because some activity just happened.
        N(RotresetRq(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytresetTimeoutïs	cCs|jƒtj||ƒdS(N(RvRR(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR÷s
cCs|jƒtj||ƒdS(N(RvRR(RR?((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRüs
cCs|jƒtj||ƒdS(N(RvRR%(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%s
cCs|jƒtj||ƒdS(N(RrRR'(RR(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR's
cCs|jƒdS(s³
        This method is called when the timeout is triggered.

        By default it calls L{loseConnection}.  Override this if you want
        something else to happen.
        N(R(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRssN(
R
R)R*RRORpRrRvRRR%R'Rs(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRn¿s							tTimeoutFactorycBs2eZdZeZdd„Zd„Zd„ZRS(s%
    Factory for TimeoutWrapper.
    ii<cCs||_tj||ƒdS(N(RqR+R(RR,Rq((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRs	cCs%|j||jj|ƒd|jƒS(NRq(R4R,R5Rq(RR6((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5"scCs ddlm}|j||ƒS(sG
        Wrapper around L{reactor.callLater} for test purpose.
        iÿÿÿÿ(RT(RURTRV(RRWRXRT((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRV'si(R
R)R*RnR4RR5RV(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRws
	tTrafficLoggingProtocolcBs_eZd
dd„Zd„Zd„Zd„Zd„Zd„Zd„Z	d„Z
d	„ZRS(icCs2tj|||ƒ||_||_||_dS(s
        @param factory: factory which created this protocol.
        @type factory: C{protocol.Factory}.
        @param wrappedProtocol: the underlying protocol.
        @type wrappedProtocol: C{protocol.Protocol}.
        @param logfile: file opened for writing used to write log messages.
        @type logfile: C{file}
        @param lengthLimit: maximum size of the datareceived logged.
        @type lengthLimit: C{int}
        @param number: identifier of the connection.
        @type number: C{int}.
        N(RRtlogfiletlengthLimitt_number(RRRRyRztnumber((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR2s		cCs%|jj|dƒ|jjƒdS(Ns
(RyRtflush(Rtline((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt_logFscCs:|jr6t|ƒ|jkr6||jd d}n|S(Nis<... elided>(RzR:(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt
_mungeDataKscCs|jdƒtj|ƒS(Nt*(RRtconnectionMade(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR‚Rs
cCs3|jd|j|j|ƒfƒtj||ƒS(NsC %d: %r(RR{R€RR%(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR%Ws#cCs*|jd|j|fƒtj||ƒS(NsC %d: %r(RR{RR'(RR(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR'\scCs3|jd|j|j|ƒfƒtj||ƒS(NsS %d: %r(RR{R€RR(RR((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRbs#cCsF|jd|jg|D]}|j|ƒ^qfƒtj||ƒS(Ns	SV %d: %r(RR{R€RR(Rtiovectd((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRgs6cCs$|jd|jfƒtj|ƒS(NsS %d: *(RR{RR(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRlsN(R
R)RORRR€R‚R%R'RRR(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRx0s							tTrafficLoggingFactorycBs;eZeZdZdd„Zd„Zd„Zd„Z	RS(icCs&||_||_tj||ƒdS(N(t
logfilePrefixRzR+R(RR,R†Rz((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRws		cCs
t|dƒS(Ntw(tfile(RR#((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytopen}scCs]|jd7_|j|jdt|jƒƒ}|j||jj|ƒ||j|jƒS(Nit-(t_counterR‰R†tstrR4R,R5Rz(RR6Ry((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR5s#cCs
d|_dS(sN
        Reset the value of the counter used to identify connections.
        iN(R‹(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pytresetCounterˆsN(
R
R)RxR4R‹RORR‰R5R(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR…rs		tTimeoutMixincBsGeZdZdZdZd„Zd„Zd„Zd„Z	d„Z
RS(sL
    Mixin for protocols which wish to timeout connections.

    Protocols that mix this in have a single timeout, set using L{setTimeout}.
    When the timeout is hit, L{timeoutConnection} is called, which, by
    default, closes the connection.

    @cvar timeOut: The number of seconds after which to timeout the connection.
    cCs ddlm}|j||ƒS(sG
        Wrapper around L{reactor.callLater} for test purpose.
        iÿÿÿÿ(RT(RURTRV(RRWRXRT((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRVžscCs8|jdk	r4|jdk	r4|jj|jƒndS(s³
        Reset the timeout count down.

        If the connection has already timed out, then do nothing.  If the
        timeout has been cancelled (probably using C{setTimeout(None)}), also
        do nothing.

        It's often a good idea to call this when the protocol has received
        some meaningful input from the other end of the connection.  "I've got
        some data, they're still there, reset the timeout".
        N(t_TimeoutMixin__timeoutCallROttimeOutRu(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRv¦scCs„|j}||_|jdk	rY|dkrF|jjƒd|_q€|jj|ƒn'|dk	r€|j||jƒ|_n|S(sÌ
        Change the timeout period

        @type period: C{int} or C{NoneType}
        @param period: The period, in seconds, to change the timeout to, or
        C{None} to disable the timeout.
        N(RRROR`RuRVt_TimeoutMixin__timedOut(RRWtprev((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRpµs		
cCsd|_|jƒdS(N(RORttimeoutConnection(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt
__timedOutËs	cCs|jjƒdS(s€
        Called when the connection times out.

        Override to define behavior other than dropping the connection.
        N(RR(R((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyR“ÏsN(R
R)R*RORRRVRvRpR‘R“(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyRŽs					((R*RaR<tzope.interfaceRRttwisted.internet.protocolRRRRURttwisted.internet.interfacesRttwisted.pythonRR
RR+R8RHRcRdReRkRnRwRxR…RŽ(((s>/usr/lib/python2.7/dist-packages/twisted/protocols/policies.pyt<module>	s(	Z<)‹*WB

Youez - 2016 - github.com/yon3zu
LinuXploit