ó ½-'Nc@s¸ddlmZmZmZddlmZddlmZmZm Z m Z ddl m Z ddl mZddlmZddlmZdefd „ƒYZd efd „ƒYZd efd „ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZde fd„ƒYZde fd„ƒYZdefd„ƒYZdefd„ƒYZe jeƒe jeƒe jeƒe jeƒdS(iÿÿÿÿ(t maybeDeferredtexecutetsucceed(t RemoteObject(tComponentProtocoltComponentProtocolFactorytRemoteComponentConnectortRemoteComponentsRegistry(t BrokerServer(t BrokerClient(tMonitor(tManagertBrokerServerProtocolc Bs<eZdZejddddddddd d d g ZRS( sK Communication protocol between the broker server and its clients. t fire_eventtget_accepted_message_typestget_server_uuidtis_message_pendingtregistertregister_clientt%register_client_accepted_message_typetreload_configurationt send_messaget stop_clientst listen_events(t__name__t __module__t__doc__Rtmethods(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR stBrokerServerProtocolFactorycBseZeZRS((RRR tprotocol(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRst RemoteBrokercBseZd„Zd„ZRS(cs2|jƒ}‡‡‡fd†}|j|ƒ|S(s8Call C{callable} if C{type} is an accepted message type.csˆ|krˆˆŒSdS(N((tresult(tcallabletargsttype(s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pytgot_accepted_types*s (Rt addCallback(tselfR"R R!tdeferred_typesR#((R!R R"s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pytcall_if_accepted&s  cs+|jˆjƒƒ}|j‡fd†ƒS(sQCall a given handler as soon as a certain event occurs. @param handlers: A dictionary mapping event types to callables, where an event type is string (the name of the event). When the first of the given event types occurs in the broker reactor, the associated callable will be fired. cs ˆ|ƒS(N((t event_type(thandlers(s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyt9s(RtkeysR$(R%R)R((R)s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyt call_on_event0s(RRR'R,(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR$s tFakeRemoteBrokercBsGeZdZd„Zd„Zd„Zed„Zd„Zd„Z RS(s@Looks like L{RemoteBroker}, but actually talks to local objects.cCs"||_||_tƒ|_dS(N(t exchangert message_storeR R(R%R.R/((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyt__init__?s  cCs ttƒS(N(RtTrue(R%((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pytpingDscGs,||jjƒkr"t||ŒStdƒS(N(R/tget_accepted_typesRRtNone(R%R"R R!((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR'Gs cCs>ddlm}|j|ƒs%t‚t|jj|d|ƒS(s7Send to the previously given L{MessageExchange} object.iÿÿÿÿ(tMethodCallArgumentturgent(tlandscape.lib.ampR5tchecktAssertionErrorRR.tsend(R%tmessageR6R5((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRLscCst|jj|ƒS(N(RR.R(R%R"((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRUs cCst|jjƒS(st Return a deferred resulting in the list of message types accepted by the Landscape server. (RR/R3(R%((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRYs( RRRR0R2R'tFalseRRR(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR-<s    tBrokerClientProtocolcBs!eZdZejddgZRS(s7Communication protocol between a client and the broker.R R;(RRRRR(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR=astBrokerClientProtocolFactorycBseZeZRS((RRR=R(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR>gst RemoteClientcBseZdZRS(s8A remote L{BrokerClient} connected to a L{BrokerServer}.(RRR(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR?lstRemoteBrokerConnectorcBs eZdZeZeZeZRS(s6Helper to create connections with the L{BrokerServer}.( RRRR>tfactoryRtremoteRt component(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyR@pstRemoteClientConnectorcBs eZdZeZeZeZRS(s6Helper to create connections with the L{BrokerServer}.( RRRRRAR?RBR RC(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRDxstRemoteMonitorConnectorcBseZdZeZRS(s1Helper to create connections with the L{Monitor}.(RRRR RC(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRE€stRemoteManagerConnectorcBseZdZeZRS(s4Helper for creating connections with the L{Monitor}.(RRRR RC(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyRF†sN( ttwisted.internet.deferRRRR7Rt landscape.ampRRRRtlandscape.broker.serverRtlandscape.broker.clientR tlandscape.monitor.monitorR tlandscape.manager.managerR R RRtobjectR-R=R>R?R@RDRERFR(((s8/usr/lib/python2.7/dist-packages/landscape/broker/amp.pyts*"%