-ν
ιΆ<c       sΐ     d  k  Z   d k  l Z l Z l Z l Z  e  i d   d k T d  k Z 	 d  k Z 
 d  k	 Z	  d  k
 Z
  d  k Z  d Z  d Z  d f  d     YZ  d e e f d	     YZ  d
 e e f d     YZ  d f  d     YZ ' d Z ) d d  Z 0 d   Z : d   Z E d e
 i f d     YZ T d a U d   Z Z d Z [ g  Z \ d   Z d d   Z l d   Z  ~ e! e" g Z#  e$ e d  o  e# i% e&  n  e' e( g Z)  e$ e d  o  e) i% e*  n  e$ e d  o  g  Z+  g  Z, n]  d e- e. f d     YZ/  e. e0 e/ g Z+  d e- e1 f d      YZ2  e1 e3 e2 g Z,  d!   Z4  d"   Z5 € e6 d# j o ₯ e5   n d  S($   N(   s   verboses   verifys   TESTFNs   TestSkippeds   network(   s   *i   f0.5s   MyMixinHandlerc      s    t  Z  d   Z RS(   Nc    sL     t  i t   |  i i   }  t  i t   |  i i |  d  S(   N(	   s   times   sleeps   DELAYs   selfs   rfiles   readlines   lines   wfiles   write(   s   selfs   line(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   handle s   (   s   __name__s
   __module__s   handle(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   MyMixinHandler s   	s   MyStreamHandlerc      s    t  Z  RS(   N(   s   __name__s
   __module__(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   MyStreamHandler s   	s   MyDatagramHandlerc      s    t  Z  RS(   N(   s   __name__s
   __module__(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   MyDatagramHandler s   	s   MyMixinServerc      s#    t  Z  d   Z " d   Z RS(   Nc    s1      x$ t  t  D  ] } ! |  i   q Wd  S(   N(   s   ranges   NREQs   is   selfs   handle_request(   s   selfs   i(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   serve_a_few s    	c    s*   " # |  i |  $ |  i   %   d  S(   N(   s   selfs   close_requests   requests   server_close(   s   selfs   requests   client_address(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   handle_error" s   (   s   __name__s
   __module__s   serve_a_fews   handle_error(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   MyMixinServer s   	s   hello world
i   c    sc   ) * t  i  |  g g  g  |  \ } } } + |  | j o , |  i |  Sn . t d |   d  S(   Ns   timed out on %s(	   s   selects   socks   timeouts   rs   ws   xs   recvs   ns   RuntimeError(   s   socks   ns   timeouts   rs   ws   x(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   receive) s   'c    s©   0 1 t  i  |  t  i  } 2 | i t |  3 t | d  } } 4 x; 4 | o
 d | j o# 5 t | d  } 6 | | 7} qJ W7 t
 | t j  8 | i   d  S(   Nid   s   
(   s   sockets   protos
   SOCK_DGRAMs   ss   sendtos
   teststrings   addrs   receives   bufs   datas   verifys   close(   s   protos   addrs   ss   datas   buf(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys	   testdgram0 s    c    sΆ   : ; t  i  |  t  i  } < | i |  = | i t  > t | d  } } ? x; ? | o
 d | j o# @ t | d  } A | | 7} qW WB t | t j  C | i   d  S(   Nid   s   
(   s   sockets   protos   SOCK_STREAMs   ss   connects   addrs   sendalls
   teststrings   receives   bufs   datas   verifys   close(   s   protos   addrs   ss   datas   buf(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys
   teststream: s    s   ServerThreadc      s#   E t  Z F d   Z K d   Z RS(   Nc    s>   F G t  i i |   H | |  _ I | |  _ J | |  _	 d  S(   N(
   s	   threadings   Threads   __init__s   selfs   addrs   _ServerThread__addrs   svrclss   _ServerThread__svrclss   hdlrclss   _ServerThread__hdlrcls(   s   selfs   addrs   svrclss   hdlrcls(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   __init__F s   c    s   K L d t  |  i f d     Y} N t o N d GHn O | |  i |  i  } P t o P d GHn Q | i   R t o R d GHn d  S(   Ns   svrclsc      s   L t  Z M RS(   N(   s   __name__s
   __module__(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   svrclsL s   	s   thread: creating servers   thread: serving three timess   thread: done(	   s   MyMixinServers   selfs   _ServerThread__svrclss   svrclss   verboses   _ServerThread__addrs   _ServerThread__hdlrclss   svrs   serve_a_few(   s   selfs   svrs   svrcls(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   runK s   
 
 
 (   s   __name__s
   __module__s   __init__s   run(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   ServerThreadE s   	i    c      s4   U V W t  d 7a  X d t i   d d t  Sd  S(   Ni   i'  iθ  i
   (   s   seeds   oss   getpid(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   pickportU s   s	   localhostc    s[   \ ] |  t i j o ^ t t   f Sn. ` t t t    } a t i	 |  b | Sd  S(   N(
   s   protos   sockets   AF_INETs   hosts   pickports   TESTFNs   strs   fns	   testfiless   append(   s   protos   fn(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   pickaddr\ s
   c     s^   d e xG t  De ]< }  f y g t i |   Wn h t i j
 o
 i n Xq Wj g  t  (d  S(   N(   s	   testfiless   fns   oss   removes   error(   s   fn(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   cleanupd s   
 	c    s1  l m x$| Dm ]} n t |   } o t o p d G| GHq d G| GHn r t | | |  } s t o s d GHn t | i	   u t o u d GHn v xQ t
 t  Dv ]@ } w t i t  x t o x d G| GHn y | |  |  q© Wz t o z d GHn { | i   | t o | d GHn q Wd  S(   Ns   ADDR =s   CLASS =s   server createds   server runnings   test clients   waiting for servers   done(   s   serverss   svrclss   pickaddrs   protos   addrs   verboses   ServerThreads   hdlrclss   ts   starts   ranges   NREQs   is   times   sleeps   DELAYs   testfuncs   join(   s   protos   serverss   hdlrclss   testfuncs   is   ts   svrclss   addr(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   testloopl s.   
 	

 
  	
 
 
 s   forks   AF_UNIXs   ForkingUnixStreamServerc      s    t  Z  RS(   N(   s   __name__s
   __module__(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   ForkingUnixStreamServer s   	 s   ForkingUnixDatagramServerc      s    t  Z  RS(   N(   s   __name__s
   __module__(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   ForkingUnixDatagramServer s   	 c      si     t  t i t t t   t  t i t t t   t	 t d  o  t  t i
 t t t  n d  S(   Ns   AF_UNIX(   s   testloops   sockets   AF_INETs
   tcpserverss   MyStreamHandlers
   teststreams
   udpserverss   MyDatagramHandlers	   testdgrams   hasattrs   AF_UNIXs   streamservers(    (    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   testall s   c     sX     d  k  }   |  i   o  t d   n  z   t   Wd  ‘ ’ t   Xd  S(   Ns"   can't run when import lock is held(   s   imps	   lock_helds   TestSkippeds   testalls   cleanup(   s   imp(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys	   test_main s   s   __main__(7   s   test_supports   verboses   verifys   TESTFNs   TestSkippeds   requiress   SocketServers   sockets   selects   times	   threadings   oss   NREQs   DELAYs   MyMixinHandlers   StreamRequestHandlers   MyStreamHandlers   DatagramRequestHandlers   MyDatagramHandlers   MyMixinServers
   teststrings   receives	   testdgrams
   teststreams   Threads   ServerThreads   seeds   pickports   hosts	   testfiless   pickaddrs   cleanups   testloops	   TCPServers   ThreadingTCPServers
   tcpserverss   hasattrs   appends   ForkingTCPServers	   UDPServers   ThreadingUDPServers
   udpserverss   ForkingUDPServers   streamserverss   dgramserverss   ForkingMixIns   UnixStreamServers   ForkingUnixStreamServers   ThreadingUnixStreamServers   UnixDatagramServers   ForkingUnixDatagramServers   ThreadingUnixDatagramServers   testalls	   test_mains   __name__(#   s   test_supports   verboses
   udpserverss   dgramserverss
   teststrings   ServerThreads   DELAYs   selects
   tcpserverss   pickports	   testfiless   streamserverss   MyDatagramHandlers   ForkingUnixDatagramServers	   testdgrams   verifys   testloops   pickaddrs	   test_mains   MyStreamHandlers   TestSkippeds   MyMixinServers   NREQs   testalls
   teststreams   TESTFNs   MyMixinHandlers   sockets   receives   hosts	   threadings   ForkingUnixStreamServers   times   oss   cleanup(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   ? sV   "
				
					