mς %U²Ic@sˆdkZdkZdkZdkZdkZdkZdZdZdeifd„ƒYZ dei fd„ƒYZ d„Z e ƒdS(Ns 127.0.0.1i1Τt echo_servercBstZd„ZRS(NcCsγtititiƒ}|ititidƒ|itt fƒ|i dƒ|i ƒ\}}d}x7d|jo)|idƒ}|pPn||}qlWx%|o|i|ƒ}||}q¦W|iƒ|iƒdS(Nits i (tsockettAF_INETt SOCK_STREAMtsockt setsockoptt SOL_SOCKETt SO_REUSEADDRtbindtHOSTtPORTtlistentaccepttconntclienttbuffertrecvtdatatsendtntclose(tselfRRRRRR((t//data/zmath/lib/python2.4/test/test_asynchat.pytrun s$   (t__name__t __module__R(((RR st echo_clientcBs,tZd„Zd„Zd„Zd„ZRS(NcCsStii|ƒ|ititiƒ|it t fƒ|i dƒd|_ dS(Ns R( tasynchatt async_chatt__init__Rt create_socketRRRtconnectR R tset_terminatorR(R((RRs  cCs dGHdS(Nt Connected((R((Rthandle_connect&scCs|i||_dS(N(RRR(RR((Rtcollect_incoming_data)scCs)dGt|iƒGHd|_|iƒdS(Ns Received:R(treprRRR(R((Rtfound_terminator,s (RRRR#R$R&(((RRs   cCsQtƒ}|iƒtidƒtƒ}|idƒ|idƒti ƒdS(Nishello sworld ( RtststartttimetsleepRtctpushtasyncoretloop(R+R'((Rtmain1s      ( tthreadR-RRt threadingR)R R tThreadRRRR/( RR-RR0RR1R RR)R/R ((Rt?s -