;
"Ic               @   s_  d  d l  Z  d  d l m Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l	 Z	 d  d l
 Z
 d  d l Z d  d l Z d  d l Z d  d l Z d  d l m Z d  d l Z e j Z d Z Gd   d e  j  Z Gd   d e  j  Z Gd	   d
  Z Gd   d e e  Z Gd   d e e  Z Gd   d e  Z Gd   d e  j e  Z Gd   d e  j  Z Gd   d e  Z Gd   d e  Z Gd   d e  Z Gd   d e  Z  Gd   d e  Z! Gd   d  e  Z" Gd!   d" e"  Z# Gd#   d$ e"  Z$ Gd%   d& e"  Z% Gd'   d( e&  Z' Gd)   d* e' e  Z( Gd+   d, e  j  Z) Gd-   d. e e  Z* Gd/   d0 e e  Z+ Gd1   d2 e  Z, Gd3   d4 e  Z- Gd5   d6 e  j  Z. Gd7   d8 e  j  Z/ Gd9   d: e  Z0 d; Z1 d< Z2 d= Z3 d>   Z4 Gd?   d@ e  j  Z5 GdA   dB e  j e  Z6 dC   Z7 e8 dD k o e7   n d S(E   i    N(   u   support(   u   proxys   Michael Gilfix was here
