| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/landscape/lib/ |
Upload File : |
ó
}9Rc @ sž d Z d d l m Z d d l m Z m Z m Z d d l m Z m Z d d l
m Z d d l m
Z
m Z m Z m Z m Z m Z m Z d d l m Z m Z m Z d e
f d „ ƒ YZ d
e f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ! d e f d „ ƒ YZ" d e f d „ ƒ YZ# d e f d „ ƒ YZ$ d S( s> Expose the methods of a remote object over AMP.
This module implements an AMP-based protocol for performing remote procedure
calls in a convenient and easy way. It's conceptually similar to DBus in that
it supports exposing a Python object to a remote process, with communication
happening over any Twisted-supported transport, e.g. Unix domain sockets.
For example let's say we have a Python process "A" that creates an instance of
this class::
class Greeter(object):
def hello(self, name):
return "hi %s!" % name
greeter = Greeter()
Process A can "publish" the greeter object by defining which methods are
exposed remotely and opening a Unix socket for incoming connections::
factory = MethodCallServerFactory(greeter, ["hello"])
reactor.listenUNIX("/some/socket/path", factory)
Then a second Python process "B" can connect to that socket and build a
"remote" greeter object, i.e. a proxy that forwards method calls to the
real greeter object living in process A::
factory = MethodCallClientFactory()
reactor.connectUNIX("/some/socket/path", factory)
def got_remote(remote_greeter):
deferred = remote_greeter.hello("Ted")
deferred.addCallback(lambda result: ... # result == "hi Ted!")
factory.getRemoteObject().addCallback(got_remote)
Note that when invoking a method via the remote proxy, the parameters
are required to be serializable with bpickle, so they can be sent over
the wire.
See also::
http://twistedmatrix.com/documents/current/core/howto/amp.html
for more details about the Twisted AMP protocol.
iÿÿÿÿ( t uuid4( t Deferredt
maybeDeferredt succeed( t
ServerFactoryt ReconnectingClientFactory( t Failure( t Argumentt Stringt Integert Commandt AMPt MAX_VALUE_LENGTHt CommandLocator( t loadst dumpst dumps_tablet MethodCallArgumentc B s/ e Z d Z d „ Z d „ Z e d „ ƒ Z RS( s A bpickle-compatible argument.c C s
t | ƒ S( s Serialize an argument.( R ( t selft inObject( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt toString> s c C s
t | ƒ S( s Unserialize an argument.( R ( R t inString( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt
fromStringB s c C s t | ƒ t k S( s% Check if an argument is serializable.( t typeR ( t clsR ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt checkF s ( t __name__t
__module__t __doc__R R t classmethodR ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR ; s t MethodCallErrorc B s e Z d Z RS( s* Raised when a L{MethodCall} command fails.( R R R ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR L s t
MethodCallc B sW e Z d Z d e ƒ f d e ƒ f d e ƒ f g Z d e ƒ f g Z i d e 6Z RS( sÅ Call a method on the object exposed by a L{MethodCallServerFactory}.
The command arguments have the following semantics:
- C{sequence}: An integer uniquely indentifying a the L{MethodCall}
being issued. The name 'sequence' is a bit misleading because it's
really a uuid, since its values in practice are not in sequential
order, they are just random values. The name is kept just for backward
compatibility.
- C{method}: The name of the method to invoke on the remote object.
- C{arguments}: A BPickled binary tuple of the form C{(args, kwargs)},
where C{args} are the positional arguments to be passed to the method
and C{kwargs} the keyword ones.
t sequencet methodt argumentst resultt METHOD_CALL_ERROR(
R R R R R R" R t responseR t errors( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR P s t MethodCallChunkc B sK e Z d Z d e ƒ f d e ƒ f g Z d e ƒ f g Z i d e 6Z RS( s Send a chunk of L{MethodCall} containing a portion of the arguments.
When a the arguments of a L{MethodCall} are bigger than 64k, they get split
in several L{MethodCallChunk}s that are buffered on the receiver side.
The command arguments have the following semantics:
- C{sequence}: The unique integer associated with the L{MethodCall} that
this L{MethodCallChunk} is part of.
- C{chunk}: A portion of the big BPickle C{arguments} string which is
being split and buffered.
R t chunkR# R$ ( R R R R R R" R% R R& ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR' k s
t MethodCallReceiverc B sD e Z d Z d „ Z e j d „ ƒ Z e j d „ ƒ Z d „ Z RS( s¼ Expose methods of a local object over AMP.
@param obj: The Python object to be exposed.
@param methods: The list of the object's methods that can be called
remotely.
c C s, t j | ƒ | | _ | | _ i | _ d S( N( R
t __init__t _objectt _methodst _pending_chunks( R t objt methods( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* Š s
c sÎ ˆ j j | d ƒ } | d k r@ | j | ƒ d j | ƒ } n t | ƒ \ } } | ˆ j k rt t d | ƒ ‚ n t ˆ j | ƒ } ‡ f d † } d „ } t
| | | Ž }
|
j | ƒ |
j | ƒ |
S( s Call an object's method with the given arguments.
If a connected client sends a L{MethodCall} for method C{foo_bar}, then
the actual method C{foo_bar} of the object associated with the protocol
will be called with the given C{args} and C{kwargs} and its return
value delivered back to the client as response to the command.
@param sequence: The integer that uniquely identifies the L{MethodCall}
being received.
@param method: The name of the object's method to call.
@param arguments: A bpickle'd binary tuple of (args, kwargs) to be
passed to the method. In case this L{MethodCall} has been preceded
by one or more L{MethodCallChunk}s, C{arguments} is the last chunk
of data.
t s Forbidden method '%s'c s i ˆ j | ƒ d 6S( NR# ( t
_check_result( R# ( R ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt
handle_result® s c S s t | j ƒ ‚ d S( N( R t value( t failure( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt handle_failure± s N(
R- t popt Nonet appendt joinR R, R t getattrR+ R t addCallbackt
addErrback( R R R! R" t chunkst argst kwargst method_funcR2 R5 t deferred( ( R s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt receive_method_call s
c C s' | j j | g ƒ j | ƒ i | d 6S( s Receive a part of a multi-chunk L{MethodCall}.
Add the received C{chunk} to the buffer of the L{MethodCall} identified
by C{sequence}.
R# ( R- t
setdefaultR8 ( R R R( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt receive_method_call_chunk¹ s c C s" t j | ƒ s t d ƒ ‚ n | S( s¿ Check that the C{result} we're about to return is serializable.
@return: The C{result} itself if valid.
@raises: L{MethodCallError} if C{result} is not serializable.
s Non-serializable result( R R R ( R R# ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR1 Ã s (
R R R R* R t responderRB R' RD R1 ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR) ‚ s
)
t MethodCallSenderc B s; e Z d Z d Z e Z d „ Z d „ Z g i d „ Z RS( s Call methods on a remote object over L{AMP} and return the result.
@param protocol: A connected C{AMP} protocol.
@param clock: An object implementing the C{IReactorTime} interface.
@ivar timeout: A timeout for remote method class, see L{send_method_call}.
i< c C s | | _ | | _ d S( N( t _protocolt _clock( R t protocolt clock( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* Ú s c sh t ƒ ‰ ‡ ‡ f d † } ‡ f d † } | j j | j | ƒ ‰ | j j | | } | j | ƒ ˆ S( s Send an L{AMP} command that will errback in case of a timeout.
@return: A deferred resulting in the command's response (or failure) if
the peer responds within C{self.timeout} seconds, or that errbacks
with a L{MethodCallError} otherwise.
c s+ ˆ j ƒ s d Sˆ j ƒ ˆ j | ƒ d S( N( t activet cancelt callback( R% ( RA t call( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt handle_responseç s
c s ˆ j t d ƒ ƒ d S( Nt timeout( t errbackR ( ( RA ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt handle_timeoutï s ( R RH t callLaterRP RG t
callRemotet addBoth( R t commandR? RO RR R# ( ( RA RN s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt _call_remote_with_timeoutÞ s
c
sø t | | f ƒ } t ƒ j ‰ g t d t | ƒ ˆ j ƒ D] } | | | ˆ j !^ q: ‰ t ƒ } t ˆ ƒ d k r² x: ˆ d D]+ } ‡ f d † } | j | ˆ | ƒ ƒ q€ Wn ‡ ‡ ‡ ‡ f d † } | j | ƒ | j d „ ƒ | j d ƒ | S( s— Send a L{MethodCall} command with the given arguments.
If a response from the server is not received within C{self.timeout}
seconds, the returned deferred will errback with a L{MethodCallError}.
@param method: The name of the remote method to invoke.
@param args: The positional arguments to pass to the remote method.
@param kwargs: The keyword arguments to pass to the remote method.
@return: A C{Deferred} firing with the return value of the method
invoked on the remote object. If the remote method itself returns
a deferred, we fire with the callback value of such deferred.
i i iÿÿÿÿc s ‡ ‡ ‡ f d † } | S( Nc s ˆ j j t d ˆ d ˆ ƒS( NR R( ( RG RT R' ( t x( R R R( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt <lambda> s ( ( R R( t
send_chunk( R ( R( R s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt create_send_chunk s c s) ˆ d } ˆ j t d ˆ d ˆ d | ƒS( NiÿÿÿÿR R! R" ( RW R ( t ignoredR( ( R R! R= R ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt send_last_chunk s
c S s | d S( NR# ( ( R% ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRY s N(
R R t intt xranget lent _chunk_sizeR R; RM R7 (
R R! R> R? R" t iR# R( R[ R] ( ( R R R= R! s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt send_method_callù s 9
( R R R RP R Ra R* RW Rc ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRF Î s t MethodCallServerProtocolc B s e Z d Z d „ Z RS( sC Receive L{MethodCall} commands over the wire and send back results.c C s t j | d t | | ƒ ƒd S( Nt locator( R R* R) ( R R. R/ ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* ( s ( R R R R* ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRd % s t MethodCallClientProtocolc B s e Z d Z d Z d „ Z RS( sA Send L{MethodCall} commands over the wire using the AMP protocol.c C s& | j d k r" | j j | ƒ n d S( s* Notify our factory that we're ready to go.N( t factoryR7 t clientConnectionMade( R ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt connectionMade1 s N( R R R R7 Rg Ri ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRf , s t RemoteObjectc B sV e Z d Z d „ Z d „ Z d d „ Z d d „ Z d d „ Z d „ Z d „ Z
RS( s An object able to transparently call methods on a remote object.
Any method call on a L{RemoteObject} instance will return a L{Deferred}
resulting in the return value of the same method call performed on
the remote object exposed by the peer.
c C s2 d | _ i | _ | | _ | j j | j ƒ d S( sÅ
@param factory: The L{MethodCallClientFactory} used for connecting to
the other peer. Look there if you need to tweak the behavior of
this L{RemoteObject}.
N( R7 t _sendert _pending_requestst _factoryt notifyOnConnectt _handle_connect( R Rg ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* ? s c s ‡ ‡ f d † } | S( s^ Return a function sending a L{MethodCall} for the given C{method}.
When the created function is called, it sends the an appropriate
L{MethodCall} to the remote peer passing it the arguments and
keyword arguments it was called with, and returning a L{Deferred}
resulting in the L{MethodCall}'s response value.
c s# t ƒ } ˆ j ˆ | | | ƒ | S( N( R t _send_method_call( R> R? RA ( R R! ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRc R s ( ( R R! Rc ( ( R R! s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt __getattr__J s c C s… | j j d | d | d | ƒ } | j | j | d | ƒ| j | j | | | | d | ƒ| j j d k r | j j j ƒ n d S( sA Send a L{MethodCall} command, adding callbacks to handle retries.R! R> R? RN N(
Rk Rc R; t _handle_resultR< t _handle_failureRm t fake_connectionR7 t flush( R R! R> R? RA RN R# ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRp Y s
c C s* | d k r | j ƒ n | j | ƒ d S( s& Handles a successful C{send_method_call} result.
@param response: The L{MethodCall} response.
@param deferred: The deferred that was returned to the caller.
@param call: If not C{None}, the scheduled timeout call associated with
the given deferred.
N( R7 RL RM ( R R# RA RN ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRr i s
c
C sð | j t k } | j j t k } | s- | rs | | j k rO | j j | ƒ n | rb | j ƒ n | j | ƒ d S| j j rÓ | d k rÓ t t d ƒ ƒ } | j j j
| j j | j | | | | d | ƒ} n | | | | f | j | <d S( s+ Called when a L{MethodCall} command fails.
If a failure is due to a connection error and if C{retry_on_reconnect}
is C{True}, we will try to perform the requested L{MethodCall} again
as soon as a new connection becomes available, giving up after the
specified C{timeout}, if any.
@param failure: The L{Failure} raised by the requested L{MethodCall}.
@param name: The method name associated with the failed L{MethodCall}.
@param args: The positional arguments of the failed L{MethodCall}.
@param kwargs: The keyword arguments of the failed L{MethodCall}.
@param deferred: The deferred that was returned to the caller.
@param call: If not C{None}, the scheduled timeout call associated with
the given deferred.
NRP RA ( R R Rm t retryOnReconnectt FalseRl R6 RL RQ t retryTimeoutR7 R RJ RS Rs (
R R4 R! R> R? RA RN t is_method_call_errort
dont_retryRP ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRs u s
c C s5 t | | j j ƒ | _ | j j r1 | j ƒ n d S( sa Handles a reconnection.
@param protocol: The newly connected protocol instance.
N( RF Rm RJ Rk Rv t _retry( R RI ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRo s c C sg | j j ƒ } | j j ƒ xD | rb | j ƒ \ } \ } } } } | j | | | | d | ƒq Wd S( s* Try to perform again requests that failed.RN N( Rl t copyt cleart popitemRp ( R t requestsRA R! R> R? RN ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR{ © s
N( R R R R* Rq R7 Rp Rr Rs Ro R{ ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRj 7 s
* t MethodCallServerFactoryc B s& e Z d Z e Z d „ Z d „ Z RS( s@ Expose a Python object using L{MethodCall} commands over C{AMP}.c C s | | _ | | _ d S( s
@param object: The object exposed by the L{MethodCallProtocol}s
instances created by this factory.
@param methods: A list of the names of the methods that remote peers
are allowed to call on the C{object} that we publish.
N( t objectR/ ( R R. R/ ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* ½ s c C s% | j | j | j ƒ } | | _ | S( N( RI R R/ Rg ( R t addrRI ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt
buildProtocolÇ s ( R R R Rd RI R* Rƒ ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR€ ¸ s
t MethodCallClientFactoryc B s€ e Z d Z d Z d Z e Z e Z e Z
d Z d Z
d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d
„ Z RS( sÞ
Factory for L{MethodCallClientProtocol}s exposing an object or connecting
to L{MethodCall} servers.
When used to connect, if the connection fails or is lost the factory
will keep retrying to establish it.
@ivar factor: The time factor by which the delay between two subsequent
connection retries will increase.
@ivar maxDelay: Maximum number of seconds between connection attempts.
@ivar protocol: The factory used to build protocol instances.
@ivar remote: The factory used to build remote object instances.
@ivar retryOnReconnect: If C{True}, the remote object returned by the
C{getRemoteObject} method will retry requests that failed, as a
result of a lost connection, as soon as a new connection is available.
@param retryTimeout: A timeout for retrying requests, if the remote object
can't perform them again successfully within this number of seconds,
they will errback with a L{MethodCallError}.
g¨ô—›wãù?i c C s4 | | _ | j | _ g | _ g | _ d | _ d S( sö
@param object: The object exposed by the L{MethodCallProtocol}s
instances created by this factory.
@param reactor: The reactor used by the created protocols
to schedule notifications and timeouts.
N( RJ t initialDelayt delayt _connectst _requestsR7 t _remote( R RJ ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR* ñ s
c C s9 | j d k r t | j ƒ St ƒ } | j j | ƒ | S( s‹ Get a L{RemoteObject} as soon as the connection is ready.
@return: A C{Deferred} firing with a connected L{RemoteObject}.
N( R‰ R7 R R Rˆ R8 ( R RA ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt getRemoteObjectþ s
c C s | j j | ƒ d S( sA Invoke the given C{callback} when a connection is re-established.N( R‡ R8 ( R RM ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRn s c C s | j j | ƒ d S( s, Remove the given C{callback} from listeners.N( R‡ t remove( R RM ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt dontNotifyOnConnect
s c C sV | j d k r$ | j | ƒ | _ n x | j D] } | | ƒ q. W| j | j ƒ d S( s2 Called when a newly built protocol gets connected.N( R‰ R7 t remoteR‡ t _fire_requests( R RI RM ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRh s
c C s6 t j | | | ƒ | j d k r2 | j | ƒ n d S( s0 Try to connect again or errback pending request.N( R t clientConnectionFailedt _callIDR7 RŽ ( R t connectort reason( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR s c C s | j ƒ t j | | ƒ } | S( N( t
resetDelayR Rƒ ( R R‚ RI ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRƒ % s
c C s5 | j } g | _ x | D] } | j | ƒ q Wd S( sY
Fire all pending L{getRemoteObject} deferreds with the given C{result}.
N( Rˆ RM ( R R# R RA ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyRŽ * s
N( R R R t factort maxDelayRf RI Rj R Rw Rv R7 Rx Rt R* RŠ Rn RŒ Rh R Rƒ RŽ ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyR„ Í s
N(% R t uuidR t twisted.internet.deferR R R t twisted.internet.protocolR R t twisted.python.failureR t twisted.protocols.ampR R R R
R R R
t landscape.lib.bpickleR R R R t ExceptionR R R' R) R RF Rd Rf Rj R€ R„ ( ( ( s5 /usr/lib/python2.7/dist-packages/landscape/lib/amp.pyt <module>. s" 4 LW