ó
úR‹_c           @   s‡   d  d l  m Z m Z d  d l j Z d  d l Z d  d l m Z d  d l m Z d e j	 f d „  ƒ  YZ
 e d k rƒ e j ƒ  n  d S(   iÿÿÿÿ(   t   create_connectiont   timeoutN(   t   util(   t   paramst   Testc           B   s   e  Z d  Z d „  Z RS(   s   echoserver.pyc            sP   ‡  f d †  } t  j | d ƒ } t  j | d ƒ } t  j | | g d t ƒd  S(   Nc            sà   t  j r i d d 6} n i d d 6} d | d <t t j d f ƒ } | j t  j ƒ | j |   } | j ƒ  } ˆ  j	 d | ƒ | j
 |  ƒ | j t |  ƒ ƒ } ˆ  j | |  ƒ ˆ  j t | j d ƒ | j ƒ  | j ƒ  d  S(   Ni   t	   bufferingt   bufsizet   rbt   modei€>  t   Welcome(   t	   greentestt   PY3R    R   t   DEFAULT_LOCAL_HOST_ADDRt
   settimeoutt   DEFAULT_XPC_SOCKET_TIMEOUTt   makefilet   readlinet   assertInt   sendallt   readt   lent   assertEqualt   assertRaisesR   t   recvt   close(   t   messaget   kwargst   connt   rfilet   welcomet   received(   t   self(    s^   /var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__example_echoserver.pyt   test_client   s    	

s   hello
s   world
t   raise_error(   t   geventt   spawnt   joinallt   True(   R   R    t   client1t   client2(    (   R   s^   /var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__example_echoserver.pyt   _run_all_tests   s    (   t   __name__t
   __module__t   serverR(   (    (    (    s^   /var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__example_echoserver.pyR      s   t   __main__(   t   gevent.socketR    R   t   gevent.testingt   testingR
   R"   R   R   t
   TestServerR   R)   t   main(    (    (    s^   /var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__example_echoserver.pyt   <module>   s   