-í
Û„?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   < 