File: //lib64/python2.7/Demo/sockets/throughput.pyo
ó
A fc @ s] d d l Z d d l Z d d l Td
Z d Z d „ Z d „ Z d „ Z d „ Z e ƒ d S( iÿÿÿÿN( t *iPÃ i* i c C sd t t j ƒ d k r t ƒ n t j d d k r< t ƒ n$ t j d d k rY t ƒ n t ƒ d S( Ni i s -ss -c( t lent syst argvt usaget servert client( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt main s
c C s' t j t _ d GHd GHt j d ƒ d S( Ns* Usage: (on host_A) throughput -s [port]s7 and then: (on host_B) throughput -c count host_A [port]i ( R t stderrt stdoutt exit( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR " s c C sÓ t t j ƒ d k r+ t t j d ƒ } n t } t t t ƒ } | j d | f ƒ | j d ƒ d GHxg | j
ƒ \ } \ } } x | j t ƒ } | sœ Pn ~ qƒ W| j
d ƒ | j ƒ d G| Gd G| GHqh Wd S( Ni t i s Server ready...s OK
s Done witht port( R R R t evalt MY_PORTt sockett AF_INETt SOCK_STREAMt bindt listent acceptt recvt BUFSIZEt sendt close( R t st connt hostt
remoteportt data( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR ) s"
c C s¬ t t j ƒ d k r t ƒ n t t t j d ƒ ƒ } t j d } t t j ƒ d k rp t t j d ƒ } n t } d t d d } t j ƒ } t t
t ƒ } t j ƒ } | j | | f ƒ t j ƒ } d } x' | | k rý | d } | j
| ƒ q× W| j d ƒ t j ƒ } | j t ƒ }
t j ƒ } |
GHd G| G| G| G| G| GHd G| | G| | G| | G| | GHd
G| | GHd Gt t | d | | d ƒ Gd
GHd S( Ni i i t xi s
i s Raw timers:s
Intervals:s Total:s Throughput:gü©ñÒMbP?s K/sec.( R R R R t intR
R R t timeR R R t connectR t shutdownR t round( t countR R t testdatat t1R t t2t t3t it t4R t t5( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyR > s6
%
!izà ( R R R R R R R R R ( ( ( s/ /usr/lib64/python2.7/Demo/sockets/throughput.pyt <module> s