ó ½-'Nc@soddlZddlmZddlmZddlmZddlmZd„Z de fd„ƒYZ dS( iÿÿÿÿN(tDeferred(tgather_results(tRemoteComponentsRegistry(tFAILEDcs(|jjddƒ‰‡fd†}|S(s&Turns a L{BrokerServer} method into an event broadcaster. When the decorated method is called, an event is fired on all connected clients. The event will have the same name as the method being called, except that any underscore in the method name will be replaced with a dash. t_t-csCg}x0|jƒD]"}|j|jˆ||ŽƒqWt|ƒS(N(t get_clientstappendt fire_eventR(tselftargstkwargstfiredtclient(t event_type(s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytbroadcast_events (t__name__treplace(tmethodR((Rs;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytevent st BrokerServercBs+eZdZdZeZd„Zd„Zd„Zd„Z d„Z d„Z d„Z e d „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zed„ƒZed„ƒZd„Zed„ƒZed„ƒZed„ƒZed„ƒZd„Z d„Z!RS(sn A broker server capable of handling messages from plugins connected using the L{BrokerProtocol}. tbrokercCsµ||_||_||_||_||_i|_i|_|jd|jƒ|jd|j ƒ|jd|j ƒ|jd|j ƒ|jd|j ƒ|jd|j ƒdS(sU @param config: The L{BrokerConfiguration} used by the broker. @param reactor: The L{TwistedReactor} driving the broker's events. @param exchange: The L{MessageExchange} to send messages with. @param registration: The {RegistrationHandler}. @param message_store: The broker's L{MessageStore}. tmessagesimpending-exchangesmessage-type-acceptance-changedsserver-uuid-changedspackage-data-changedsresynchronize-clientsN(t_configt_reactort _exchangert _registrationt_message_storet_registered_clientst _connectorstcall_ontbroadcast_messagetimpending_exchangetmessage_type_acceptance_changedtserver_uuid_changedtpackage_data_changedt resynchronize(R tconfigtreactortexchanget registrationt message_store((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyt__init__$s         cCstS(sReturn C{True}.(tTrue(R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytping=scsUˆjjˆƒ}|ˆjˆjƒ‰‡‡‡fd†}ˆjƒ}|j|ƒS(sQRegister a broker client called C{name}. Various broker clients interact with the broker server, such as the monitor for example, using the L{BrokerServerProtocol} for performing remote method calls on the L{BrokerServer}. They establish connectivity with the broker by connecting and registering themselves, the L{BrokerServer} will in turn connect to them in order to be able to perform remote method calls like broadcasting events and messages. @param name: The name of the client, such a C{monitor} or C{manager}. cs|ˆjˆ<ˆˆj|‚s(RRtexitRR+R4(R tresultsR tresult((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyt stop_clients{s cCs|jjƒ|jƒS(s4Reload the configuration file, and stop all clients.(RtreloadRI(R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytreload_configuration„s cCs |jjƒS(sfAttempt to register with the Landscape server. @see: L{RegistrationHandler.register} (RR0(R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR0‹scCs |jjƒS(s:Return the message types accepted by the Landscape server.(Rtget_accepted_types(R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytget_accepted_message_types’scCs |jjƒS(s:Return the uuid of the Landscape server we're pointing at.(Rtget_server_uuid(R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRN–scCs|jj|ƒdS(s|Register a new message type which can be accepted by this client. @param type: The message type to accept. N(Rt%register_client_accepted_message_type(R ttype((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyROœscCs|jj|ƒdS(s$Fire an event in the broker reactor.N(Rtfire(R R((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR£scs8ˆjjdƒˆjƒ}‡fd†}|j|ƒS(s“Request a graceful exit from the broker server. Before this method returns, all broker clients will be notified of the server broker's intention of exiting, so that they have the chance to stop whatever they're doing in a graceful way, and then exit themselves. This method will only return a result when all plugins returned their own results. spre-exitcs ˆjjd‡fd†ƒdS(NicsˆjjdƒS(Ns post-exit(RRQ((R (s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRE½s(Rt call_later(RD(R (s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytfire_post_exitºs (RRQRItaddBoth(R tclients_stoppedRS((R s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRF§s cCsdS(s2Broadcast a C{resynchronize} event to the clients.N((R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR$ÁscCsdS(s8Broadcast an C{impending-exchange} event to the clients.N((R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR Åscsatƒ‰g‰‡‡‡fd†}x6|D].}ˆjj|||ƒƒ}ˆj|ƒq+WˆS(sk Return a C{Deferred} that fires when the first event occurs among the given ones. cs‡‡‡‡fd†}|S(Ncs2xˆD]}ˆjj|ƒqWˆjˆƒdS(N(Rt cancel_calltcallback(tcall(tdeferredR Rtcalls(s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pythandlerÓs ((RR[(RYR RZ(Rs;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyt get_handlerÑs(RRRR(R t event_typesR\RRX((RZR RYs;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyt listen_eventsÉs  cCsdS(s5Broadcast a C{broker-reconnect} event to the clients.N((R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pytbroker_reconnectßscCsdS(s8Broadcast a C{server-uuid-changed} event to the clients.N((R told_uuidtnew_uuid((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR"ãscCsdS(N((R RPtaccepted((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR!çscCsdS(s@Fire a package-data-changed event in the reactor of each client.N((R ((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyR#ëscCsRg}x*|jƒD]}|j|j|ƒƒqWt|ƒ}|j|j|ƒS(seCall the C{message} method of all the registered plugins. @see: L{register_plugin}. (RRRRR4t_message_delivered(R RRGR RH((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRïs  cCs¡|jdƒ}t|kr|d k r|ddkr|d}tjd|fƒd|f}idd6td6|d6|d6}|jj|d tƒnd S( s¾ If the message wasn't handled, and it's an operation request (i.e. it has an operation-id), then respond with a failing operation result indicating as such. s operation-idRPR$sNobody handled the %s message.s4Landscape client failed to handle this request (%s) because the plugin which should handle it isn't available. This could mean that the plugin has been intentionally disabled, or that the client isn't running properly, or you may be running an older version of the client that doesn't support this feature. soperation-resulttstatuss result-textR<N(R2R+RCtloggingterrorRRR=(R RGRtopidtmtypet result_texttresponse((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRcús     ("Rt __module__t__doc__R/RR1R*R,R7RR9R:R;tFalseR>RARIRKR0RMRNRORRFRR$R R^R_R"R!R#RRc(((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyRs:                 ( Rettwisted.internet.deferRtlandscape.lib.twisted_utilRt landscape.ampRtlandscape.manager.managerRRtobjectR(((s;/usr/lib/python2.7/dist-packages/landscape/broker/server.pyts