yX @sddlZddlZddlZddlmZddlmZddlZedZej dkr{dej d}t|d ro|jnt|drM|jqMqMWtj}xtj||jjkrd} x6|D].}|jj|jjkr| d7} qqW| sdS|jtjd qW|j j d|j!dd|DWnYnXdS)N server_sideTzwsgi.multithreadZSERVER_SOFTWAREZ applicationspawnr2Z handler_classenvironhandleg?closekillrz Worker graceful timeout (pid:%s)cSs"g|]}|jddqS)timeoutr;)stop).0serverrrr s z$GeventWorker.run..)"r7Zis_ssldictZ ssl_optionsr% setblockingrZworker_connections server_classr updateVERSIONrr2 wsgi_handlerrr>rstartr'aliver/r#sleephasattrr?r@timeZgraceful_timeoutpoolZ free_countsizewarningpid) r+ZserversZssl_argsr,rQr=rDZhfuntsZ acceptingrrrrunZsV              zGeventWorker.runc sGytt|j|Wn&tjk r1Yntk rBYnXdS)N)r.rhandle_requestr#Z GreenletExit SystemExit)r+r)r5rrrWs  zGeventWorker.handle_requestcs#tjtt|j||dS)N)r#r<r.r handle_quit)r+sigframe)r5rrrYszGeventWorker.handle_quitrcsZ|jddl}|jj|jjdd|jjtt|jdS)NrZ fail_requestsr;) r-Z gevent.corecorereinitZ dns_shutdownZdns_initr.r init_process)r+r#)r5rrr^s     zGeventWorker.init_processcs;|jddlm}|jtt|jdS)Nr)hub)r-r#r_r]r.rr^)r+r_)r5rrr^s  )__name__ __module__ __qualname__rHrKr-r/r9rVrWrYr#r$r^rr)r5rr4s    <rc@s.eZdZdZdZdZddZdS)GeventResponseNcCs||_||_||_dS)N)statusheaderssent)r+rdreclengthrrr__init__s  zGeventResponse.__init__)r`rarbrdrerfrhrrrrrcs rccs.eZdZddZfddZS) PyWSGIHandlercCstj|j}tj|j}||}t|di}t|j||j}t|drdd|j j D}ng}|j j j |||j |dS)NZresponse_headersrecSs"g|]}|jddqS):r;)split)rChrrrrEs z-PyWSGIHandler.log_request..)r fromtimestampZ time_startZ time_finishgetattrrcrdZresponse_lengthrOrerDr2accessr=)r+rLfinishZ response_timeZ resp_headersrespZ req_headersrrr log_requests zPyWSGIHandler.log_requestcs3tt|j}|j|d<|j|d<|S)Nz gunicorn.sockZRAW_URI)r.ri get_environrpath)r+env)r5rrrss  zPyWSGIHandler.get_environ)r`rarbrrrsrr)r5rris  ric@seZdZdS) PyWSGIServerN)r`rarbrrrrrvs rvc@s"eZdZdZeZeZdS)GeventPyWSGIWorkerz&The Gevent StreamServer based workers.N)r`rarb__doc__rvrHrirKrrrrrws rw))rr0r&r functoolsrrP __import__r(platformr=r# ImportError RuntimeErrorZ gevent.poolrZ gevent.serverrZ gevent.socketr rr ZgunicornZgunicorn.http.wsgir Zgunicorn.workers.asyncr r r __version__rJrrrobjectrcZ WSGIHandlerriZ WSGIServerrvrwrrrrs8