ó ½-'Nc@sødZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z d efd „ƒYZd efd „ƒYZd efd„ƒYZdS(s Implementation of a lightweight exchange-triggering mechanism via small HTTP requests asking if we should do a full exchange. i’’’’N(tinfo(tFailure(tdefer(tloads(tfetch(t log_failuret PingClientcBs,eZdZdd„Zd„Zd„ZRS(sBAn HTTP client which asks: Are there messages for computer X? cCs=|dkrt}n||_||_||_||_dS(s° @param url: The URL to ask the question to. @type identity: L{landscape.broker.registration.Identity} @param identity: This client's identity. N(tNoneRt_reactort _identitytget_pageturl(tselftreactorR tidentityR ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyt__init__s      c s«|jj}|dk ržidd6}tji|d6ƒ}tjƒ‰‡fd†}|jjˆj ||j |j dt d|d|ƒˆj |jƒˆStjtƒS( sāAsk the question. Hits the URL previously specified with the insecure_id gotten from the identity. @return: A deferred resulting in True if there are messages and False otherwise. s!application/x-www-form-urlencodeds Content-Typet insecure_idcsˆjt|||ƒƒdS(N(terrbackR(ttypetvaluettb(t page_deferred(s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR1stposttdatatheadersN(R RRturllibt urlencodeRtDeferredRtcall_in_threadtcallbackR R tTruet addCallbackt _got_resulttsucceedtFalse(R RRRR((Rs9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pytping"s     cCs!t|ƒitd6krtSdS(sŗ Given a response that came from a ping server, return True if the response indicates that their are messages waiting for this computer, False otherwise. tmessagesN(RR(R twebtext((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR :sN(t__name__t __module__t__doc__RRR#R (((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyRs tPingercBseeZdZded„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z RS( sy A plugin which pings the Landscape server with HTTP requests to see if a full exchange should be initiated. icCs_||_||_||_||_||_d|_d|_||_|j d|j ƒdS(s @param reactor: The reactor to schedule calls with @param url: The URL to ping @param interval: How often to send the pings @param exchanger: The L{landscape.broker.exchange.MessageExchange} to trigger exchanges with. tmessageN( t_urlt _intervalR Rt _exchangerRt_call_idt _ping_clienttping_client_factorytcall_ont_handle_set_intervals(R R R Rt exchangertintervalR0((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyRJs        cCs|jS(N(R+(R ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pytget_url]scCs+||_|jdk r'||j_ndS(N(R+R/RR (R R ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pytset_url`s cCs|jS(N(R,(R ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyt get_intervalescCsC|j|j|j|jƒ|_|jj|j|jƒ|_dS(sStart pinging.N( R0RR+R R/t call_everyR,R#R.(R ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pytstarthscCs3|jjƒ}|j|jƒ|j|jƒdS(s8Perform a ping; if there are messages, fire an exchange.N(R/R#RR t addErrbackt _got_error(R t ping_deferred((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR#nscCs*|r&tdƒ|jjdtƒndS(Ns@Ping indicates message available. Scheduling an urgent exchange.turgent(RR-tschedule_exchangeR(R texchange((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR ts cCst|d|jfƒdS(Ns"Error contacting ping server at %s(RR+(R tfailure((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR;zscCs„|ddkr=d|kr=|d|_td|jƒn|jdk r€|jj|jƒ|jj|j|jƒ|_ndS(NRs set-intervalsR#s Ping interval set to %d seconds.(R,RR.RRt cancel_callR8R#(R R*((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR2~s  ( R&R'R(RRR5R6R7R9R#R R;R2(((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR)Ds       t FakePingercBseZd„Zd„ZRS(cOsdS(N((R targstkwargs((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR‰scCsdS(N((R ((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyR9Œs(R&R'RR9(((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyRB‡s (R(RtloggingRttwisted.python.failureRttwisted.internetRtlandscape.lib.bpickleRtlandscape.lib.fetchRtlandscape.lib.logRtobjectRR)RB(((s9/usr/lib/python2.7/dist-packages/landscape/broker/ping.pyts 3C