ó ½-'Nc@sŒddlmZmZddlmZddlmZddlmZde fd„ƒYZ de fd„ƒYZ d e fd „ƒYZ d S( iÿÿÿÿ(tinfot exception(t maybeDeferred(t format_object(tgather_resultstHandlerNotFoundErrorcBseZdZRS(s3A handler for the given message type was not found.(t__name__t __module__t__doc__(((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR stBrokerClientPlugincBs2eZdZdZeZd„Zed„ƒZRS(sA convenience for writing L{BrokerClient} plugins. This provides a register method which will set up a bunch of reactor handlers in the idiomatic way. If C{run} is defined on subclasses, it will be called every C{run_interval} seconds after being registered. @cvar run_interval: The interval, in seconds, to execute the C{run} method. If set to C{None}, then C{run} will not be scheduled. @cvar run_immediately: If C{True} the plugin will be run immediately after it is registered. icCsl||_t|ddƒdk rh|jr7|jƒn|jdk rh|jjj|j|jƒqhndS(Ntrun(tclienttgetattrtNonetrun_immediatelyR t run_intervaltreactort call_every(tselfR ((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytregisters    cCs|jS(s%An alias for the C{client} attribute.(R (R((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytregistry's( RRRRtFalseRRtpropertyR(((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR s   t BrokerClientcBs‰eZdZdZd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„ZRS(sïBasic plugin registry for clients that have to deal with the broker. This knows about the needs of a client when dealing with the Landscape broker, including interest in messages of a particular type delivered by the broker to the client. @cvar name: The name used when registering to the broker, it must be defined by sub-classes. @ivar broker: A reference to a connected L{RemoteBroker}, it must be set by the connecting machinery at service startup. R cCsptt|ƒjƒ||_d|_i|_g|_i|_|jj d|j ƒ|jj d|j ƒdS(s6 @param reactor: A L{TwistedReactor}. simpending-exchangesbroker-reconnectN( tsuperRt__init__RR tbrokert_registered_messagest_pluginst _plugin_namestcall_ontnotify_exchangethandle_reconnect(RR((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR;s     cCstS(sReturn C{True}(tTrue(R((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytpingJscCsVtdt|ƒƒ|jj|ƒt|dƒrE||j|jclient message. @param type: The type of message to register C{handler} for. @param handler: A callable taking a message as a parameter, called when messages of C{type} are received. @return: A C{Deferred} that will fire when registration completes. (RRt%register_client_accepted_message_type(Rttypethandler((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytregister_messagees cCsg|d}|jj|ƒ}|dkr7t|ƒ‚ny||ƒSWntd||fƒnXdS(sÆRun the handler registered for the type of the given message. @return: The return value of the handler, if found. @raises: HandlerNotFoundError if the handler was not found R,s-Error running message handler for type %r: %rN(RtgetR RR(RtmessageR,R-((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytdispatch_messagers  cCs.y|j|ƒtSWntk r)tSXdS(sŠCall C{dispatch_message} for the given C{message}. @return: A boolean indicating if a handler for the message was found. N(R1R!RR(RR0((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR0‚s   cCsOxH|jƒD]:}t|dƒr y|jƒWqGtdƒqGXq q WdS(s Call C{exchange} on all plugins.texchangesError during plugin exchangeN(R(R%R2R(RR&((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR2s cCstdƒ|jƒdS(s/Notify all plugins about an impending exchange.s>Got notification of impending exchange. Notifying all plugins.N(RR2(R((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR–s cOs|dkr>|d}|d}|jj||f|ƒ}n|jj|||Ž}tg|D]}td„|ƒ^q`ƒS(s´Fire an event of a given type. @return: A L{Deferred} resulting in a list of returns values of the fired event handlers, in the order they were fired. smessage-type-acceptance-changediicSs|S(N((tx((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyt¨s(RtfireRR(Rt event_typetargstkwargst message_typet acceptancetresultstresult((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyt fire_event›s   cCs;x!|jD]}|jj|ƒq W|jj|jƒdS(sCalled when the connection with the broker is established again. The following needs to be done: - Re-register any previously registered message types, so the broker knows we have interest on them. - Re-register ourselves as client, so the broker knows we exist and will talk to us firing events and dispatching messages. N(RRR+tregister_clientR)(RR,((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR ªs cCs|jjd|jjƒdS(s&Stop the reactor and exit the process.gš™™™™™¹?N(Rt call_latertstop(R((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pytexit¹s(RRRR)RR"R'R(R*R.R1R0R2RR=R RA(((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyR-s          N(tloggingRRttwisted.internet.deferRt landscape.logRtlandscape.lib.twisted_utilRt ExceptionRtobjectR R(((s;/usr/lib/python2.7/dist-packages/landscape/broker/client.pyts