ó ½-'Nc@sddlZddlZddlmZmZmZdefd„ƒYZdefd„ƒYZdefd„ƒYZd e fd „ƒYZ dS( iÿÿÿÿN(tMethodCallProtocoltMethodCallFactorytRemoteObjectConnectortComponentProtocolcBs eZdZddgZdZRS(s"Communication protocol between the various Landscape components. It can be used both as server-side protocol for exposing the methods of a certain Landscape component, or as client-side protocol for connecting to another Landscape component we want to call the methods of. tpingtexiti<(t__name__t __module__t__doc__tmethodsttimeout(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyRs tComponentProtocolFactorycBseZeZdZRS(gš™™™™™©?(RRRtprotocolt initialDelay(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyR stRemoteComponentConnectorcBs/eZdZeZd„Zdded„ZRS(s%Utility superclass for creating connections with a Landscape component. @cvar component: The class of the component to connect to, it is expected to define a C{name} class attribute, which will be used to find out the socket to use. It must be defined by sub-classes. cOsT||_tjj|j|jjdƒ}tt|ƒj |jj |||ŽdS(s3 @param reactor: A L{TwistedReactor} object. @param config: A L{LandscapeConfiguration}. @param args: Positional arguments for protocol factory constructor. @param kwargs: Keyword arguments for protocol factory constructor. @see: L{MethodCallClientFactory}. s.sockN( t_twisted_reactortostpathtjoint sockets_patht componenttnametsuperRt__init__t_reactor(tselftreactortconfigtargstkwargstsocket((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyR#s csx‡fd†‰‡‡fd†}‡fd†}ttˆƒjd|d|ƒ}|sg|j|ƒn|j|ƒ|S(sConnect to the remote Landscape component. If the connection is lost after having been established, and then it is established again by the reconnect mechanism, an event will be fired. @param max_retries: If given, the connector will keep trying to connect up to that number of times, if the first connection attempt fails. @param factor: Optionally a float indicating by which factor the delay between subsequent retries should increase. Smaller values result in a faster reconnection attempts pace. @param quiet: A boolean indicating whether to log errors. csˆjjdˆjjƒdS(Ns %s-reconnect(RtfireRR(tremote(R(s1/usr/lib/python2.7/dist-packages/landscape/amp.pytfire_reconnectAs csˆjjˆƒ|S(N(t_factoryt add_notifier(R (R!R(s1/usr/lib/python2.7/dist-packages/landscape/amp.pyt connectedEscstjdˆjjƒ|S(NsError while connecting to %s(tloggingterrorRR(tfailure(R(s1/usr/lib/python2.7/dist-packages/landscape/amp.pyt log_errorIst max_retriestfactor(RRtconnectt addErrbackt addCallback(RR)R*tquietR$R(tresult((RR!s1/usr/lib/python2.7/dist-packages/landscape/amp.pyR+2s N( RRRR tfactoryRtNonetFalseR+(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyRs tRemoteComponentsRegistrycBs2eZdZiZed„ƒZed„ƒZRS(sR A global registry for looking up Landscape component connectors by name. cCs |j|S(sÂGet the connector class for the given Landscape component. @param name: Name of the Landscape component we want to connect to, for instance C{monitor} or C{manager}. (t_by_name(tclsR((s1/usr/lib/python2.7/dist-packages/landscape/amp.pytget\scCs||j|jjs   <