-ν
ιΆ<c       s9  d  k  Z  d k  l Z l Z l Z l Z e  i d  d k Td  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 d   Z d   Z d e
 i f d     YZ d a d   Z d Z g  Z d   Z d   Z 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, nQ 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    s=   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    s%   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    sT   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   t  i  |  t  i  } | i t |  t | d  } } x2 | o
 d | j o t | d  } | | 7} q; Wt
 | t j  | 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  } } x2 | o
 d | j o t | d  } | | 7} qE Wt | t j  | 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   t  Z d   Z d   Z RS(   Nc    s/   t  i i |   | |  _ | |  _ | |  _	 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    so   d t  |  i f d     Y} t o	 d GHn | |  i |  i  } t o	 d GHn | i   t o	 d GHn d  S(   Ns   svrclsc      s   t  Z 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      s(   t  d 7a  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    sI   |  t i j o t t   f Sn% t t t    } t i	 |  | 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     sF   x8 t  D]0 }  y t i |   Wn t i j
 o n Xq Wg  t  (d  S(   N(   s	   testfiless   fns   oss   removes   error(   s   fn(    (    s,   /usr/lib/python2.2/test/test_socketserver.pys   cleanupd s     	c    sι   xβ | D]Ϊ } t |   } t o d G| GHd G| GHn t | | |  } t o	 d GHn | i	   t o	 d GHn xB t
 t  D]4 } t i t  t o d G| GHn | |  |  q Wt o	 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      sZ   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     s@   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   								
					
			