-ํ
.f?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 W d e i f d     YZ	 w 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      s8    t  Z d  Z   d   Z + d   Z H d   Z RS(   s   Per-storage usage statistics.c    s     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  \ } } 0 | d j o 1 | |  _ n2 | d j o 3 t |  |  _	 na4 | d j o 5 t |  |  _
 n;6 | d j o 7 t |  |  _ n8 | d j o  : t i   t |  |  _ nๅ ; | d	 j o < t |  |  _ nฟ = | d
 j o > t |  |  _ n ? | d j o @ t |  |  _ ns A | d j o B t |  |  _ nM C | d j o D t |  |  _ n' E | d j o F 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#  H I | d I|  i IJJ | d I|  i IJK | d I|  i IJL | d I|  i IJM |  i o3 N t i   |  i } O | d It	 |  IJn P | d I|  i
 IJQ | d I|  i IJR | d I|  i IJS | d	 I|  i IJT | d
 I|  i IJU | 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      sS   W t  Z Y d   Z ^ d   Z c d   Z f d   Z i d   Z m d   Z RS(   Nc    s5   Y Z 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   c d |  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   f g 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   i k d Sd  S(   Ni    (    (   s   self(    (    s3   /usr/pkg/lib/python2.2/site-packages/ZEO/monitor.pys   readablei s   c    s   m n d i  |  i  } o g  |  _ p |  i i |  } q | t |  j  o r |  i i | |   n t |  i	 o |  i o u 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      sP   w t  Z y 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    sx     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	    xK | D ]@ }  |  i | }   | d I| IJก | i |  ข | JqZ 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   < 