Ñò ÉbMQc@sŽddkZddkZddkZddkZddkZddkZddklZddkl Z ddk l Z ddk l Z ddk l Z ddk lZddk lZdd klZdd klZdd klZdd klZdd klZddklZddklZeieƒZd„Zd„Zhd„d6d„d6d„d6d„d6Z d„Z!eƒZ"d„Z#d„Z$d„Z%h d„d6d„d 6d!„d"6d#„d6d$„d%6e%d&6d'„d(6e$d)6d*„d6Z&d+d,„Z'd-Z(e(d.d/d07Z(ed1„ƒZ)d2efd3„ƒYZ*d4„e_+d5efd6„ƒYZ,d7„Z-ed8jo e!ƒndS(9iÿÿÿÿN(tRequest(tResponse(turl_open(tbytes_(treraise(tQueue(tEmpty(tcontextmanager(t assert_raises(teq_(t make_server(tWSGIRequestHandler(t WSGIServer(t ServerHandlerc Csqttƒiiƒ}zQ|~}xAtD]9}t|i|ddƒ}|iƒdjpt‚q*WWdQXdS(s‡ Test actual request/response cycle in the presence of Request.copy() and other methods that can potentially hang. ttimeoutitokN( tservet_test_app_req_readingt__exit__t __enter__t_test_ops_req_readRturltreadtAssertionError(t_[1]tservertkeytresp((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyttest_request_readings #cCs\t|ƒ}tid|iƒt|i}||ƒtidƒtdƒ}|||ƒS(Nsstarting test operation: %stdoneR(Rtlogtdebugt path_infoRR(tenvtsrtreqttest_optr((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR"s     cCs |iƒS((tcopy(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyt,ss/copycCs |iiƒS((t body_fileR(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'-ss /read-allcCs|iidƒS(i(R(R(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'.ss/read-0cCs |iƒS((tmake_body_seekable(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'/ss/make-seekablec Cs¬ttƒiiƒ}zŒ|~}x|tD]t}t||ƒytiddƒ}Wn"tj ot d|ƒ‚nX|dj od|fGHt |ƒq*q*WWdQXdS(NRisError during test %ssError during test:( Rt_test_app_req_interruptRRt_test_ops_req_interruptt_send_interrupted_reqt _global_restgetRRtNoneR(RRtpathtres((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyttest_interrupted_request8s#   cCsµd}ypt|ƒ}|i}||jotd||fƒ‚nt|i}tid|iƒtt||ƒWnt i t i ƒƒnXt i dƒ|dgƒgSdS(Ni †s*request.content_length is %s instead of %ssRunning test: %ss200 OK(Rtcontent_lengthRR+R RtinfoRtIOErrorR-tputtsystexc_infoR/(R!R"t target_clR#tcltop((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR*Fs      cCsB|iidƒdjpt‚tid|id|iƒ}dS(Nittfptenviron(R(RRtcgit FieldStorageR>(R#td((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyt _req_int_cgiXs   cCsMyt|iiƒdƒWntj otdƒ‚nX|iiƒdS(Nsa=b sFalse disconnect alert(teqR(treadlineR5R(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyt_req_int_readline`s cCs |iƒS((R&(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'jscCs|iS((tbody(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'kss /read-bodycCs|iS((tPOST(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'lss /read-postcCs |iiƒS((R(R(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'mscCs|iidƒS(iii@(R(R(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'nss/read-too-muchs /readlinecCs |iiƒS((R(t readlines(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'pss /readliness /read-cgicCs |iƒS((R)(R#((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'rst/cCsjtiƒ}|id|ifƒ|idƒ}|itt|ƒƒ|iƒ|iƒ|iƒdS(Nt localhosttwb( tsockettconnectt server_porttmakefiletwriteRt_interrupted_reqtflushtclose(RR0tsocktf((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR,vs   s]POST %s HTTP/1.0 content-type: application/x-www-form-urlencoded content-length: 100000 sa=b z=txi'ccs»t|ƒ}zXtid|iƒ}|itƒ|iƒd|i|_t i d|iƒ|VWdt i dƒ|i ƒ|i dƒ|i ƒot idƒnt i dƒXdS(Nttargetshttp://localhost:%dsserver started on %ssshutting server downisworker is hangedsserver stopped(t_make_test_servert threadingtThreadt serve_forevert setDaemontTruetstartRNRRRtshutdowntjointisAlivetwarning(tappRtworker((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyRˆs        t QuietHanldercBseZd„ZRS(cGsdS(N((tselftargs((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyt log_requestžs(t__name__t __module__Rh(((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyRescCsdS(N(R/(((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyR'¡st QuietServercBseZd„ZRS(cCsdS(N((RfR#taddr((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyt handle_error¤s(RiRjRm(((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyRk£sc CsŠd }x}tdddƒD]i}yEti|d|ƒ}td||dtd tƒ}d |_|SWq|djo‚q‚qXqWdS( NiiiiiÿÿÿÿiRJt server_classt handler_classiiiÿÿ(trangetrandomtrandintR RkReR(RctmaxporttitportR((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pyRX§s   t__main__(.R7tloggingRYRqRLR?t webob.requestRtwebob.responseRt webob.compatRRRRRt contextlibRt nose.toolsRR RCtwsgiref.simple_serverR R R R t getLoggerRiRRRRR2R-R*RBRER+R,RQRReRmRkRX(((s4/home/chrism/projects/webob/tests/test_in_wsgiref.pytsh