-ν
Ϋ?c       s   d  Z  d k Z d k Z d k Z d k Z d k Z d k Z d f  d     YZ d e i f d     YZ	 d e i f d     YZ
 d S(   st   Monitor behavior of ZEO server and record statistics.

$Id: monitor.py,v 1.3.18.1 2003/09/15 21:26:53 tim_one Exp $
Ns   StorageStatsc      s)   t  Z d  Z d   Z d   Z d   Z RS(   s   Per-storage usage statistics.c    sm   d |  _ d |  _ d |  _ d |  _ d |  _ d |  _ d |  _ t |  _	 d |  _
 d |  _ t i   |  _ d  S(   Ni    (   s   selfs   loadss   storess   commitss   abortss   active_txnss   clientss   verifying_clientss   Nones	   lock_times	   conflictss   conflicts_resolveds   times   ctimes   start(   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   __init__ s    										c    s   | i d  } x| D]} | i d d  \ } } | d j o | |  _ nK| d j o t |  |  _	 n+| d j o t |  |  _
 n| d j o t |  |  _ nλ | d j o t i   t |  |  _ nΑ | d	 j o t |  |  _ n‘ | d
 j o t |  |  _ n | d j o t |  |  _ na | d j o t |  |  _ nA | d j o t |  |  _ n! | d j o t |  |  _ n q Wd  S(   Ns   
s   :i   s   Server starteds   Clientss   Clients verifyings   Active transactionss   Commit lock held fors   Commitss   Abortss   Loadss   Storess	   Conflictss   Conflicts resolved(   s   ss   splits   liness   lines   fields   values   selfs   starts   ints   clientss   verifying_clientss   active_txnss   times	   lock_times   commitss   abortss   loadss   storess	   conflictss   conflicts_resolved(   s   selfs   ss   fields   lines   liness   value(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   parse+ s4     c    sω   | d I|  i IJ| d I|  i IJ| d I|  i IJ| d I|  i IJ|  i o- t i   |  i } | d It	 |  IJn | d I|  i
 IJ| d I|  i IJ| d I|  i IJ| d	 I|  i IJ| d
 I|  i IJ| d I|  i IJd  S(   Ns   Server started:s   Clients:s   Clients verifying:s   Active transactions:s   Commit lock held for:s   Commits:s   Aborts:s   Loads:s   Stores:s
   Conflicts:s   Conflicts resolved:(   s   fs   selfs   starts   clientss   verifying_clientss   active_txnss	   lock_times   times   howlongs   ints   commitss   abortss   loadss   storess	   conflictss   conflicts_resolved(   s   selfs   fs   howlong(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   dumpH s    
(   s   __name__s
   __module__s   __doc__s   __init__s   parses   dump(    (    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   StorageStats s    		s   StatsClientc      s>   t  Z d   Z d   Z d   Z d   Z d   Z d   Z RS(   Nc    s)   t  i i |  |  g  |  _ d |  _ d  S(   Ni    (   s   asyncores
   dispatchers   __init__s   selfs   socks   bufs   closed(   s   selfs   socks   addr(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   __init__Y s    	c    s   d |  _ d  S(   Ni   (   s   selfs   closed(   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   close^ s    c    s   |  i i |  d  S(   N(   s   selfs   bufs   appends   s(   s   selfs   s(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   writec s    c    s   t  |  i  Sd  S(   N(   s   lens   selfs   buf(   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   writablef s    c    s   d Sd  S(   Ni    (    (   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   readablei s    c    s   d i  |  i  } g  |  _ |  i i |  } | t |  j  o |  i i | |   n |  i	 o |  i o t
 i i |   n d  S(   Ns    (   s   joins   selfs   bufs   ss   sockets   sends   ns   lens   appends   closeds   asyncores
   dispatchers   close(   s   selfs   ss   n(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   handle_writem s    	(   s   __name__s
   __module__s   __init__s   closes   writes   writables   readables   handle_write(    (    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   StatsClientW s   					s   StatsServerc      s;   t  Z e Z d   Z d   Z d   Z d   Z d   Z RS(   Nc    sΉ   t  i i |   | |  _ | |  _ t |  i  t i j o |  i	 t
 i t
 i  n |  i	 t
 i t
 i  |  i   t i d t i d t |  i   |  i |  i  |  i d  d  S(   Ns   ZSMs   monitor listening on %si   (   s   asyncores
   dispatchers   __init__s   selfs   addrs   statss   types   typess	   TupleTypes   create_sockets   sockets   AF_INETs   SOCK_STREAMs   AF_UNIXs   set_reuse_addrs   zLOGs   LOGs   INFOs   reprs   binds   listen(   s   selfs   addrs   stats(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   __init__{ s    		
#c    s   d Sd  S(   Ni    (    (   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   writable s    c    s   d Sd  S(   Ni   (    (   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   readable s    c    s`   y |  i   \ } } Wn t i j
 o d  Sn X|  i | |  } |  i |  | i	   d  S(   N(
   s   selfs   accepts   socks   addrs   sockets   errors   StatsConnectionClasss   fs   dumps   close(   s   selfs   fs   socks   addr(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   handle_accept s    	c    s   | d t i IJ| t i   IJ| J|  i i   } | i	   x< | D]4 } |  i | } | d I| IJ| i |  | JqE Wd  S(   Ns   ZEO monitor server version %ss   Storage:(   s   fs   ZEOs   versions   times   ctimes   selfs   statss   keyss   Ls   sorts   ks   dump(   s   selfs   fs   statss   ks   L(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   dump s    
 (	   s   __name__s
   __module__s   StatsClients   StatsConnectionClasss   __init__s   writables   readables   handle_accepts   dump(    (    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   StatsServerw s   					(   s   __doc__s   asyncores   sockets   times   typess   ZEOs   zLOGs   StorageStatss
   dispatchers   StatsClients   StatsServer(	   s   StatsServers   asyncores   sockets   times   zLOGs   StatsClients   StorageStatss   ZEOs   types(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   ? s   						< 