-í ™º‘;csdZdkZdkZdkZdkZ edjoÈdkZdeijoJdkZdkZeiei ei ƒZ eidZ e i e dfƒeidZe iedƒeie idƒd ƒZd ZgZx]eejoLe id ƒZe oPn$eeeƒZ eieƒqW!dkZ"x$eD"]Z#eiieƒq‘Wn\%dkZ'd eifd „ƒYZAdeifd„ƒYZMeƒNei ƒndS(s=$Id: test_sendfile.py,v 3.3 2000/02/01 00:49:34 rushing Exp $Ns__main__s-cii1#is iiii s test_channelcs5')d„Z.d„Z1d„Z>d„ZRS(Ncs9)*tii||ƒ+|idƒ,d|_dS(Ns s(sasynchat_sendfilesasync_chat_with_sendfiles__init__sselfsconnsset_terminatorsbuffer(sselfsconnsaddr((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys__init__)scs./|i||_dS(N(sselfsbuffersdata(sselfsdata((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pyscollect_incoming_data.scsÓ12|idf\}|_3|oŠ4ti|tidƒ}5ti|ddƒ}6ti|ddƒ7|i d|ƒ8|i |d||i ƒ9|i ƒn;|i dƒ<|i ƒdS(Nsi¤iis%08xs ok, bye ( sselfsbuffersfilenamesossopensO_RDONLYsfdslseekssizespushs push_sendfilessendfile_callbacksclose_when_done(sselfssizesfdsfilename((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pysfound_terminator1s cs>?ti|ƒdS(N(sossclosesfd(sselfssuccesssfd((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pyssendfile_callback>s(s__init__scollect_incoming_datasfound_terminatorssendfile_callback(((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys test_channel's   s test_servercs&ABddfd„ZId„ZRS(Nsi1#csYBC|ititiƒD|iƒE|i|ƒF|idƒGdG|GHdS(Nisserver started on( sselfs create_socketssocketsAF_INETs SOCK_STREAMsset_reuse_addrsbindsaddrslisten(sselfsaddr((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys__init__Bs  cs,IJ|iƒ\}}Kt||ƒdS(N(sselfsacceptsconnsaddrs test_channel(sselfsaddrsconn((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys handle_acceptIs(s__init__s handle_accept(((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys test_serverAs(!sRCS_IDsasyncoresosssocketsstrings__name__ssyssargvsoperatorsAF_INETs SOCK_STREAMssshostsconnectsfnamessendsatoisrecvssizestotalsblockssblockslensappendsbsstdoutswritesasynchat_sendfilesasync_chat_with_sendfiles test_channels dispatchers test_serversloop(sasynchat_sendfilestotalsasyncoressocketsRCS_IDsblocksshostssyssssbs test_channelsfnames test_serversoperatorssizesossblocksstring((sU/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/sendfile/test_sendfile.pys?sB