-í
Û„?c       s#  d  k  Z  d  k Z d  k Z d  k Z d  k Z d  k Z d  k Z d k l Z d k	 l
 Z
 l Z d k l Z l Z d k l Z d k l Z d  k Z d k l Z d Z d Z d	 f  d
 „  ƒ  YZ d e f d „  ƒ  YZ d e i e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d  S(   N(   s   smac(   s	   ZRPCErrors   DisconnectedError(   s
   short_reprs   log(   s
   Marshaller(   s   trigger(   s   POSExceptions   .replyi   s   Delayc      s)   t  Z d  Z d „  Z d „  Z d „  Z RS(   sò   Used to delay response to client for synchronous calls

    When a synchronous call is made and the original handler returns
    without handling the call, it returns a Delay object that prevents
    the mainloop from sending a response.
    c    s   | |  _  | |  _ | |  _ d  S(   N(   s   msgids   selfs
   send_replys   return_error(   s   selfs   msgids
   send_replys   return_error(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys
   set_sender) s    		c    s   |  i |  i | ƒ d  S(   N(   s   selfs
   send_replys   msgids   obj(   s   selfs   obj(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   reply. s    c    s4   t  d t i d | ƒ|  i |  i d | d  Œ d  S(   Ns   Error raised in delayed methods   errori    i   (   s   logs   zLOGs   ERRORs   exc_infos   selfs   return_errors   msgid(   s   selfs   exc_info(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   error1 s    (   s   __name__s
   __module__s   __doc__s
   set_senders   replys   error(    (    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   Delay! s    		s   MTDelayc      s,   t  Z d „  Z d „  Z d „  Z d „  Z RS(   Nc    s   t  i ƒ  |  _ d  S(   N(   s	   threadings   Events   selfs   ready(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   __init__7 s    c    s'   t  i |  | | | ƒ |  i i ƒ  d  S(   N(   s   Delays
   set_senders   selfs   msgids
   send_replys   return_errors   readys   set(   s   selfs   msgids
   send_replys   return_error(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys
   set_sender: s    c    s!   |  i i ƒ  t i |  | ƒ d  S(   N(   s   selfs   readys   waits   Delays   replys   obj(   s   selfs   obj(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   reply> s    c    s!   |  i i ƒ  t i |  | ƒ d  S(   N(   s   selfs   readys   waits   Delays   errors   exc_info(   s   selfs   exc_info(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   errorB s    (   s   __name__s
   __module__s   __init__s
   set_senders   replys   error(    (    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   MTDelay5 s   			s
   Connectionc      ss  t  Z d  Z e i i Z e i i Z e i i	 Z
 d Z d Z e d „ Z d „  Z e Z e i e d „ Z d „  Z d „  Z d „  Z e d	 „ Z d
 „  Z d „  Z d „  Z d „  Z d „  Z d d „ Z d „  Z d „  Z d „  Z d „  Z	 d „  Z d „  Z  d „  Z! d „  Z" d „  Z# d „  Z$ d „  Z% d „  Z& d „  Z' d d „ Z( d  „  Z) d! „  Z* d" „  Z+ d# d$ „ Z, RS(%   sÇ  Dispatcher for RPC on object on both sides of socket.

    The connection supports synchronous calls, which expect a return,
    and asynchronous calls, which do not.

    It uses the Marshaller class to handle encoding and decoding of
    method calls and arguments.  Marshaller uses pickle to encode
    arbitrary Python objects.  The code here doesn't ever see the wire
    format.

    A Connection is designed for use in a multithreaded application,
    where a synchronous call must block until a response is ready.

    A socket connection between a client and a server allows either
    side to invoke methods on the other side.  The processes on each
    end of the socket use a Connection object to manage communication.

    The Connection deals with decoded RPC messages.  They are
    represented as four-tuples containing: msgid, flags, method name,
    and a tuple of method arguments.

    The msgid starts at zero and is incremented by one each time a
    method call message is sent.  Each side of the connection has a
    separate msgid state.

    When one side of the connection (the client) calls a method, it
    sends a message with a new msgid.  The other side (the server),
    replies with a message that has the same msgid, the string
    ".reply" (the global variable REPLY) as the method name, and the
    actual return value in the args position.  Note that each side of
    the Connection can initiate a call, in which case it will be the
    client for that particular call.

    The protocol also supports asynchronous calls.  The client does
    not wait for a return value for an asynchronous call.  The only
    defined flag is ASYNC.  If a method call message has the ASYNC
    flag set, the server will raise an exception.

    If a method call raises an Exception, the exception is propagated
    back to the client via the REPLY message.  The client side will
    raise any exception it receives instead of returning the value to
    the caller.
    s   Z200s   Z201c    sö   t  |  _ t ƒ  |  _ d |  _ d |  _ t  |  _ t | t
 i ƒ o d | |  _ n d | |  _ |  i | | ƒ d |  _ t  |  _ |  i ƒ  h  |  |  i <|  _ t i ƒ  |  _ t i ƒ  |  _ h  |  _ d |  _ t  |  _ |  i | ƒ |  i ƒ  d  S(   Ni    s   zrpc-conn:%s:%ds   zrpc-conn:%s(   s   Nones   selfs   objs
   Marshallers   marshals   closeds   msgids   peer_protocol_versions
   isinstances   addrs   typess	   TupleTypes	   log_labels   _Connection__super_inits   socks	   thr_asyncs   triggers   _prepare_asyncs   _filenos   _maps	   threadings   Locks
   msgid_locks	   Conditions   replies_conds   repliess   waiting_for_replys   delay_sesskeys   register_objects	   handshake(   s   selfs   socks   addrs   obj(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   __init__‹ s(    						
			c    s   d |  i i |  i f Sd  S(   Ns   <%s %s>(   s   selfs	   __class__s   __name__s   addr(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   __repr__® s    c    s    t  i |  i | | d | ƒd  S(   Ns   error(   s   zLOGs   LOGs   selfs	   log_labels   levels   messages   error(   s   selfs   messages   levels   error(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   log³ s    c    s@   |  i o d  Sn |  i i ƒ  d |  _ |  i ƒ  |  i ƒ  d  S(   Ni   (   s   selfs   closeds   _maps   clears   close_triggers   _Connection__super_close(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   close¶ s    
	
c    s%   |  i t j	 o |  i i ƒ  n d  S(   N(   s   selfs   triggers   Nones   close(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   close_trigger¾ s    c    s   | |  _  d S(   s4   Register obj as the true object to invoke methods onN(   s   objs   self(   s   selfs   obj(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   register_objectÃ s     c    s'   |  i |  _ |  i | p |  i ƒ d  S(   N(   s   selfs   recv_handshakes   message_inputs   message_outputs   protos   protocol_version(   s   selfs   proto(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   handshakeÇ s    c    s…   |  ` | |  _ |  i | j o |  i j n o |  i d | d t i ƒn1 |  i d t	 | ƒ d t i
 ƒt d | ƒ ‚ d  S(   Ns   received handshake %rs   levels   bad handshake %ss   bad handshake %r(   s   selfs   message_inputs   protos   peer_protocol_versions   oldest_protocol_versions   protocol_versions   logs   zLOGs   INFOs
   short_reprs   ERRORs	   ZRPCError(   s   selfs   proto(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   recv_handshakeÖ s    	$ c    s\   |  i i | ƒ \ } } } } | t j o |  i	 | | | ƒ n |  i
 | | | | ƒ d S(   s,   Decoding an incoming message and dispatch itN(   s   selfs   marshals   decodes   messages   msgids   flagss   names   argss   REPLYs   handle_replys   handle_request(   s   selfs   messages   flagss   names   msgids   args(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   message_inputà s      c    sF   |  i i ƒ  z$ | | f |  i | <|  i i ƒ  Wd  |  i i ƒ  Xd  S(   N(	   s   selfs   replies_conds   acquires   flagss   argss   repliess   msgids	   notifyAlls   release(   s   selfs   msgids   flagss   args(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   handle_replyñ s      c 	   s™  |  i | ƒ o) d | t |  i ƒ f } t | ƒ ‚ n t |  i | ƒ } y* d |  _	 z | | Œ  } Wd  d |  _	 XWn| t t f j
 o
 ‚  nb t j
 oU } t i ƒ  } |  i d | | f t i d | ƒ| d  } |  i | | | Œ Sn X| t @o1 | t j	 o  t d | t | ƒ f ƒ ‚ n n> t | t ƒ o | i | |  i |  i ƒ n |  i | | ƒ |  i o |  i  |  i ƒ t |  _ n d  S(   Ns   Invalid method name: %s on %si   i    s   %s() raised exception: %ss   errori   s!   async method %s returned value %s(!   s   selfs   check_methods   names   reprs   objs   msgs	   ZRPCErrors   getattrs   meths   waiting_for_replys   argss   rets
   SystemExits   KeyboardInterrupts	   Exceptions   syss   exc_infos   errors   logs   zLOGs   INFOs   return_errors   msgids   flagss   ASYNCs   Nones
   short_reprs
   isinstances   Delays
   set_senders
   send_replys   delay_sesskeys    _Connection__super_setSessionKey(	   s   selfs   msgids   flagss   names   argss   msgs   meths   rets   error(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   handle_requestü s:     	 

$ 
c    sB   t  i ƒ  d t j o t  i ƒ  ‚ n |  i d ƒ |  i ƒ  d  S(   Ni    s   Error caught in asyncore(   s   syss   exc_infos
   SystemExits   selfs	   log_errors   close(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   handle_error$s    s   No error message suppliedc    s#   |  i | t i d t i ƒ  ƒd  S(   Ns   error(   s   selfs   logs   msgs   zLOGs   ERRORs   syss   exc_info(   s   selfs   msg(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   log_error*s    c    s,   | i d ƒ o t Sn t |  i | ƒ Sd  S(   Ns   _(   s   names
   startswiths   Nones   hasattrs   selfs   obj(   s   selfs   name(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   check_method-s    c    s§   y |  i i | d t | ƒ } Wnj |  i i j
 oX y t | ƒ } Wn d } n Xt
 d | ƒ } |  i i | d t t
 | f ƒ } n X|  i | ƒ |  i ƒ  d  S(   Ni    s   <unreprable>s   Couldn't pickle return %.100s(   s   selfs   marshals   encodes   msgids   REPLYs   rets   msgs   errorss
   short_reprs   rs	   ZRPCErrors   errs   message_outputs   poll(   s   selfs   msgids   rets   rs   errs   msg(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys
   send_reply3s    
&c    s÷   | t @o |  i d |  ƒ d  Sn t | ƒ t i j	 o | | f } n y% |  i	 i
 | d t | | f ƒ } Wnj |  i	 i j
 oX y t | ƒ } Wn d } n Xt d | ƒ } |  i	 i
 | d t t | f ƒ } n X|  i | ƒ |  i ƒ  d  S(   Ns&   Asynchronous call raised exception: %si    s   <unreprable>s   Couldn't pickle error %.100s(   s   flagss   ASYNCs   selfs	   log_errors   types	   err_values   typess   InstanceTypes   err_types   marshals   encodes   msgids   REPLYs   msgs   errorss
   short_reprs   rs	   ZRPCErrors   errs   message_outputs   poll(   s   selfs   msgids   flagss   err_types	   err_values   errs   rs   msg(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   return_error@s     %
&c    s(   |  i o | |  _ n |  i | ƒ d  S(   N(   s   selfs   waiting_for_replys   keys   delay_sesskeys    _Connection__super_setSessionKey(   s   selfs   key(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   setSessionKeySs    
c    sk   |  i i ƒ  z |  i } |  i d |  _ Wd  |  i i ƒ  X|  i i | | | | ƒ } |  i | ƒ | Sd  S(   Ni   (   s   selfs
   msgid_locks   acquires   msgids   releases   marshals   encodes   flagss   methods   argss   bufs   message_output(   s   selfs   methods   argss   flagss   msgids   buf(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   send_call\s    	  c    s±   |  i o t ƒ  ‚ n |  i | | d ƒ } |  i | ƒ \ } } t
 | t i ƒ o> t | ƒ d j o+ t | d ƒ t i j o t | d t ƒ o | d } | ‚ n | Sd  S(   Ni    i   (   s   selfs   closeds   DisconnectedErrors	   send_calls   methods   argss   msgids   waits   r_flagss   r_argss
   isinstances   typess	   TupleTypes   lens   types	   ClassTypes
   issubclasss	   Exceptions   inst(   s   selfs   methods   argss   msgids   r_argss   r_flagss   inst(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   callks    
T

c    sG   |  i o t ƒ  ‚ n |  i | | d ƒ } t i d |  i	 ƒ | Sd  S(   Ni    f0.01(
   s   selfs   closeds   DisconnectedErrors	   send_calls   methods   argss   msgids   asyncores   polls   _map(   s   selfs   methods   argss   msgid(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   _deferred_call~s
    
c    sr   |  i | ƒ \ } } t | t i ƒ o+ t | d ƒ t i	 j o t
 | d t ƒ o | d } | ‚ n | Sd  S(   Ni    i   (   s   selfs   waits   msgids   r_flagss   r_argss
   isinstances   typess	   TupleTypes   types	   ClassTypes
   issubclasss	   Exceptions   inst(   s   selfs   msgids   r_flagss   insts   r_args(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   _deferred_wait…s
    A

c    s8   |  i o t ƒ  ‚ n |  i | | t ƒ |  i ƒ  d  S(   N(   s   selfs   closeds   DisconnectedErrors	   send_calls   methods   argss   ASYNCs   poll(   s   selfs   methods   args(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   callAsyncs    
c    s.   |  i o t ƒ  ‚ n |  i | | t ƒ d  S(   N(   s   selfs   closeds   DisconnectedErrors	   send_calls   methods   argss   ASYNC(   s   selfs   methods   args(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   callAsyncNoPoll•s    
c    s   d |  _ t i |  i ƒ d  S(   Ni    (   s   selfs	   thr_asyncs   ThreadedAsyncs   register_loop_callbacks	   set_async(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   _prepare_asyncŸs    	c    s   t  ƒ  |  _  d |  _ d  S(   Ni   (   s   triggers   selfs	   thr_async(   s   selfs   map(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   set_async¥s    c    s   |  i o d Sn d Sd  S(   Ni   i    (   s   selfs	   thr_async(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   is_async©s    
i
   c    si   y |  i i ƒ  WnQ t j
 oE |  i i ƒ  t ƒ  |  _ | d j o |  i d | d ƒ n n Xd  S(   Ni    s   tryagaini   (   s   selfs   triggers   pull_triggers   OSErrors   closes   tryagains   _pull_trigger(   s   selfs   tryagain(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   _pull_trigger°s    c    sR  |  i ƒ  o |  i ƒ  n d } |  i i ƒ  zxd o |  i o t ƒ  ‚ n |  i i	 | ƒ } | t j	 o |  i | =| Sn |  i ƒ  o |  i i d ƒ n” |  i i ƒ  zu y2 t i | |  i ƒ | d j  o | | 7} n Wn< t i j
 o- } |  i d | d t i ƒ|  i ƒ  n XWd |  i i ƒ  Xq4 WWd |  i i ƒ  Xd S(   s,   Invoke asyncore mainloop and wait for reply.f0.001i   f10.0f1.0s$   Closing.  asyncore.poll() raised %s.s   levelN(   s   selfs   is_asyncs   _pull_triggers   delays   replies_conds   acquires   closeds   DisconnectedErrors   repliess   gets   msgids   replys   Nones   waits   releases   asyncores   polls   _maps   selects   errors   errs   logs   zLOGs   BLATHERs   close(   s   selfs   msgids   delays   errs   reply(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   wait¹sB       

    c    s#   x |  i ƒ  o |  i ƒ  q Wd S(   s/   Invoke poll() until the output buffer is empty.N(   s   selfs   writables   poll(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   flushæs
       c    s2   |  i ƒ  o |  i ƒ  n t i d |  i ƒ d S(   s4   Invoke asyncore mainloop to get pending message out.f0.0N(   s   selfs   is_asyncs   _pull_triggers   asyncores   polls   _map(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   pollís
      i    c 	   s`  |  i ƒ  o d Sn |  i g } } g  } x.| o |  i o|  i ƒ  o |  i g } n g  } y% t	 i	 | | | | ƒ \ } } } Wn< t	 i j
 o- } | d t i j o d } q. n ‚  n Xd } | o> y |  i ƒ  Wn) t i j
 o
 ‚  n |  i ƒ  n Xn | o> y |  i ƒ  Wn) t i j
 o
 ‚  n |  i ƒ  n Xn q. Wd S(   s7   Invoke mainloop until any pending messages are handled.Ni    (   s   selfs   is_asyncs   _filenos   rs   r_ins   x_ins   closeds   writables   w_ins   selects   timeouts   ws   xs   errors   errs   errnos   EINTRs   handle_read_events   asyncores   ExitNows   handle_errors   handle_write_event(	   s   selfs   timeouts   errs   x_ins   rs   ws   xs   r_ins   w_in(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   pendingösB      	 %	(-   s   __name__s
   __module__s   __doc__s   smacs   SizedMessageAsyncConnections   __init__s   _Connection__super_inits   closes   _Connection__super_closes   setSessionKeys    _Connection__super_setSessionKeys   oldest_protocol_versions   protocol_versions   Nones   __repr__s   __str__s   zLOGs   BLATHERs   logs   close_triggers   register_objects	   handshakes   recv_handshakes   message_inputs   handle_replys   handle_requests   handle_errors	   log_errors   check_methods
   send_replys   return_errors	   send_calls   calls   _deferred_calls   _deferred_waits	   callAsyncs   callAsyncNoPolls   _prepare_asyncs	   set_asyncs   is_asyncs   _pull_triggers   waits   flushs   polls   pending(    (    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys
   ConnectionF sL   + #					
			(										
		
					-			s   ManagedServerConnectionc      s2   t  Z d  Z e i Z e i Z d „  Z d „  Z RS(   s    Server-side Connection subclass.c    s0   | |  _  |  i | | | ƒ |  i i |  ƒ d  S(   N(   s   mgrs   selfs$   _ManagedServerConnection__super_inits   socks   addrs   objs   notifyConnected(   s   selfs   socks   addrs   objs   mgr(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   __init__0s    	c    s+   |  i i ƒ  |  i i |  ƒ |  i ƒ  d  S(   N(   s   selfs   objs   notifyDisconnecteds   mgrs
   close_conns%   _ManagedServerConnection__super_close(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   close5s    (   s   __name__s
   __module__s   __doc__s
   Connections   __init__s$   _ManagedServerConnection__super_inits   closes%   _ManagedServerConnection__super_close(    (    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   ManagedServerConnection+s
    			s   ManagedConnectionc      sz   t  Z d  Z e i Z e i Z d „  Z d „  Z d „  Z	 d „  Z
 d „  Z d „  Z d „  Z d „  Z d	 „  Z d
 „  Z RS(   s    Client-side Connection subclass.c    s*   | |  _  |  i | | | ƒ |  i ƒ  d  S(   N(   s   mgrs   selfs   _ManagedConnection__super_inits   socks   addrs   objs   check_mgr_async(   s   selfs   socks   addrs   objs   mgr(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   __init__?s    	c    s%   |  i |  _ |  i |  _ g  |  _ d  S(   N(   s   selfs   recv_handshakes   message_inputs   queue_outputs   message_outputs   output_queue(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   handshakeks    c    s   |  i i | ƒ d  S(   N(   s   selfs   output_queues   appends   message(   s   selfs   message(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   queue_outputqs    c    sf   |  ` t | |  i ƒ } t i |  | ƒ |  i | ƒ |  i } |  ` x | D] } |  i | ƒ qK Wd  S(   N(
   s   selfs   message_outputs   mins   protos   protocol_versions
   Connections   recv_handshakes   output_queues   queues   message(   s   selfs   protos   queues   message(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   recv_handshakets    	 c    s
   |  ` d  S(   N(   s   selfs   trigger(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   close_trigger€s    c    s   d  S(   N(    (   s   selfs   map(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys	   set_async„s    c    s   d  S(   N(    (   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   _prepare_async‡s    c    s@   |  i o
 |  i i o  d |  _ |  i i |  _ d Sn d Sd  S(   Ni   i    (   s   selfs	   thr_asyncs   mgrs   trigger(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   check_mgr_async‹s     	c    s    |  i o d Sn |  i ƒ  Sd  S(   Ni   (   s   selfs	   thr_asyncs   check_mgr_async(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   is_async”s    
c    s   |  i i |  ƒ |  i ƒ  d  S(   N(   s   selfs   mgrs
   close_conns   _ManagedConnection__super_close(   s   self(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   closešs    (   s   __name__s
   __module__s   __doc__s
   Connections   __init__s   _ManagedConnection__super_inits   closes   _ManagedConnection__super_closes	   handshakes   queue_outputs   recv_handshakes   close_triggers	   set_asyncs   _prepare_asyncs   check_mgr_asyncs   is_async(    (    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   ManagedConnection:s    			,									(   s   asyncores   errnos   selects   syss	   threadings   typess   ThreadedAsyncs   ZEO.zrpcs   smacs   ZEO.zrpc.errors	   ZRPCErrors   DisconnectedErrors   ZEO.zrpc.logs
   short_reprs   logs   ZEO.zrpc.marshals
   Marshallers   ZEO.zrpc.triggers   triggers   zLOGs   ZODBs   POSExceptions   REPLYs   ASYNCs   Delays   MTDelays   SizedMessageAsyncConnections   objects
   Connections   ManagedServerConnections   ManagedConnection(   s   ManagedServerConnections   asyncores   smacs
   Connections   MTDelays   DisconnectedErrors   REPLYs   ASYNCs   POSExceptions   typess   syss
   short_reprs   ThreadedAsyncs   logs	   threadings   errnos   Delays
   Marshallers   triggers   selects   ManagedConnections   zLOGs	   ZRPCError(    (    s;   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/connection.pys   ? s*   								ÿ æ