ó ÍÿŠTc@s…dZddlZddlZddlmZmZmZdefd„ƒYZd„Z d„Z defd „ƒYZ d „Z dS( shCommunication between components in different services via twisted AMP. The Landscape client is composed by several processes that need to talk to each other. For example the monitor and manager processes need to talk to the broker in order to ask it to add new messages to the outgoing queue, and the broker needs to talk to them in order to dispatch them incoming messages from the server. This module implements a few conveniences built around L{landscape.lib.amp} to let the various services connect to each other in an easy and idiomatic way, and have them respond to standard requests like "ping" or "exit". iÿÿÿÿN(tMethodCallClientFactorytMethodCallServerFactoryt RemoteObjecttComponentPublishercBs/eZdZeZd„Zd„Zd„ZRS(sPublish a Landscape client component using a UNIX socket. Other Landscape client processes can then connect to the socket and invoke methods on the component remotely, using L{MethodCall} commands. @param component: The component to publish. It can be any Python object implementing the methods listed in the C{methods} class variable. @param reactor: The L{LandscapeReactor} used to listen to the socket. @param config: The L{Configuration} object used to build the socket path. cCsC||_||_||_d|_tt|ƒƒjƒ|_dS(N( t_reactort_configt _componenttNonet_porttget_remote_methodsttypetkeystmethods(tselft componenttreactortconfig((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyt__init__"s     cCsFt|j|jƒ}t|j|jƒ}|jj||ƒ|_dS(sStart accepting connections.N(RRR t_get_socket_pathRRt listen_unixR(R tfactoryt socket_path((s1/usr/lib/python2.7/dist-packages/landscape/amp.pytstart)scCs |jjƒS(sStop accepting connections.(Rt stopListening(R ((s1/usr/lib/python2.7/dist-packages/landscape/amp.pytstop/s(t__name__t __module__t__doc__RRRRR(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyRs    cCs[i}xNt|ƒD]@}t||ƒ}t|ddƒ}|dk r||||jj}|jƒ|jjƒd|_ndS(s4Disconnect the L{RemoteObject} that we have created.N(R(RRt stopTryingt disconnect(R R((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyRA‘s    N( RRRRRRRRR%tFalseRR?RA(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyR&Ks *cCstjj|j|jdƒS(Ns.sock(tostpathtjoint sockets_pathR#(RR((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyRšs( RRCR/tlandscape.lib.ampRRRtobjectRR R%R&R(((s1/usr/lib/python2.7/dist-packages/landscape/amp.pyt s    O