File: //proc/self/root/proc/3/cwd/usr/lib/python2.4/test/test_asynchat.pyc
mò
‚=5Dc @ sˆ d k Z d k Z d k Z d k Z d k Z d k Z d Z d Z d e i f d „ ƒ YZ d e i
f d „ ƒ YZ d „ Z e ƒ d S( Ns 127.0.0.1i1Ô t echo_serverc B s t Z d „ Z RS( Nc C sã t i t i t i ƒ } | i t i t i d ƒ | i t t f ƒ | i
d ƒ | i ƒ \ } } d } x7 d | j o) | i d ƒ } | p Pn | | } ql Wx% | o | i | ƒ } | | } q¦ W| i ƒ | i ƒ d S( Ni t s
i
( t sockett AF_INETt SOCK_STREAMt sockt
setsockoptt
SOL_SOCKETt SO_REUSEADDRt bindt HOSTt PORTt listent acceptt connt clientt buffert recvt datat sendt nt close( t selfR R R R R R ( ( t( /usr/lib/python2.4/test/test_asynchat.pyt run s$
( t __name__t
__module__R ( ( ( R R s t echo_clientc B s, t Z d „ Z d „ Z d „ Z d „ Z RS( Nc C sS t i i | ƒ | i t i t i ƒ | i t t
f ƒ | i d ƒ d | _ d S( Ns
R (
t asynchatt
async_chatt __init__R t
create_socketR R R t connectR
R t set_terminatorR ( R ( ( R R s
c C s d GHd S( Nt Connected( ( R ( ( R t handle_connect& s c C s | i | | _ d S( N( R R R ( R R ( ( R t collect_incoming_data) s c C s) d Gt | i ƒ GHd | _ | i ƒ d S( Ns Received:R ( t reprR R R ( R ( ( R t found_terminator, s ( R R R R# R$ R& ( ( ( R R s c C sQ t ƒ } | i ƒ t i d ƒ t ƒ } | i d ƒ | i d ƒ t i ƒ d S( Ni s hello s world
(
R t st startt timet sleepR t ct pusht asyncoret loop( R+ R' ( ( R t main1 s
(
t threadR- R R t threadingR) R
R t ThreadR R R R/ ( R R- R R0 R R1 R
R R) R/ R ( ( R t ? s -