-í
.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 B 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    sc     "   |  _  # |  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Ő   . / yV 0 |  i i |  } 1 | o 4 |  i   5 d Sn 7 |  i t |  8 | SWnr 9 t i j
 o` } ; |  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      sM   B t  Z D e Z E e Z G d   Z L d   Z S d   Z Y d   Z	 RS(   Nc    s:   G H t  i | |   I |  i | d  J 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    sa   L M y N t  | d  |  _ Wn; O t j
 o, } P t |  _ Q 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    sH   S T |  i } U |  i d 7_ V |  i | t t |   W | 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    sE   Y Z 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   				$