U dTH@sddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlmZddlmZddlZee ddZedZzddl m Z dd Z!Wne"k rd d Z!YnXdVd dZ#ej$j%ej$j&fZ'ddZ(ddZ)dWddZ*ddZ+ej,-drndXddZ.ddZ/ne j0Z/ddZ0dd Z1dYd"d#Z2d$d%Z3d&d'Z4d(d)Z5zdd*l m6Z6Wne"k rd+d,Z6YnXd-d.Z7dZd/d0Z8d[d1d2Z9d3d4Z:d5d6Z;d7d8Zd=d>Z?d]d?d@Z@dAdBZAdCdDZBd^dFdGZCdHdIZDdJdKZEdLdMZFdNdOZGd_dPdQZHdRdSZIdTdUZJdS)`N)AppImportError)SUPPORTED_WORKERSdevnullz /dev/nullz connection keep-alive proxy-authenticate proxy-authorization te trailers transfer-encoding upgrade server date  setproctitlecCstd|dS)Nz gunicorn: %srtitler 1/tmp/pip-unpacked-wheel-1tw_qy24/gunicorn/util.py _setproctitle2sr cCsdSNr rr r r r 5s gunicorn.workers.sync.SyncWorkergunicorn.workersc Cst|r|S|dr|dd}z|dd\}}Wntk rV|}|}YnXzt|||WStk rt }d}t |||fYnXn|d}t |dkr*|dr|dd}|t krt |d}q*ztd||WStk r&t }d}t |||fYqXq|d} ztd|} Wn(t }d}t |||fYnXt| | SdS)Nzegg:#z)class uri %r invalid or not found: [%s].Zgunicorn)inspectisclass startswithsplitrsplit ValueError pkg_resourcesload_entry_point Exception traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsectionZ entry_strdistnameexcmsg componentsklassmodr r r load_class9sP       r/cCs4t|}d}|jD]}|jtkr|d7}q|S)Nrr)r signature parametersvalueskind positionals)fsigarityparamr r r get_arityqs    r9cCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidr r r get_username|sr>FcCst|rb|r.z t|}Wntk r,d}YnXt|d@}|rLt||n|tkrbt||rpt|dS)z) set user and group of workers processes FiN)r>KeyErrorabsos initgroupsgetgidsetgidsetuid)r=gidrBusernamer r r set_owner_processs     rHcCst|||dSr )rAchown)pathr=rFr r r rIsrIwincCs|||r|}ntj|\}}|p(d}d}|dkrjt|}|rJ|sVn||krVdSt||d9}q.tjd|tdddS)NrgMbP?g?z)tests may fail, delete still pending for ) stacklevel) rArJrlistdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamer)timeoutLr r r _waitfors     rZcCsttj|dSr )rZrAunlink)filenamer r r _unlinksr]c CsHz t|Wn6tk rB}z|jtjtjfkr2W5d}~XYnXdSr )r]OSErrorerrnoENOENTENOTDIR)r\errorr r r r[s  r[cCsDzttj|Wn,tjk r*YdStk r>YdSXdS)NFT)socket inet_ptonAF_INET6rbr)addrr r r is_ipv6srg8000cCs2td|rtd|dS|dr`|dd}z t|WStk r^td|dYnX|drx|dd}||}}d|krd |kr|d d dd}|d |gd}n8d |kr|d |gdd \}}n|dkrd|}}z t|}Wn"tk r$td|YnX||fS)Nz unix:(//)?rzfd://z"%r is not a valid file descriptor.ztcp://r[]rz]::rLz0.0.0.0z%r is not a valid port number.)rematchrrintrrlower)netloc default_portfdhostportr r r parse_addresss.        rwcCs,t|tj}|tjO}t|tj|dSr )fcntlZF_GETFDZ FD_CLOEXECZF_SETFDrtflagsr r r close_on_execs r{cCs(t|tjtjB}t|tj|dSr )rxZF_GETFLrA O_NONBLOCKZF_SETFLryr r r set_non_blockingsr}cCs(z |Wntjk r"YnXdSr )closercrb)sockr r r r~s r~) closerangec Cs8t||D](}zt|Wq tk r0Yq Xq dSr )rangerAr~r^)Zfd_lowZfd_highrtr r r r s rcCsDt|tr|d}dt|}d|d|dg}||dS)Nzutf-8z%X s ) isinstancestrencoderr#sendall)rdata chunk_sizechunkr r r write_chunks    rcCs|rt||S||dSr )rr)rrchunkedr r r writes rc CsJ|}|dkr:z|dt|||WS|dXn t|||SdS)Ngrr) gettimeout setblockingr)rrrrXr r r write_nonblock"s rcCsLtd|t|d}tdt||t||f}t||ddS)Nz %(reason)s

%(reason)s

