-í
Û„?c       s­      d  k  Z   d  k Z  d  k Z  d  k Z  d  k Z  e i d j o   d e  i f d „  ƒ  YZ n8 ~ d Z  d Z	 € d Z
 ‚ d e  i f d „  ƒ  YZ d  S(   Ns   posixs   triggerc      sƒ    t  Z d  Z  7 d „  Z E d „  Z M d „  Z P d „  Z S d „  Z V d „  Z Y d „  Z	 \ e
 d „ Z e d	 „  Z RS(
   s5   Wake up a call to select() running in the main threadc    so   7 8 t  i ƒ  \ } } |  _ 9 | |  _ : t i i	 |  | ƒ ; t
 i ƒ  |  _ < g  |  _ = d |  _ d  S(   Ni    (   s   oss   pipes   rs   ws   selfs   _fdss   triggers   asyncores   file_dispatchers   __init__s   threads   allocate_locks   locks   thunkss   _closed(   s   selfs   rs   w(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   __init__7 s   c    sh   E F |  i oS G d |  _ H |  i ƒ  I x$ |  i DI ] } J t i | ƒ q7 WK g  |  _ n d  S(   Ni   (   s   selfs   _closeds   del_channels   _fdss   fds   oss   close(   s   selfs   fd(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   closeE s    	c    s   M N d t  |  ƒ Sd  S(   Ns   <select-trigger (pipe) at %x>(   s   ids   self(   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   __repr__M s   c    s   P Q d Sd  S(   Ni   (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   readableP s   c    s   S T d Sd  S(   Ni    (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   writableS s   c    s
   V W d  S(   N(    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_connectV s   c    s   Y Z |  i ƒ  d  S(   N(   s   selfs   close(   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_closeY s   c    sl   \ ] | oE ^ |  i i ƒ  _ z ` |  i i | ƒ Wd  a b |  i i ƒ  Xn c t i |  i	 d ƒ d  S(   Ns   x(
   s   thunks   selfs   locks   acquires   thunkss   appends   releases   oss   writes   trigger(   s   selfs   thunk(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   pull_trigger\ s   
c    sã   e f y g |  i d ƒ Wn  h t i j
 o i d  Sn Xj |  i i ƒ  k zx l xb |  i Dl ]T } m y n | ƒ  Wn: o p t i	 ƒ  \ } } } } q d | | | f GHn Xq` Ws g  |  _ Wd  t u |  i i ƒ  Xd  S(   Ni    s&   exception in trigger thunk: (%s:%s %s)(   s   selfs   recvs   sockets   errors   locks   acquires   thunkss   thunks   asyncores   compact_tracebacks   nils   ts   vs   tbinfos   release(   s   selfs   tbinfos   thunks   nils   vs   t(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_reade s     	(   s   __name__s
   __module__s   __doc__s   __init__s   closes   __repr__s   readables   writables   handle_connects   handle_closes   Nones   pull_triggers   handle_read(    (    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   trigger s   	s	   127.0.0.1iîM  i2   c      sw   ‚ t  Z „ d Z † d „  Z ¬ d „  Z ´ d „  Z · d „  Z º d „  Z ½ d „  Z À e	 d „ Z
 É d	 „  Z RS(
   Ni    c    sÃ  † ‡ t  i  t  i t  i ƒ } ˆ t  i  t  i t  i ƒ } ‹ | i t  i d d ƒ Ž x– t t ƒ DŽ ]y }  t
 i d t t
 _  t t
 i } ‘ t | f } ’ y “ | i | ƒ Wn ” t  i j
 o • qb n X— Pqb W™ t d ‚ › | i d ƒ œ | i d ƒ  y ž | i | ƒ Wn Ÿ   n X¡ | i ƒ  \ } } ¢ | i ƒ  £ | i d ƒ ¤ | |  _
 ¦ t i i |  | ƒ § t i ƒ  |  _  ¨ g  |  _! © d |  _" ª d |  _# d  S(   Ni   s   Cannot bind trigger!i    ($   s   sockets   AF_INETs   SOCK_STREAMs   as   ws
   setsockopts   IPPROTO_TCPs   ranges   NPORTSs   is   triggers
   portoffsets   MINPORTs   ports   HOSTs   addresss   binds   errors   RuntimeErrors   listens   setblockings   connects   accepts   rs   addrs   closes   selfs   asyncores
   dispatchers   __init__s   threads   allocate_locks   locks   thunkss   _trigger_connecteds   _closed(   s   selfs   as   is   ws   addresss   rs   ports   addr(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   __init__† s:    	c    sR   ¬ ­ |  i o= ® d |  _ ¯ |  i ƒ  ± |  i i ƒ  ² |  i i ƒ  n d  S(   Ni   (   s   selfs   _closeds   del_channels   sockets   closes   trigger(   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   close¬ s
   c    s   ´ µ d t  |  ƒ Sd  S(   Ns!   <select-trigger (loopback) at %x>(   s   ids   self(   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   __repr__´ s   c    s   · ¸ d Sd  S(   Ni   (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   readable· s   c    s   º » d Sd  S(   Ni    (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   writableº s   c    s
   ½ ¾ d  S(   N(    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_connect½ s   c    si   À Á | oE Â |  i i ƒ  Ã z Ä |  i i | ƒ Wd  Å Æ |  i i ƒ  Xn Ç |  i i d ƒ d  S(   Ns   x(	   s   thunks   selfs   locks   acquires   thunkss   appends   releases   triggers   send(   s   selfs   thunk(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   pull_triggerÀ s   
c    sã   É Ê y Ë |  i d ƒ Wn  Ì t i j
 o Í d  Sn XÎ |  i i ƒ  Ï zx Ð xb |  i DÐ ]T } Ñ y Ò | ƒ  Wn: Ó Ô t i	 ƒ  \ } } } } Õ d | | | f GHn Xq` W× g  |  _ Wd  Ø Ù |  i i ƒ  Xd  S(   Ni    s&   exception in trigger thunk: (%s:%s %s)(   s   selfs   recvs   sockets   errors   locks   acquires   thunkss   thunks   asyncores   compact_tracebacks   nils   ts   vs   tbinfos   release(   s   selfs   tbinfos   thunks   nils   vs   t(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_readÉ s     	(   s   __name__s
   __module__s
   portoffsets   __init__s   closes   __repr__s   readables   writables   handle_connects   Nones   pull_triggers   handle_read(    (    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   trigger‚ s   		&	(   s   asyncores   oss   sockets   threads   errnos   names   file_dispatchers   triggers   HOSTs   MINPORTs   NPORTSs
   dispatcher(	   s   NPORTSs   HOSTs   triggers   asyncores   sockets   threads   errnos   MINPORTs   os(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   ? s    g			