-í
.f?c       s   d  Z  d k l Z d k Z d k Z d k l Z l Z l Z d k	 l
 Z
 d Z d Z d Z d Z d	 e
 f d
     YZ d e f d     YZ d S(   s@   A debugging version of the server that records network activity.(   s   nested_scopesN(   s   StorageServers
   ZEOStorages   log(   s   ManagedServerConnectioni   i   i   i   s   DebugManagedServerConnectionc      s#   t  Z d   Z d   Z d   Z RS(   Nc    sQ     |  _  |  i | | |    i |      d   |  _ |  i i	 |   d  S(   Nc    s    i   |  |  S(   N(   s   mgrs   _records	   record_ids   codes   data(   s   codes   data(   s	   record_ids   mgr(    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   <lambda>% s    (
   s   mgrs   selfs)   _DebugManagedServerConnection__super_inits   socks   addrs   objs   _record_connections	   record_ids   _records   notifyConnected(   s   selfs   socks   addrs   objs   mgrs	   record_id(    (   s   mgrs	   record_ids7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   __init__  s
    	c    s!   |  i t d  t i |   d  S(   Ns    (   s   selfs   _records
   CLOSE_CONNs   ManagedServerConnections   close(   s   self(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   close( s    c    sŤ   yD |  i i |  } | o |  i   d Sn |  i t |  | SWn` t i j
 oQ } |  i t
 |  | d t t t g j o |  i   d Sn t i |  n Xd  S(   Ns    i    (   s   selfs   sockets   recvs   buffer_sizes   datas   handle_closes   _records   DATAs   errors   whys   ERRORs
   ECONNRESETs   ENOTCONNs	   ESHUTDOWN(   s   selfs   buffer_sizes   datas   why(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   recv. s    

(   s   __name__s
   __module__s   __init__s   closes   recv(    (    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   DebugManagedServerConnection s   		s   DebugServerc      s8   t  Z e Z e Z d   Z d   Z d   Z d   Z	 RS(   Nc    s.   t  i | |   |  i | d  d |  _ d  S(   Ns   recordi   (   s   StorageServers   __init__s   argss   kwargss   selfs   _setup_records   _conn_counter(   s   selfs   argss   kwargs(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   __init__G s    c    sO   y t  | d  |  _ Wn2 t j
 o& } t |  _ t d | | f  n Xd  S(   Ns   abs    failed to open recordfile %s: %s(   s   opens   paths   selfs   _recordfiles   IOErrors   msgs   Nones   log(   s   selfs   paths   msg(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   _setup_recordL s
    	c    s9   |  i } |  i d 7_ |  i | t t |   | Sd  S(   Ni   (   s   selfs   _conn_counters   cids   _records   NEW_CONNs   strs   addr(   s   selfs   addrs   cid(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   _record_connectionS s    	c    s<   t  i d | t i   t |   | } |  i i	 |  d  S(   Ns   >iii(
   s   structs   packs   codes   times   lens   datas   ss   selfs   _recordfiles   write(   s   selfs   conns   codes   datas   s(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   _recordY s    ((
   s   __name__s
   __module__s   DebugZEOStorages   ZEOStorageClasss   DebugManagerConnections   ManagedServerConnectionClasss   __init__s   _setup_records   _record_connections   _record(    (    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   DebugServerB s   			(   s   __doc__s
   __future__s   nested_scopess   structs   times   ZEO.StorageServers   StorageServers
   ZEOStorages   logs   ZEO.zrpc.servers   ManagedServerConnections   NEW_CONNs
   CLOSE_CONNs   DATAs   ERRORs   DebugManagedServerConnections   DebugServer(   s   logs   nested_scopess   DebugManagedServerConnections   StorageServers   ERRORs   structs
   ZEOStorages   DebugServers   times   ManagedServerConnections
   CLOSE_CONNs   DATAs   NEW_CONN(    (    s7   /usr/pkg/lib/python2.2/site-packages/ZEO/DebugServer.pys   ? s   		$