-ν
Ϋ?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 n, d Z d Z	 d Z
 d e  i f d     YZ d  S(   Ns   posixs   triggerc      sb   t  Z d  Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 e
 d  Z d	   Z RS(
   s5   Wake up a call to select() running in the main threadc    sZ   t  i   \ } } |  _ | |  _ 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    sP   |  i oA d |  _ |  i   x |  i D] } t i |  q( Wg  |  _ 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   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   d Sd  S(   Ni   (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   readableP s    c    s   d Sd  S(   Ni    (    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   writableS s    c    s   d  S(   N(    (   s   self(    (    s8   /usr/pkg/lib/python2.2/site-packages/ZEO/zrpc/trigger.pys   handle_connectV s    c    s   |  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    sT   | o6 |  i i   z |  i i |  Wd  |  i i   Xn 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°   y |  i d  Wn t i j
 o d  Sn X|  i i   z` xP |  i D]E } y |   Wn1 t i	   \ } } } } d | | | f GHn XqH Wg  |  _ 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_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      sY   t  Z d Z d   Z d   Z d   Z d   Z d   Z d   Z e	 d  Z
 d	   Z RS(
   Ni    c    si  t  i  t  i t  i  } t  i  t  i t  i  } | i t  i d d  xx t t  D]a } t
 i d t t
 _ t t
 i } t | f } y | i |  Wn t  i j
 o
 qS n XPqS Wt 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    s@   |  i o1 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    sQ   | o6 |  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   z` xP |  i D]E } y |   Wn1 t i	   \ } } } } d | | | f GHn XqH Wg  |  _ 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