ó [³XMc@s¡ddlmZddlmZddlmZddlmZmZddlZdej fd„ƒYZ dej fd „ƒYZ d ej fd „ƒYZ dS( iÿÿÿÿ(tunittest(tloopback(tbasic(tprotocoltabstractNtBufferingServercBseZdZd„ZRS(tcCs|j|7_dS(N(tbuffer(tselftdata((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyt dataReceiveds(t__name__t __module__RR (((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyR stFileSendingClientcBseZd„Zd„ZRS(cCs ||_dS(N(tf(RR((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyt__init__scsDtjƒ}|jˆjˆjd„ƒ}|j‡fd†ƒdS(NcSs|S(N((tx((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pytscs ˆjjƒS(N(t transporttloseConnection(tr(R(s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyRs(Rt FileSendertbeginFileTransferRRt addCallback(Rtstd((Rs</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pytconnectionMades (R R RR(((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyR s tFileSenderTestCasecBseZd„Zd„ZRS(csjdddddd‰tƒ‰ttjˆƒƒ}tjˆ|ƒ}|j‡‡‡fd†ƒ|S(Ntxyzidtabct123csˆjˆjˆƒS(N(t assertEqualsR(R(RRttestStr(s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyR"s(RR tStringIORt loopbackTCPR(RtcR((RRR s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyttestSendingFiles  cCsrtjƒ}tjƒ}d|_tjdƒ}|j||d„ƒ}|j|jdƒ|j |j dƒdS(NiRcSs|S(N((R((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyR+ss0producer unregistered with deferred being called( RRRtFileDescriptort connectedR!Rt assertEqualtproducertNonet failUnlesstcalled(Rt fileSendertconsumert emptyFileR((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyttestSendingEmptyFile%s    (R R R$R/(((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyRs (t twisted.trialRttwisted.protocolsRRttwisted.internetRRR!tProtocolRR tTestCaseR(((s</usr/lib/python2.7/dist-packages/twisted/test/test_tpfile.pyts