ó ½-'Nc@sdZddlZddlZddlmZddlmZddlmZm Z ddl m Z ddl m Z mZdefd „ƒYZd „ZdS( sGThe part of the broker which deals with communications with the server.iÿÿÿÿN(tmd5(tsucceed(tgot_next_expectedtANCIENT(t format_delta(t SERVER_APIt CLIENT_APItMessageExchangecBsæeZdZdZddejd„Zd„Zd„Ze d„Z d„Z d„Z d „Z d „Zd „Zd „Zd „Zd„Ze e d„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(sã The Message Exchange is the place where messages are sent to go out to the Landscape server. The Message Exchange will accumulate messages in its message store and periodically deliver them to the server. smessage-exchangeidc Cs||_||_| |_||_||_||_|j|_|j|_ ||_ d|_ d|_ t|_t|_tƒ|_d|_i|_||_|jd|jƒ|jd|jƒ|jd|jƒ|jd|jƒ|jd|jƒdS(sú @param reactor: A L{TwistedReactor} used to fire events in response to messages received by the server. @param store: A L{MessageStore} used to queue outgoing messages. @param transport: A L{HTTPTransport} used to deliver messages. @param exchange_interval: time interval between subsequent exchanges of non-urgent messages. @param urgent_exchange_interval: time interval between subsequent exchanges of urgent messages. saccepted-typest resynchronizes set-intervalssresynchronize-clientsspre-exitN(t_reactort_message_storet _create_timet _transportt_registration_infot_configtexchange_intervalt_exchange_intervalturgent_exchange_intervalt_urgent_exchange_intervalt _max_messagestNonet_notification_idt _exchange_idtFalset _exchangingt_urgent_exchangetsett_client_accepted_typest_client_accepted_types_hasht_message_handlerst_exchange_storetregister_messaget_handle_accepted_typest_handle_resynchronizet_handle_set_intervalstcall_ont_resynchronizetstop( tselftreactortstoret transporttregistration_infotexchange_storetconfigtmonitor_intervalt max_messagest create_time((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyt__init__s,                 cCs|j|jfS(s@Return a binary tuple with urgent and normal exchange intervals.(RR(R&((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pytget_exchange_intervals@scCspd|krtS|d}|jj|ƒ}|dkrMtjd|ƒtS|jj|jk}|jƒ|S(s’Returns C{True} if message is obsolete. A message is considered obsolete if the secure ID changed since it was received. s operation-ids4No message context for message with operation-id: %sN( RRtget_message_contextRtloggingtwarningR t secure_idtremove(R&tmessaget operation_idtcontexttresult((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyt_message_is_obsoleteDs    cCs„|j|ƒr-tjd|jdƒƒdSd|krUt|jjƒƒ|dtget_pending_messagesRCRDR tfireR(R&R7t old_typest new_typestdiffttype((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR ~s cCs<|d}|jjidd6|d6ƒ|jjdƒdS(Ns operation-idRRRsresynchronize-clients(R RBR RN(R&R7topid((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR!–s  cCs|jdtƒdS(NR=(RCRD(R&((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR$œscCsd|kr?|d|_|j|j_tjd|jƒnd|kr~|d|_|j|j_tjd|jƒn|jjƒdS(Ntexchanges$Exchange interval set to %d seconds.surgent-exchanges+Urgent exchange interval set to %d seconds.(RRRR3R>RRtwrite(R&R7((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR"Ÿs      csшjr dStˆ_ˆjjdƒˆjƒ‰ˆjƒ‰ˆjrdtjdˆj j ƒƒntjdˆj j ƒƒ‡‡‡fd†}ˆjj |dˆj j ˆˆjjˆjdƒƒtdƒS(såSend pending messages to the server and process responses. An C{pre-exchange} reactor event will be emitted just before the actual exchange takes place. An C{exchange-done} or C{exchange-failed} reactor event will be emitted after a successful or failed exchange. @return: A L{Deferred} that is fired when exchange has completed. XXX Actually that is a lie right now. It returns before exchange is actually complete. Ns pre-exchanges)Starting urgent message exchange with %s.s"Starting message exchange with %s.cs¥tˆ_|rDˆjr1tjdƒtˆ_nˆjˆ|ƒnˆjjdƒtjdƒˆjdt ƒˆjjdƒtjdt ˆj ƒˆƒƒdS(Ns"Switching to normal exchange mode.sexchange-failedsMessage exchange failed.tforces exchange-dones!Message exchange completed in %s.( RRRR3R>t_handle_resultR RNRCRDRR (R:(t start_timeR&tpayload(s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyt handle_resultÌs      s server-api(RRDR RNt make_payloadR RR3R>R tget_urltcall_in_threadRRTR R5R?R(R&RZ((RXRYR&s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRT­s"         cCs|jS(sMReturn a bool showing whether there is an urgent exchange scheduled. (R(R&((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyt is_urgentäscCsê|j ræ|s/|jdks/|ræ|j ræ|rAt|_n|jr`|jj|jƒn|jru|j}n |j}|j dk r£|jj|j ƒn|d}|jj ||j ƒ|_ |jj ||j ƒ|_ndS(s_Schedule an exchange to happen. The exchange will occur after some time based on whether C{urgent} is True. An C{impending-exchange} reactor event will be emitted approximately 10 seconds before the exchange is started. @param urgent: If true, ensure an exchange happens within the urgent interval. This will reschedule the exchange if necessary. If another urgent exchange is already scheduled, nothing happens. @param force: If true, an exchange will necessarily be scheduled, even if it was already scheduled before. i N( RRRRRDR RHRRRt call_latert_notify_impending_exchangeRT(R&R=RVtintervaltnotification_interval((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRCés"         cCs|jjdƒdS(Nsimpending-exchange(R RN(R&((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR`sc CsC|j}|j|jƒƒ}|j|jƒ}|jƒ}|r¿|djdƒ}x9t|ƒD]%\}}|jdƒ|krbPqbqbWd }|d k r§||3n|d krÅd}qÅnt }i|d6t d6|j ƒd6|d6|d6|j ƒd 6|d 6}|j ƒ} |j| ƒ} | |jkr?| |d RBR RNtget_server_uuidtset_server_uuidRjthandle_messagetset_server_sequenceRMRCRD( R&RYR:t message_storet next_expectedt old_sequencetmessage_store_statetold_uuidtnew_uuidRdR7((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRWEs>                 cCs0|jj|gƒj|ƒ|jj|ƒdS(sRegister a handler for the given message type. The C{handler} callable will to be executed when a message of type C{type} has been received from the server. Multiple handlers for the same type will be called in the order they were registered. N(Rt setdefaulttappendRRB(R&RRthandler((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRs cCs†d|kr3|jj|d|jj|dƒn|jjd|ƒ|d|jkr‚x&|j|dD]}||ƒqkWndS(s– Handle a message received from the server. Any message handlers registered with L{register_message} will be called. s operation-idRRR7N(Rtadd_message_contextR R5R RNR(R&R7R„((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRzs  cCs|jjt|ƒƒdS(N(RRBtstr(R&RR((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyt%register_client_accepted_message_type¡scCs t|jƒS(N(tsortedR(R&((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRk¦sN(t__name__t __module__t__doc__t plugin_nameRRAR0R1R;RRFRGR%R R!R$R"RTR^RCR`R[RfRWRRzR‡Rk(((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyR s2#          7 &  /  <  cCsµt|ƒ}t|ƒ}||}||@}||}g}|jg|D]}d|^qIƒ|jg|D]}d|^qmƒ|jg|D]}d|^q‘ƒdj|ƒS(Ns+%ss%ss-%st (RtextendRs(RORPt added_typest stable_typest removed_typesRQRR((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyRKªs     $$$(R‹RAR3tlandscape.lib.hashlibRttwisted.internet.deferRtlandscape.lib.messageRRt landscape.logRt landscapeRRtobjectRRK(((s=/usr/lib/python2.7/dist-packages/landscape/broker/exchange.pyts  ÿž