%(mesg)s )reasonmesgzl HTTP/1.1 %s %s Connection: close Content-Type: text/html Content-Length: %d %slatin1)textwrapdedenthtmlescaperrrr)rZ status_intrrZ html_errorhttpr r r write_error.s  rcCsDtd}z.|dk r4|jj|jkr,WdS|j}qWdS~XdS)zCheck whether calling a function raised a ``TypeError`` because the call failed or because something in the function raised the error. :param f: The function that was called. :return: ``True`` if the call failed. rLNFT)sysexc_infotb_framef_code__code__tb_next)r5tbr r r _called_with_wrong_argsEs rc CsN|dd}t|dkrd}n|d|d}}zt|}WnLtk r|drtj|rd}t|| ddd|fYnXzt j |dd j }Wn t k rtd |YnXt|t jr|j}d}}nt|t jrZt|jt jstd ||jj}z$d d |jD}dd|jD}Wn"tk rVtd|YnXn td |tjjtjk} zt||} Wn:tk r| rtjt td||fYnX|dk r"z| ||} WnJt!k r } z*t"| rtd#t$t!| %W5d} ~ XYnX| dkr8td|t&| sJtd| S)NrlrZ applicationrz.pyz1Failed to find application, did you mean '%s:%s'?reval)modez9Failed to parse %r as an attribute name or function call.z,Function reference must be a simple name: %rcSsg|]}t|qSr )ast literal_eval).0argr r r szimport_app..cSsi|]}|jt|jqSr )rrrvalue)rkwr r r szimport_app..z/Failed to parse arguments as literal values: %rz"Failed to find attribute %r in %r.rmz%Failed to find application object: %rz$Application object must be callable.)'rrr!r" ImportErrorendswithrArJexistsrrparsebody SyntaxErrorrrNameidZCallrUargskeywordsrloggingrootlevelDEBUGr$AttributeErrorrprint_exceptionrr TypeErrorrr#format_exception_onlystripcallable) modulepartsobjr.r+Z expressionr)rkwargsZis_debugapper r r import_app_sn            rcCspzNttjd}tt}|j|jkrD|j|jkrDtjd}nt}Wntk rjt}YnX|S)NZPWD)rAstatenvirongetcwdst_inost_devr)abcwdr r r rs  rcCs&|dkrt}tjj|ddd}|S)z@Return the current date and time formatted for a message header.NFT) localtimeusegmt)rPemailutils formatdate) timestampsr r r http_datesrcCs|tkSr )rqr hop_headers)headerr r r is_hoppishsrcsdtjkrtrtdttr6tdtd|stddtttj dkrpt dt dt dnPtttj dkrt dt dfdd}|t j d|t jdd S) z~ Standard daemonization of a process. http://www.svbug.com/documentation/comp.unix.programmer-FAQ/faq_2.html#SEC16 Z GUNICORN_FDrrrLcsLz2|}||kr0|r0t|t|Wntk rFYnXdSr )filenoisattyrAr~dup2r)streamZ fd_expectrtZfd_nullr r redirects zdaemonize..redirectN)rArfork_exitsetsidumaskropen REDIRECT_TOO_RDWRrr~rstdoutstderr)Zenable_stdio_inheritancerr rr daemonizes*          rc CsHzttdWn.tk rBtdttfYnXdS)N@z%s.%s)randomseedrAurandomNotImplementedErrorrPgetpidr r r r rsrc CsNzt|d}Wn2tk r@}ztd||fW5d}~XYnX|dS)NrzError: '%s' isn't writable [%r])rIOErrorrr~)rJr5rr r r check_is_writeable&s "rutf8cCs.t|tr|St|ts$td|||S)z+Converts a string argument to a byte stringz%r is not a string)rbytesrrr)rencodingr r r to_bytestring.s    rc Cs>t|dsdSz |Wntttjfk r8YdSXdS)NrFT)hasattrrrrioUnsupportedOperation)rr r r has_fileno8s  rcCsftdtjd|}t|D]*\}}|dkr6d|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r+linesiliner r r rSEsrScstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error)z Content-Typez text/plainzContent-Length)rr)rZstart_responser+r r rUs zmake_fail_app..app)r)r+rr rr make_fail_appRs rcCs<|dr0tjd|}|j|jdddStj|S)Nz//rr)rJ)rurllibrurlsplit_replacerJ)r%rr r r split_request_uri_s rcCs:z*|dkr|}|j|k r$|||W5d}d}XdSr ) __traceback__with_traceback)tprrr r r reraisels  r cCst|tr|St|dS)Nr)rr)rr r r bytes_to_strxs r cCstj|dS)Nzlatin-1)rrunquote_to_bytesdecode)stringr r r unquote_to_wsgi_str~sr)r r)F)F)rh)F)F)N)F)r)N)Kr email.utilsrr_rxrr!rrrrAr:rrnrcrrrPrrRrZgunicorn.errorsrZgunicorn.workersr urllib.parserr$rsetrrrr rr/ ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr4r9r>rHrIplatformrrZr]r[rgrwr{r}r~rrrrrrrrrrrrrrrrSrrr r rr r r r s      3   !      S  S