c             B   s    |  Ee  Z d    Z d   Z d S(   c             C   sD   t  j  t  j t  j  |  _ t j |  j  |  _ |  j j d  d  S(   Ni   (   u   socketu   AF_INETu   SOCK_STREAMu   servu   supportu	   bind_portu   portu   listen(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp   s    c             C   s   |  j  j   d  |  _  d  S(   N(   u   servu   closeu   None(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   tearDown   s    N(   u   __name__u
   __module__u   setUpu   tearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   SocketTCPTest   s   
	u   SocketTCPTestc             B   s    |  Ee  Z d    Z d   Z d S(   c             C   s4   t  j  t  j t  j  |  _ t j |  j  |  _ d  S(   N(   u   socketu   AF_INETu
   SOCK_DGRAMu   servu   supportu	   bind_portu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp$   s    c             C   s   |  j  j   d  |  _  d  S(   N(   u   servu   closeu   None(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   tearDown(   s    N(   u   __name__u
   __module__u   setUpu   tearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   SocketUDPTest"   s   
	u   SocketUDPTestc             B   sS   |  Ee  Z d  Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 d S(	   u  Threadable Test class

    The ThreadableTest class makes it easy to create a threaded
    client/server pair from an existing unit test. To create a
    new threaded class from an existing unit test, use multiple
    inheritance:

        class NewClass (OldClass, ThreadableTest):
            pass

    This class defines two new fixture functions with obvious
    purposes for overriding:

        clientSetUp ()
        clientTearDown ()

    Any new test functions within the class must then define
    tests in pairs, where the test name is preceeded with a
    '_' to indicate the client portion of the test. Ex:

        def testFoo(self):
            # Server portion

        def _testFoo(self):
            # Client portion

    Any exceptions raised by the clients during their tests
    are caught and transferred to the main thread to alert
    the testing framework.

    Note, the server setup function cannot call any blocking
    functions that rely on the client thread during setup,
    unless serverExplicitReady() is called just before
    the blocking call (such as in setting up a client/server
    connection and performing the accept() in setUp().
    c             C   s4   |  j  |  _ |  j |  _ |  j |  _  |  j |  _ d  S(   N(   u   setUpu   _ThreadableTest__setUpu   tearDownu   _ThreadableTest__tearDownu   _setUpu	   _tearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__R   s    c             C   s   |  j  j   d S(   u   This method allows the server to explicitly indicate that
        it wants the client thread to proceed. This is useful if the
        server is about to execute a blocking routine that is
        dependent upon the client thread during its setup routine.N(   u   server_readyu   set(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   serverExplicitReadyY   s    c             C   s   t  j   |  _ t  j   |  _ t  j   |  _ t j d  |  _ |  j   } | j d  } | | d d   } t	 |  d |  } t
 j |  j | f  |  _ |  j   |  j j   p |  j j   n |  j j   d  S(   Ni   u   .u   _(   u	   threadingu   Eventu   server_readyu   client_readyu   doneu   queueu   Queueu   idu   rfindu   getattru   threadu   start_new_threadu	   clientRunu   client_threadu   _ThreadableTest__setUpu   is_setu   setu   wait(   u   selfu
   methodnameu   iu   test_method(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _setUp`   s    
c             C   sK   |  j    |  j j   |  j j   o  |  j j   } |  j |  n d  S(   N(   u   _ThreadableTest__tearDownu   doneu   waitu   queueu   qsizeu   getu   fail(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   _tearDowns   s
    
c             C   s   |  j  j   |  j j   |  j   t | d  p t d   n y |   Wn7 t k
 o+ } z |  j j	 |  WYd  d  } ~ Xn X|  j
   d  S(   Nu   __call__u%   test_func must be a callable function(   u   server_readyu   waitu   client_readyu   setu   clientSetUpu   hasattru	   TypeErroru	   Exceptionu   queueu   putu   clientTearDown(   u   selfu	   test_funcu   strerror(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   clientRun{   s    
$c             C   s   t  d   d  S(   Nu    clientSetUp must be implemented.(   u   NotImplementedError(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp   s    c             C   s   |  j  j   t j   d  S(   N(   u   doneu   setu   threadu   exit(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown   s    N(
   u   __name__u
   __module__u   __doc__u   __init__u   serverExplicitReadyu   _setUpu	   _tearDownu	   clientRunu   clientSetUpu   clientTearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   ThreadableTest,   s   
$						u   ThreadableTestc             B   s,   |  Ee  Z d  d  Z d   Z d   Z d S(   u   runTestc             C   s$   t  j |  d | t j |   d  S(   Nu
   methodName(   u   SocketTCPTestu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__   s    c             C   s   t  j  t  j t  j  |  _ d  S(   N(   u   socketu   AF_INETu   SOCK_STREAMu   cli(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp   s    c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u   cliu   closeu   Noneu   ThreadableTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown   s    	N(   u   __name__u
   __module__u   __init__u   clientSetUpu   clientTearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   ThreadedTCPSocketTest   s   
	u   ThreadedTCPSocketTestc             B   s#   |  Ee  Z d  d  Z d   Z d S(   u   runTestc             C   s$   t  j |  d | t j |   d  S(   Nu
   methodName(   u   SocketUDPTestu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__   s    c             C   s   t  j  t  j t  j  |  _ d  S(   N(   u   socketu   AF_INETu
   SOCK_DGRAMu   cli(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp   s    N(   u   __name__u
   __module__u   __init__u   clientSetUp(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   ThreadedUDPSocketTest   s   
u   ThreadedUDPSocketTestc             B   sD   |  Ee  Z d  Z d d  Z d   Z d   Z d   Z d   Z d S(   u   Socket tests for client-server connection.

    self.cli_conn is a client socket connected to the server.  The
    setUp() method guarantees that it is connected to the server.
    u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   ThreadedTCPSocketTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__   s    c             C   s9   t  j |   |  j   |  j j   \ } } | |  _ d  S(   N(   u   ThreadedTCPSocketTestu   setUpu   serverExplicitReadyu   servu   acceptu   cli_conn(   u   selfu   connu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp   s    
c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u   cli_connu   closeu   Noneu   ThreadedTCPSocketTestu   tearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   tearDown   s    	c             C   s6   t  j |   |  j j t |  j f  |  j |  _ d  S(   N(   u   ThreadedTCPSocketTestu   clientSetUpu   cliu   connectu   HOSTu   portu	   serv_conn(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp   s    c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u	   serv_connu   closeu   Noneu   ThreadedTCPSocketTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown   s    	N(   u   __name__u
   __module__u   __doc__u   __init__u   setUpu   tearDownu   clientSetUpu   clientTearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   SocketConnectedTest   s   
			u   SocketConnectedTestc             B   s>   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d S(   u   runTestc             C   s'   t  j j |  d | t j |   d  S(   Nu
   methodName(   u   unittestu   TestCaseu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__   s    c             C   s   t  j   \ |  _ |  _ d  S(   N(   u   socketu
   socketpairu   servu   cli(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp   s    c             C   s   |  j  j   d  |  _  d  S(   N(   u   servu   closeu   None(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   tearDown   s    c             C   s   d  S(   N(    (   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp   s    c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u   cliu   closeu   Noneu   ThreadableTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown   s    	N(   u   __name__u
   __module__u   __init__u   setUpu   tearDownu   clientSetUpu   clientTearDown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   SocketPairTest   s
   
			u   SocketPairTestc             B   s   |  Ee  Z d    Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 d   Z
 d	   Z d
   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d S(   c             C   s8   t  j  t  j t  j  } |  j t |  j d   d  S(   Nu   <socket.socket object(   u   socketu   AF_INETu   SOCK_STREAMu   assert_u   repru
   startswith(   u   selfu   s(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   test_repr   s    c             C   s   t  j  t  j t  j  } t |  } |  j | j   | j    | j   d  } y | j   Wn t k
 o Yn X|  j	 d  d  S(   Nu   Socket proxy still exists(
   u   socketu   AF_INETu   SOCK_STREAMu   proxyu   assertEqualu   filenou   closeu   Noneu   ReferenceErroru   fail(   u   selfu   su   p(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   test_weakref   s    
c             C   sa   d   } d   } d   } |  j  t j | d  |  j  t j | d  |  j  t j | d  d  S(   Nc              _   s   t  j  d  S(   N(   u   socketu   error(   u   argsu   kwargs(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   raise_error   s    c              _   s   t  j  d  S(   N(   u   socketu   herror(   u   argsu   kwargs(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   raise_herror   s    c              _   s   t  j  d  S(   N(   u   socketu   gaierror(   u   argsu   kwargs(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   raise_gaierror   s    u   Error raising socket exception.(   u   failUnlessRaisesu   socketu   error(   u   selfu   raise_erroru   raise_herroru   raise_gaierror(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSocketError   s    			c             C   s<   t  j t  j t  j t  j t  j t  j t  j t  j d  S(   N(	   u   socketu   AF_INETu   SOCK_STREAMu
   SOCK_DGRAMu   SOCK_RAWu   SOCK_RDMu   SOCK_SEQPACKETu
   SOL_SOCKETu   SO_REUSEADDR(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testCrucialConstants  s    c             C   s   t  j   } y t  j |  } Wn t  j k
 o d  SYn X|  j | j d  d k d  y t  j |  \ } } } Wn t  j k
 o d  SYn X| | g | } t  j |  } | | k o! |  j d | t	 |  f  n d  S(   Nu   .i    u   Error resolving host to ip.u=   Error testing host resolution mechanisms. (fqdn: %s, all: %s)(
   u   socketu   gethostnameu   gethostbynameu   erroru   assert_u   findu   gethostbyaddru   getfqdnu   failu   repr(   u   selfu   hostnameu   ipu   hnameu   aliasesu   ipaddrsu   all_host_namesu   fqhn(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testHostnameRes  s    

c          	   C   sy   t  t d  oe y# t j t  } t j t d  Wqu t k
 o/ t j t  | k o |  j d  n Yqu Xn d  S(   Nu   getrefcounti    u$   socket.getnameinfo loses a reference(   u   hasattru   sysu   getrefcountu   __name__u   socketu   getnameinfou   SystemErroru   fail(   u   selfu   orig(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRefCountGetNameInfo  s    c             C   s2   y t  j d d  Wn t  j k
 o Yn Xd  S(   Nu   xi    (   u   xi    i    i    (   u   socketu   getnameinfou   error(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testInterpreterCrash*  s    c             C   s   i d t  j 6d t  j 6d t  j 6d t  j 6} x | j   D] \ } } d | >d } xK d d d d
 d d d f D]. } |  j | | @| | | | @  | @ qq W| |  } |  j | | @|  |  j t | d  q; Wd  S(   Ni    i   i   i    i  i   igE#i2Tvi"   i  l        (	   u   socketu   htonlu   ntohlu   htonsu   ntohsu   itemsu   assertEqualu   assertRaisesu   OverflowError(   u   selfu   sizesu   funcu   sizeu   masku   iu   swapped(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testNtoH2  s      ,c             C   s   d d d d d d g } d d d d d d g } xB | D]: } t  j |  t  j |  t  j |  t  j |  q7 Wxf | D]^ } |  j t t  j |  |  j t t  j |  |  j t t  j |  |  j t t  j |  q| Wd  S(   Ni   i   i   iii(   u   socketu   ntohlu   ntohsu   htonlu   htonsu   assertRaisesu   OverflowError(   u   selfu   good_valuesu
   bad_valuesu   k(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testNtoHErrors@  s      c             C   s0  |  j  } t j d k o
 d } n d } xH | D]7 } y t j | d  } PWq0 t j k
 o Yq0 Xq0 Wt j  t j |  } | | |  y t j | d  } Wn t j k
 o d  } Yn X| | |  | t j |  |  | t j | d  |  | d  k	 o | t j | d  |  n d  S(   Nu   linux2u   freebsd4u   freebsd5u   freebsd6u   freebsd7u   freebsd8u   darwinu   daytimeu   qotdu   domainu   echou   tcpu   udp(   u   linux2u   freebsd4u   freebsd5u   freebsd6u   freebsd7u   freebsd8u   darwin(   u   daytimeu   qotdu   domain(   u   echou   daytimeu   domain(   u   assertEqualu   sysu   platformu   socketu   getservbynameu   erroru   Noneu   getservbyport(   u   selfu   equ   servicesu   serviceu   portu   port2u   udpport(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testGetServByN  s0    	

 
	c             C   s  |  j  t j   d   t j   } |  j  | j   d   | j   t j d  |  j  t j   d  t j   } |  j  | j   d  | j   t j d   |  j  t j   d   t j   } |  j  | j   d   | j   |  j t t j d  |  j t	 t j d  d  S(   Ni
   iu   spam(
   u   assertEqualu   socketu   getdefaulttimeoutu   Noneu
   gettimeoutu   closeu   setdefaulttimeoutu   assertRaisesu
   ValueErroru	   TypeError(   u   selfu   s(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testDefaultTimeoutr  s     


c                s  t  t d  p d  Sd d l m } m  m      f d   } |  j d | d   |  j d | d   |  j d	 | d
   |  j d | d   |  j d | d   |  j d | d   |  j d | d   |  j d	 | d
   |  j d | d   d  S(   Nu	   inet_ptoni    (   u	   inet_atonu	   inet_ptonu   AF_INETc                s      |   S(    (    (   u   a(   u   AF_INETu	   inet_pton(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    s       u   0.0.0.0s     u   255.0.255.0s   u   170.170.170.170s   u   1.2.3.4s   u   255.255.255.255(   u   hasattru   socketu	   inet_atonu	   inet_ptonu   AF_INETu   assertEquals(   u   selfu   fu   g(    (   u   AF_INETu	   inet_ptonu-   /mit/python/lib/python3.0/test/test_socket.pyu   testIPv4toString  s    c                s   t  t d  p d  Sy, d d l m  m   m } | p d  SWn t k
 o d  SYn X   f d   } |  j d | d   |  j d | d   |  j d	 d | d   |  j d | d   d  S(   Nu	   inet_ptoni    (   u	   inet_ptonu   AF_INET6u   has_ipv6c                s      |   S(    (    (   u   a(   u   AF_INET6u	   inet_pton(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    s    i   u   ::u   0::0s    i   u   1::s   Ev V$u$   45ef:76cb:1a:56ef:afeb:bac:1924:aeaes                   s                   s                 (   u   hasattru   socketu	   inet_ptonu   AF_INET6u   has_ipv6u   ImportErroru   assertEquals(   u   selfu   has_ipv6u   f(    (   u   AF_INET6u	   inet_ptonu-   /mit/python/lib/python3.0/test/test_socket.pyu   testIPv6toString  s    	
c                s   t  t d  p d  Sd d l m } m   m     f d   } |  j d | d   |  j d | d   |  j d	 | d
   |  j d | d   |  j d | d   |  j d | d   |  j d	 | d
   d  S(   Nu	   inet_ntopi    (   u	   inet_ntoau	   inet_ntopu   AF_INETc                s      |   S(    (    (   u   a(   u	   inet_ntopu   AF_INET(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    u   1.0.1.0s     u   170.85.170.85s   UUu   255.255.255.255s   u   1.2.3.4s   (   u   hasattru   socketu	   inet_ntoau	   inet_ntopu   AF_INETu   assertEquals(   u   selfu   fu   g(    (   u	   inet_ntopu   AF_INETu-   /mit/python/lib/python3.0/test/test_socket.pyu   testStringToIPv4  s    c                s   t  t d  p d  Sy, d d l m  m   m } | p d  SWn t k
 o d  SYn X   f d   } |  j d | d   |  j d | d   |  j d | d   d  S(   Nu	   inet_ntopi    (   u	   inet_ntopu   AF_INET6u   has_ipv6c                s      |   S(    (    (   u   a(   u   AF_INET6u	   inet_ntop(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    u   ::s    i   u   ::1i   s   u!   aef:b01:506:1001:ffff:9997:55:170s   
 Ups                   s                  s                  (   u   hasattru   socketu	   inet_ntopu   AF_INET6u   has_ipv6u   ImportErroru   assertEquals(   u   selfu   has_ipv6u   f(    (   u   AF_INET6u	   inet_ntopu-   /mit/python/lib/python3.0/test/test_socket.pyu   testStringToIPv6  s    	
c             C   s   t  j    } | j d  | j   \ } } | j   ~ t  j  t  j t  j  } | j d | f  | j   } t  j t  j    } |  j | d d | f k d | d  |  j	 | d |  d  S(   Nu   0.0.0.0i    u
   %s invalidi   (   u   0.0.0.0i    (
   u   socketu   bindu   getsocknameu   closeu   AF_INETu   SOCK_STREAMu   gethostbynameu   gethostnameu   assert_u   assertEqual(   u   selfu   tempsocku   hostu   portu   socku   nameu
   my_ip_addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSockName  s    
(c             C   sJ   t  j  t  j t  j  } | j t  j t  j  } |  j | d k d  d  S(   Ni    u   initial mode is reuse(   u   socketu   AF_INETu   SOCK_STREAMu
   getsockoptu
   SOL_SOCKETu   SO_REUSEADDRu   failIf(   u   selfu   socku   reuse(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testGetSockOpt  s    c             C   sc   t  j  t  j t  j  } | j t  j t  j d  | j t  j t  j  } |  j | d k d  d  S(   Ni   i    u   failed to set reuse mode(   u   socketu   AF_INETu   SOCK_STREAMu
   setsockoptu
   SOL_SOCKETu   SO_REUSEADDRu
   getsockoptu   failIf(   u   selfu   socku   reuse(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSetSockOpt  s    c             C   sL   t  j  t  j t  j  } | j d  | j   |  j t  j | j d  d  S(   Ni   s   spam(   u   socketu   AF_INETu   SOCK_STREAMu
   settimeoutu   closeu   assertRaisesu   erroru   send(   u   selfu   sock(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSendAfterClose  s    
c             C   se   t  j  t  j t  j  } |  j | j t  j  |  j | j t  j  |  j | j d  | j   d  S(   Ni    (   u   socketu   AF_INETu   SOCK_STREAMu   assertEqualu   familyu   typeu   protou   close(   u   selfu   sock(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testNewAttributes  s
    c             C   st   t  j d k o d  S|  j t t j d   |  j t t d   |  j t t d   |  j t t d   d  S(   Nu   ntu   ioctlu
   SIO_RCVALLu	   RCVALL_ONu
   RCVALL_OFF(   u   osu   nameu   assert_u   hasattru   socket(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   test_sock_ioctl  s    N(   u   __name__u
   __module__u	   test_repru   test_weakrefu   testSocketErroru   testCrucialConstantsu   testHostnameResu   testRefCountGetNameInfou   testInterpreterCrashu   testNtoHu   testNtoHErrorsu   testGetServByu   testDefaultTimeoutu   testIPv4toStringu   testIPv6toStringu   testStringToIPv4u   testStringToIPv6u   testSockNameu   testGetSockOptu   testSetSockOptu   testSendAfterCloseu   testNewAttributesu   test_sock_ioctl(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   GeneralModuleTests   s*   
										$										u   GeneralModuleTestsc             B   s   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 d	   Z
 d
   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d S(   u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   SocketConnectedTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s&   |  j  j d  } |  j | t  d  S(   Ni   (   u   cli_connu   recvu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecv  s    c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   _testRecv  s    c             C   sL   |  j  j t t  d  } |  j  j d  } | | } |  j | t  d  S(   Ni   i   (   u   cli_connu   recvu   lenu   MSGu   assertEqual(   u   selfu   seg1u   seg2u   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testOverFlowRecv  s    
c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testOverFlowRecv"  s    c             C   s,   |  j  j d  \ } } |  j | t  d  S(   Ni   (   u   cli_connu   recvfromu   assertEqualu   MSG(   u   selfu   msgu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecvFrom%  s    c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testRecvFrom*  s    c             C   sX   |  j  j t t  d  \ } } |  j  j d  \ } } | | } |  j | t  d  S(   Ni   i   (   u   cli_connu   recvfromu   lenu   MSGu   assertEqual(   u   selfu   seg1u   addru   seg2u   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testOverFlowRecvFrom-  s    "
c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testOverFlowRecvFrom4  s    c             C   sL   d } x+ |  j  j d  } | p Pn | | 7} q	 |  j | d d  d  S(   Ns    i   s   fi   (   u   cli_connu   recvu   assertEqual(   u   selfu   msgu   read(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSendAll7  s    c             C   s   d d } |  j  j |  d  S(   Ns   fi   (   u	   serv_connu   sendall(   u   selfu	   big_chunk(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testSendAllA  s    
c             C   sb   t  t d  p d  S|  j j   } t j | t j t j  } | j d  } |  j | t	  d  S(   Nu   fromfdi   (
   u   hasattru   socketu   cli_connu   filenou   fromfdu   AF_INETu   SOCK_STREAMu   recvu   assertEqualu   MSG(   u   selfu   fdu   socku   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu
   testFromFdE  s    c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testFromFdN  s    c             C   s2   |  j  j   } | j d  } |  j | t  d  S(   Ni   (   u   cli_connu   dupu   recvu   assertEqualu   MSG(   u   selfu   socku   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testDupQ  s    c             C   s   |  j  j t  d  S(   N(   u	   serv_connu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testDupW  s    c             C   s&   |  j  j d  } |  j | t  d  S(   Ni   (   u   cli_connu   recvu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testShutdownZ  s    c             C   s$   |  j  j t  |  j  j d  d  S(   Ni   (   u	   serv_connu   sendu   MSGu   shutdown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testShutdown_  s    N(   u   __name__u
   __module__u   __init__u   testRecvu	   _testRecvu   testOverFlowRecvu   _testOverFlowRecvu   testRecvFromu   _testRecvFromu   testOverFlowRecvFromu   _testOverFlowRecvFromu   testSendAllu   _testSendAllu
   testFromFdu   _testFromFdu   testDupu   _testDupu   testShutdownu   _testShutdown(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   BasicTCPTest  s"   
									
							u   BasicTCPTestc             B   sP   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d   Z d   Z d S(	   u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   ThreadedUDPSocketTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__e  s    c             C   s,   |  j  j t t   } |  j | t  d  S(   N(   u   servu   recvu   lenu   MSGu   assertEqual(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSendtoAndRecvh  s    c             C   s#   |  j  j t d t |  j f  d  S(   Ni    (   u   cliu   sendtou   MSGu   HOSTu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testSendtoAndRecvm  s    c             C   s2   |  j  j t t   \ } } |  j | t  d  S(   N(   u   servu   recvfromu   lenu   MSGu   assertEqual(   u   selfu   msgu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecvFromp  s    c             C   s#   |  j  j t d t |  j f  d  S(   Ni    (   u   cliu   sendtou   MSGu   HOSTu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testRecvFromu  s    c             C   s   |  j  t |  j j d  d  S(   Ni(   u   assertRaisesu
   ValueErroru   servu   recvfrom(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecvFromNegativex  s    c             C   s#   |  j  j t d t |  j f  d  S(   Ni    (   u   cliu   sendtou   MSGu   HOSTu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testRecvFromNegative|  s    N(	   u   __name__u
   __module__u   __init__u   testSendtoAndRecvu   _testSendtoAndRecvu   testRecvFromu   _testRecvFromu   testRecvFromNegativeu   _testRecvFromNegative(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   BasicUDPTestc  s   
					u   BasicUDPTestc             B   s    |  Ee  Z d    Z d   Z d S(   c             C   s   |  j  j   \ } } | j   |  j } t j | g g  g  d  \ } } } |  j | | g  |  j | j d  d  | j   | j   d  S(   Ng      ?i   s    (   u   servu   acceptu   closeu   cliu   selectu   assertEqualu   recv(   u   selfu   connu   addru   sdu   readu   writeu   err(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   testClose  s    
	$
c             C   s*   |  j  j t |  j f  t j d  d  S(   Ng      ?(   u   cliu   connectu   HOSTu   portu   timeu   sleep(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu
   _testClose  s    N(   u   __name__u
   __module__u	   testCloseu
   _testClose(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TCPCloserTest  s   
	u   TCPCloserTestc             B   s>   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d S(   u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   SocketPairTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s&   |  j  j d  } |  j | t  d  S(   Ni   (   u   servu   recvu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecv  s    c             C   s   |  j  j t  d  S(   N(   u   cliu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   _testRecv  s    c             C   s   |  j  j t  d  S(   N(   u   servu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSend  s    c             C   s&   |  j  j d  } |  j | t  d  S(   Ni   (   u   cliu   recvu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   _testSend  s    N(   u   __name__u
   __module__u   __init__u   testRecvu	   _testRecvu   testSendu	   _testSend(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   BasicSocketPairTest  s
   
			u   BasicSocketPairTestc             B   sb   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 d	   Z
 d
 S(   u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   ThreadedTCPSocketTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c          	   C   sq   |  j  j d  t j   } y |  j  j   Wn t j k
 o Yn Xt j   } |  j | | d k  d  d  S(   Ni    g      ?u    Error setting non-blocking mode.(   u   servu   setblockingu   timeu   acceptu   socketu   erroru   assert_(   u   selfu   startu   end(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSetBlocking  s    c             C   s   d  S(   N(    (   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testSetBlocking  s    c          
   C   s   |  j  j d  y |  j  j   \ } } Wn t j k
 o Yn X|  j d  t j |  j  g g  g   \ } } } |  j  | k o |  j  j   \ } } n |  j d  d  S(   Ni    u'   Error trying to do non-blocking accept.u'   Error trying to do accept after select.(   u   servu   setblockingu   acceptu   socketu   erroru   failu   select(   u   selfu   connu   addru   readu   writeu   err(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu
   testAccept  s    $c             C   s*   t  j d  |  j j t |  j f  d  S(   Ng?(   u   timeu   sleepu   cliu   connectu   HOSTu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testAccept  s    c             C   s   |  j  j   \ } } d  S(   N(   u   servu   accept(   u   selfu   connu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testConnect  s    c             C   s-   |  j  j d  |  j  j t |  j f  d  S(   Ni
   (   u   cliu
   settimeoutu   connectu   HOSTu   port(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testConnect  s    c          
   C   s   |  j  j   \ } } | j d  y | j t t   } Wn t j k
 o Yn X|  j d  t	 j	 | g g  g   \ } } } | | k o) | j t t   } |  j
 | t  n |  j d  d  S(   Ni    u%   Error trying to do non-blocking recv.u0   Error during select call to non-blocking socket.(   u   servu   acceptu   setblockingu   recvu   lenu   MSGu   socketu   erroru   failu   selectu   assertEqual(   u   selfu   connu   addru   msgu   readu   writeu   err(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecv  s    !c             C   s:   |  j  j t |  j f  t j d  |  j  j t  d  S(   Ng?(   u   cliu   connectu   HOSTu   portu   timeu   sleepu   sendu   MSG(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   _testRecv  s    N(   u   __name__u
   __module__u   __init__u   testSetBlockingu   _testSetBlockingu
   testAcceptu   _testAcceptu   testConnectu   _testConnectu   testRecvu	   _testRecv(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   NonBlockingTCPTests  s   
							u   NonBlockingTCPTestsc             B   s   |  Ee  Z d  Z d Z d d  Z d   Z d   Z d   Z d   Z d   Z	 d	   Z
 d
   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z d S(   um  Unit tests for the object returned by socket.makefile()

    self.serv_file is the io object returned by makefile() on
    the client connection.  You can read from this file to
    get output from the server.

    self.cli_file is the io object returned by makefile() on the
    server connection.  You can write to this file to send output
    to the client.
    iu   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   SocketConnectedTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s,   t  j |   |  j j d |  j  |  _ d  S(   Nu   rb(   u   SocketConnectedTestu   setUpu   cli_connu   makefileu   bufsizeu	   serv_file(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp  s    c             C   s:   |  j  j   |  j |  j  j  d  |  _  t j |   d  S(   N(   u	   serv_fileu   closeu   assert_u   closedu   Noneu   SocketConnectedTestu   tearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   tearDown  s    	c             C   s&   t  j |   |  j j d  |  _ d  S(   Nu   wb(   u   SocketConnectedTestu   clientSetUpu	   serv_connu   makefileu   cli_file(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp  s    c             C   s:   |  j  j   |  j |  j  j  d  |  _  t j |   d  S(   N(   u   cli_fileu   closeu   assert_u   closedu   Noneu   SocketConnectedTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown  s    	c             C   sL   |  j  j t t  d  } |  j  j d  } | | } |  j | t  d  S(   Ni   (   u	   serv_fileu   readu   lenu   MSGu   assertEqual(   u   selfu	   first_segu
   second_segu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testSmallRead  s    
c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testSmallRead  s    c             C   s#   |  j  j   } |  j | t  d  S(   N(   u	   serv_fileu   readu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testFullRead  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   close(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testFullRead  s    c             C   sH   d } x+ |  j  j d  } | p Pn | | 7} q	 |  j | t  d  S(   Ns    i   (   u	   serv_fileu   readu   assertEqualu   MSG(   u   selfu   bufu   char(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testUnbufferedRead"  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testUnbufferedRead,  s    c             C   s#   |  j  j   } |  j | t  d  S(   N(   u	   serv_fileu   readlineu   assertEqualu   MSG(   u   selfu   line(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testReadline0  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testReadline5  s    c             C   s0   |  j  j   |  j j   } |  j | t  d  S(   N(   u   cli_connu   closeu	   serv_fileu   readu   assertEqualu   MSG(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testCloseAfterMakefile9  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testCloseAfterMakefile@  s    c             C   s9   |  j  j   |  j j t t   } |  j | t  d  S(   N(   u	   serv_fileu   closeu   cli_connu   recvu   lenu   MSGu   assertEqual(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testMakefileAfterMakefileCloseD  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testMakefileAfterMakefileCloseI  s    c             C   s   |  j  |  j j  d  S(   N(   u   assert_u	   serv_fileu   closed(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testClosedAttrM  s    c             C   s   |  j  |  j j  d  S(   N(   u   assert_u   cli_fileu   closed(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testClosedAttrP  s    N(   u   __name__u
   __module__u   __doc__u   bufsizeu   __init__u   setUpu   tearDownu   clientSetUpu   clientTearDownu   testSmallReadu   _testSmallReadu   testFullReadu   _testFullReadu   testUnbufferedReadu   _testUnbufferedReadu   testReadlineu   _testReadlineu   testCloseAfterMakefileu   _testCloseAfterMakefileu   testMakefileAfterMakefileCloseu   _testMakefileAfterMakefileCloseu   testClosedAttru   _testClosedAttr(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   FileObjectClassTestCase  s*   

									
								u   FileObjectClassTestCasec             B   s,   |  Ee  Z d  Z d Z d   Z d   Z d S(   u  Repeat the tests from FileObjectClassTestCase with bufsize==0.

    In this case (and in this case only), it should be possible to
    create a file object, read a line from it, create another file
    object, read another line from it, without loss of data in the
    first file object's buffer.  Note that http.client relies on this
    when reading multiple requests from the same socket.i    c             C   sb   |  j  j   } |  j | d t  |  j j d d  |  _  |  j  j   } |  j | d t  d  S(   Ns   A. u   rbi    s   B. (   u	   serv_fileu   readlineu   assertEqualu   MSGu   cli_connu   makefile(   u   selfu   line(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testUnbufferedReadline_  s
    c             C   s9   |  j  j d t  |  j  j d t  |  j  j   d  S(   Ns   A. s   B. (   u   cli_fileu   writeu   MSGu   flush(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testUnbufferedReadlineg  s    N(   u   __name__u
   __module__u   __doc__u   bufsizeu   testUnbufferedReadlineu   _testUnbufferedReadline(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu!   UnbufferedFileObjectClassTestCaseS  s   
	u!   UnbufferedFileObjectClassTestCasec             B   s   |  Ee  Z d  Z d S(   i   N(   u   __name__u
   __module__u   bufsize(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu#   LineBufferedFileObjectClassTestCasel  s   
u#   LineBufferedFileObjectClassTestCasec             B   s   |  Ee  Z d  Z d S(   i   N(   u   __name__u
   __module__u   bufsize(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu$   SmallBufferedFileObjectClassTestCaseq  s   
u$   SmallBufferedFileObjectClassTestCasec             B   s   |  Ee  Z d  Z d   Z d S(   u   Prove network connection.c             C   s+   t  j t |  j f  |  _ |  j |  _ d  S(   N(   u   socketu   create_connectionu   HOSTu   portu   cliu	   serv_conn(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUpy  s    N(   u   __name__u
   __module__u   __doc__u   clientSetUp(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   NetworkConnectionTestv  s   
u   NetworkConnectionTestc             B   s   |  Ee  Z d  Z d S(   uL   Tests that NetworkConnection does not break existing TCP functionality.
    N(   u   __name__u
   __module__u   __doc__(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   BasicTCPTest2  s   
u   BasicTCPTest2c             B   s   |  Ee  Z d    Z d S(   c                s,   t  j     |  j t j   f d    d  S(   Nc                  s   t  j t   f  S(    (   u   socketu   create_connectionu   HOST(    (   u   port(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    (   u   supportu   find_unused_portu   failUnlessRaisesu   socketu   error(   u   self(    (   u   portu-   /mit/python/lib/python3.0/test/test_socket.pyu   testWithoutServer  s    N(   u   __name__u
   __module__u   testWithoutServer(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   NetworkConnectionNoServer  s   
u   NetworkConnectionNoServerc             B   s   |  Ee  Z d  d  Z d   Z d   Z d   Z e Z d   Z e Z d   Z	 e Z
 d   Z e Z d   Z e Z d	   Z d
 S(   u   runTestc             C   s$   t  j |  d | t j |   d  S(   Nu
   methodName(   u   SocketTCPTestu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s   d  S(   N(    (   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp  s    c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u   cliu   closeu   Noneu   ThreadableTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown  s    	c             C   s   |  j  j   \ } } d  S(   N(   u   servu   accept(   u   selfu   connu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _justAccept  s    c             C   s;   t  j t |  j f d d |  _ |  j |  j j d  d  S(   Nu   timeouti   i   (   u   socketu   create_connectionu   HOSTu   portu   cliu   assertEqualu   family(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testFamily  s    !c          	   C   ss   |  j  t j   d  k  t j d  z t j t |  j f  |  _ Wd  t j d   X|  j	 |  j j
   d  d  S(   Ni*   (   u   assert_u   socketu   getdefaulttimeoutu   Noneu   setdefaulttimeoutu   create_connectionu   HOSTu   portu   cliu   assertEqualsu
   gettimeout(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testTimeoutDefault  s    c          
   C   sy   |  j  t j   d  k  t j d  z% t j t |  j f d d  |  _ Wd  t j d   X|  j	 |  j j
   d   d  S(   Ni   u   timeout(   u   assert_u   socketu   getdefaulttimeoutu   Noneu   setdefaulttimeoutu   create_connectionu   HOSTu   portu   cliu   assertEqualu
   gettimeout(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testTimeoutNone  s    %c             C   s>   t  j t |  j f d d |  _ |  j |  j j   d  d  S(   Nu   timeouti   (   u   socketu   create_connectionu   HOSTu   portu   cliu   assertEqualu
   gettimeout(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testTimeoutValueNamed  s    !c             C   s;   t  j t |  j f d  |  _ |  j |  j j   d  d  S(   Ni   (   u   socketu   create_connectionu   HOSTu   portu   cliu   assertEqualu
   gettimeout(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testTimeoutValueNonamed  s    N(   u   __name__u
   __module__u   __init__u   clientSetUpu   clientTearDownu   _justAcceptu
   testFamilyu   _testFamilyu   testTimeoutDefaultu   _testTimeoutDefaultu   testTimeoutNoneu   _testTimeoutNoneu   testTimeoutValueNamedu   _testTimeoutValueNamedu   testTimeoutValueNonamedu   _testTimeoutValueNonamed(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   NetworkConnectionAttributesTest  s   
					
	
	u   NetworkConnectionAttributesTestc             B   sM   |  Ee  Z d  d  Z d   Z d   Z d   Z e Z d   Z d   Z d S(   u   runTestc             C   s$   t  j |  d | t j |   d  S(   Nu
   methodName(   u   SocketTCPTestu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s   d  S(   N(    (   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp  s    c             C   s'   |  j  j   d  |  _  t j |   d  S(   N(   u   cliu   closeu   Noneu   ThreadableTestu   clientTearDown(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientTearDown  s    	c             C   s3   |  j  j   \ } } t j d  | j d  d  S(   Ni   s   done!(   u   servu   acceptu   timeu   sleepu   send(   u   selfu   connu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testInsideTimeout  s    c             C   sB   t  j t |  j f  |  _ } | j d  } |  j | d  d  S(   Ni   s   done!(   u   socketu   create_connectionu   HOSTu   portu   cliu   recvu   assertEqual(   u   selfu   socku   data(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testInsideTimeout  s    c                sE   t  j t |  j f d d |  _   |  j t  j   f d    d  S(   Nu   timeouti   c                  s     j  d   S(   i   (   u   recv(    (   u   sock(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <lambda>  s    (   u   socketu   create_connectionu   HOSTu   portu   cliu   failUnlessRaisesu   timeout(   u   self(    (   u   socku-   /mit/python/lib/python3.0/test/test_socket.pyu   _testOutsideTimeout  s    %N(	   u   __name__u
   __module__u   __init__u   clientSetUpu   clientTearDownu   testInsideTimeoutu   testOutsideTimeoutu   _testInsideTimeoutu   _testOutsideTimeout(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   NetworkConnectionBehaviourTest  s   
				u   NetworkConnectionBehaviourTestc             B   s)   |  Ee  Z d    Z d   Z d   Z d S(   c                s)     f d   }   j  t j | d  d  S(   Nc                 s!     j  j d    j  j   d  S(   Ng      ?(   u   servu
   settimeoutu   accept(   u   argsu   kwargs(   u   self(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   raise_timeout  s    u*   Error generating a timeout exception (TCP)(   u   failUnlessRaisesu   socketu   timeout(   u   selfu   raise_timeout(    (   u   selfu-   /mit/python/lib/python3.0/test/test_socket.pyu   testTCPTimeout  s    c             C   s   d } y# |  j j d  |  j j   } WnT t j k
 o |  j d  Yn2 t j k
 o d } Yn |  j d  Yn X| p |  j d  n d  S(   Ng        u%   caught timeout instead of error (TCP)u!   caught unexpected exception (TCP)u3   accept() returned success when we did not expect itFT(	   u   Falseu   servu
   settimeoutu   acceptu   socketu   timeoutu   failu   erroru   True(   u   selfu   oku   foo(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testTimeoutZero  s    c                sT  t  t d  p d  S|  j j d  Gd   d t      f d   } t j t j |  } z y t j d  z y |  j j   } Wnl t j	 k
 o |  j
 d  YnW   k
 o YnD |  j
 d t j   d  d  t j   f  Yn X|  j
 d	  Wd  t j d
  XWn!   k
 o |  j
 d  Yn XWd  t j t j |  Xd  S(   Nu   alarmg      @c             B   s   |  Ee  Z d  S(   N(   u   __name__u
   __module__(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   Alarm  s   
u   Alarmc                s
      d  S(   N(    (   u   signalu   frame(   u   Alarm(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   alarm_handler   s    i   u   caught timeout instead of Alarmu3   caught other exception instead of Alarm: %s(%s):
%su   nothing caughti    u   got Alarm in wrong place(   u   hasattru   signalu   servu
   settimeoutu	   Exceptionu   SIGALRMu   alarmu   acceptu   socketu   timeoutu   failu   sysu   exc_infou	   tracebacku
   format_exc(   u   selfu   alarm_handleru	   old_alarmu   foo(    (   u   Alarmu-   /mit/python/lib/python3.0/test/test_socket.pyu   testInterruptedTimeout  s0      	*N(   u   __name__u
   __module__u   testTCPTimeoutu   testTimeoutZerou   testInterruptedTimeout(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TCPTimeoutTest  s   
		u   TCPTimeoutTestc             B   s    |  Ee  Z d    Z d   Z d S(   c                s)     f d   }   j  t j | d  d  S(   Nc                 s$     j  j d    j  j d  d  S(   Ng      ?i   (   u   servu
   settimeoutu   recv(   u   argsu   kwargs(   u   self(    u-   /mit/python/lib/python3.0/test/test_socket.pyu   raise_timeout  s    u*   Error generating a timeout exception (UDP)(   u   failUnlessRaisesu   socketu   timeout(   u   selfu   raise_timeout(    (   u   selfu-   /mit/python/lib/python3.0/test/test_socket.pyu   testUDPTimeout  s    c             C   s   d } y& |  j j d  |  j j d  } WnT t j k
 o |  j d  Yn2 t j k
 o d } Yn |  j d  Yn X| p |  j d  n d  S(   Ng        i   u%   caught timeout instead of error (UDP)u!   caught unexpected exception (UDP)u1   recv() returned success when we did not expect itFT(	   u   Falseu   servu
   settimeoutu   recvu   socketu   timeoutu   failu   erroru   True(   u   selfu   oku   foo(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testTimeoutZero"  s    N(   u   __name__u
   __module__u   testUDPTimeoutu   testTimeoutZero(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   UDPTimeoutTest  s   
	u   UDPTimeoutTestc             B   s   |  Ee  Z d    Z d S(   c             C   sq   |  j  t t j t   |  j  t t j t j   |  j  t t j t j   |  j  t t j t j   d  S(   N(   u   assert_u
   issubclassu   socketu   erroru	   Exceptionu   herroru   gaierroru   timeout(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testExceptionTree2  s    N(   u   __name__u
   __module__u   testExceptionTree(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TestExceptions0  s   
u   TestExceptionsc             B   s/   |  Ee  Z d  Z d   Z d   Z d   Z d S(   il   c             C   s   d } t  j  t  j t  j  } | j |  | j d  t  j  t  j t  j  } | j | j    | j   |  j | j   |  |  j | j	   |  d  S(   Ns    python-test-hello i   (
   u   socketu   AF_UNIXu   SOCK_STREAMu   bindu   listenu   connectu   getsocknameu   acceptu   assertEqualu   getpeername(   u   selfu   addressu   s1u   s2(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testLinuxAbstractNamespace<  s    
c             C   sT   d d |  j  d } t j t j t j  } | j |  |  j | j   |  d  S(   Ns    s   hi   (   u   UNIX_PATH_MAXu   socketu   AF_UNIXu   SOCK_STREAMu   bindu   assertEqualu   getsockname(   u   selfu   addressu   s(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testMaxNameG  s    c             C   sF   d d |  j  } t j t j t j  } |  j t j | j |  d  S(   Nu    u   h(   u   UNIX_PATH_MAXu   socketu   AF_UNIXu   SOCK_STREAMu   assertRaisesu   erroru   bind(   u   selfu   addressu   s(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testNameOverflowM  s    N(   u   __name__u
   __module__u   UNIX_PATH_MAXu   testLinuxAbstractNamespaceu   testMaxNameu   testNameOverflow(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TestLinuxAbstractNamespace8  s   
		u   TestLinuxAbstractNamespacec             B   sD   |  Ee  Z d  Z d d  Z d   Z d   Z d   Z d   Z d S(   uF   
    Test the buffer versions of socket.recv() and socket.send().
    u   runTestc             C   s   t  j |  d | d  S(   Nu
   methodName(   u   SocketConnectedTestu   __init__(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__W  s    c             C   s^   t  d  } |  j j |  } |  j | t t   | d  t t   } |  j | t  d  S(   Ni   (   u	   bytearrayu   cli_connu	   recv_intou   assertEqualu   lenu   MSG(   u   selfu   bufu   nbytesu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecvIntoZ  s
    c             C   s    t  t  } |  j j |  d  S(   N(   u   bytesu   MSGu	   serv_connu   send(   u   selfu   buf(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testRecvIntoa  s    c             C   sd   t  d  } |  j j |  \ } } |  j | t t   | d  t t   } |  j | t  d  S(   Ni   (   u	   bytearrayu   cli_connu   recvfrom_intou   assertEqualu   lenu   MSG(   u   selfu   bufu   nbytesu   addru   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRecvFromIntoe  s
    c             C   s    t  t  } |  j j |  d  S(   N(   u   bytesu   MSGu	   serv_connu   send(   u   selfu   buf(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testRecvFromIntol  s    N(   u   __name__u
   __module__u   __doc__u   __init__u   testRecvIntou   _testRecvIntou   testRecvFromIntou   _testRecvFromInto(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   BufferIOTestS  s   
			u   BufferIOTesti  i   i   c           
   C   s   t  t d  p d St j j d  p d St d  j }  j   } z3 | ~ } x# | D] } | j	 d  o d SqY WWd |  ~  QXt j o t d  n d S(   u   Check if the TIPC module is loaded

    The TIPC module is not loaded automatically on Ubuntu and probably
    other Linux distros.
    u   AF_TIPCu   /proc/modulesu   tipc Nu6   TIPC module is not loaded, please 'sudo modprobe tipc'FT(   u   hasattru   socketu   Falseu   osu   pathu   isfileu   openu   __exit__u	   __enter__u
   startswithu   Trueu   supportu   verboseu   print(   u   _[2]u   _[1]u   fu   line(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   isTipcAvailableu  s    % 
c             B   s   |  Ee  Z d    Z d S(   c             C   s   t  j  t  j t  j  } t  j  t  j t  j  } | j t  j t  j d  t  j t t t	 f } | j
 |  t  j t t t t	 t d  d f } | j t |  | j d  \ } } |  j | j   |  |  j | t  d  S(   Ni   i   i    i   (   u   socketu   AF_TIPCu   SOCK_RDMu
   setsockoptu
   SOL_SOCKETu   SO_REUSEADDRu   TIPC_ADDR_NAMESEQu
   TIPC_STYPEu
   TIPC_LOWERu
   TIPC_UPPERu   bindu   TIPC_ADDR_NAMEu   intu   sendtou   MSGu   recvfromu   assertEqualu   getsockname(   u   selfu   srvu   cliu   srvaddru   sendaddru   msgu   recvaddr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   testRDM  s    		N(   u   __name__u
   __module__u   testRDM(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TIPCTest  s   
u   TIPCTestc             B   s>   |  Ee  Z d  d  Z d   Z d   Z d   Z d   Z d S(   u   runTestc             C   s'   t  j j |  d | t j |   d  S(   Nu
   methodName(   u   unittestu   TestCaseu   __init__u   ThreadableTest(   u   selfu
   methodName(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   __init__  s    c             C   s   t  j  t  j t  j  |  _ |  j j t  j t  j d  t  j t t	 t
 f } |  j j |  |  j j d  |  j   |  j j   \ |  _ |  _ d  S(   Ni   i   (   u   socketu   AF_TIPCu   SOCK_STREAMu   srvu
   setsockoptu
   SOL_SOCKETu   SO_REUSEADDRu   TIPC_ADDR_NAMESEQu
   TIPC_STYPEu
   TIPC_LOWERu
   TIPC_UPPERu   bindu   listenu   serverExplicitReadyu   acceptu   connu   connaddr(   u   selfu   srvaddr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   setUp  s    	
c             C   su   t  j d  t j t j t j  |  _ t j t t t	 t
 t d  d f } |  j j |  |  j j   |  _ d  S(   Ng?i   i    (   u   timeu   sleepu   socketu   AF_TIPCu   SOCK_STREAMu   cliu   TIPC_ADDR_NAMEu
   TIPC_STYPEu
   TIPC_LOWERu   intu
   TIPC_UPPERu   connectu   getsocknameu   cliaddr(   u   selfu   addr(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   clientSetUp  s    	c             C   s<   |  j  j d  } |  j | t  |  j |  j |  j  d  S(   Ni   (   u   connu   recvu   assertEqualu   MSGu   cliaddru   connaddr(   u   selfu   msg(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu
   testStream  s    c             C   s!   |  j  j t  |  j  j   d  S(   N(   u   cliu   sendu   MSGu   close(   u   self(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   _testStream  s    N(   u   __name__u
   __module__u   __init__u   setUpu   clientSetUpu
   testStreamu   _testStream(   u
   __locals__(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   TIPCThreadableTest  s
   
	
		u   TIPCThreadableTestc           	   C   s   t  t t t t t t g }  t j d k o |  j	 t
 t g  n |  j	 t t t t t t t t g  t t d  o |  j t  n t j d k o |  j t  n t   o |  j t  |  j t  n t j   } t j |    t j |   d  S(   Nu   macu
   socketpairu   linux2(    u   GeneralModuleTestsu   BasicTCPTestu   TCPCloserTestu   TCPTimeoutTestu   TestExceptionsu   BufferIOTestu   BasicTCPTest2u   sysu   platformu   extendu   BasicUDPTestu   UDPTimeoutTestu   NonBlockingTCPTestsu   FileObjectClassTestCaseu!   UnbufferedFileObjectClassTestCaseu#   LineBufferedFileObjectClassTestCaseu$   SmallBufferedFileObjectClassTestCaseu   NetworkConnectionNoServeru   NetworkConnectionAttributesTestu   NetworkConnectionBehaviourTestu   hasattru   socketu   appendu   BasicSocketPairTestu   TestLinuxAbstractNamespaceu   isTipcAvailableu   TIPCTestu   TIPCThreadableTestu   supportu   threading_setupu   run_unittestu   threading_cleanup(   u   testsu   thread_info(    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu	   test_main  s.    

u   __main__(9   u   unittestu   testu   supportu   errnou   socketu   selectu   _threadu   threadu	   threadingu   timeu	   tracebacku   queueu   sysu   osu   arrayu   weakrefu   proxyu   signalu   HOSTu   MSGu   TestCaseu   SocketTCPTestu   SocketUDPTestu   ThreadableTestu   ThreadedTCPSocketTestu   ThreadedUDPSocketTestu   SocketConnectedTestu   SocketPairTestu   GeneralModuleTestsu   BasicTCPTestu   BasicUDPTestu   TCPCloserTestu   BasicSocketPairTestu   NonBlockingTCPTestsu   FileObjectClassTestCaseu!   UnbufferedFileObjectClassTestCaseu#   LineBufferedFileObjectClassTestCaseu$   SmallBufferedFileObjectClassTestCaseu   objectu   NetworkConnectionTestu   BasicTCPTest2u   NetworkConnectionNoServeru   NetworkConnectionAttributesTestu   NetworkConnectionBehaviourTestu   TCPTimeoutTestu   UDPTimeoutTestu   TestExceptionsu   TestLinuxAbstractNamespaceu   BufferIOTestu
   TIPC_STYPEu
   TIPC_LOWERu
   TIPC_UPPERu   isTipcAvailableu   TIPCTestu   TIPCThreadableTestu	   test_mainu   __name__(    (    (    u-   /mit/python/lib/python3.0/test/test_socket.pyu   <module>   sj   	
b	! 0UDj		69	$	