U #hJ @sddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZzddlmZWn eefk rddlZYnXddlmZddlmZddlZee ddZ e!d"Z#zddl$m$Z$dd Z%Wnek r8d d Z%YnXd d Z&dXddZ'ej(j)ej(j*fZ+ddZ,ddZ-dYddZ.ddZ/ej01drdZddZ2ddZ3ne j4Z3dd Z4d!d"Z5d[d$d%Z6d&d'Z7d(d)Z8d*d+Z9zdd,l m:Z:Wnek rd-d.Z:YnXd/d0Z;d\d1d2Zd7d8Z?d9d:Z@d;d<ZAd^d=d>ZBd?d@ZCd_dAdBZDdCdDZEdEdFZFd`dHdIZGdJdKZHdLdMZIdNdOZJdPdQZKdadRdSZLdTdUZMdVdWZNdS)bN)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-229l629p/gunicorn/util.py _setproctitle4sr cCsdSNr rr r r r 7scsBt|}fdd|jD}|s6tdff|dS)Ncs$g|]}|jkr|jkr|qSr groupname).0epr r r =s z$load_entry_point..zEntry point %r not foundr)importlib_metadata distribution entry_points ImportErrorload)rrrZdist_objZepsr r r load_entry_point;s  r 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|} Wn2tk rvt }d}t |||fYnXt| | SdS)Nzegg:#z)class uri %r invalid or not found: [%s].Zgunicorn)inspectisclass startswithsplitrsplit ValueErrorr Exception traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsectionZ entry_strdistrexcmsg componentsklassmodr r r load_classDsP       r8cCs4t|}d}|jD]}|jtkr|d7}q|S)Nrr)r signature parametersvalueskind positionals)fsigarityparamr r r get_arity|s    rBcCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidr r r get_usernamesrGFcCs|rb|r.z t|}Wntk r,d}YnXt|d@}|rLt||n|tkrbt||r||tkr|t|dS)z) set user and group of workers processes FiN) rGKeyErrorabsos initgroupsgetgidsetgidgetuidsetuid)rFgidrKusernamer r r set_owner_processs     rRcCst|||dSr )rJchown)pathrFrPr r r rSsrSwincCs|||r|}ntj|\}}|p(d}d}|dkrjt|}|rJ|sVn||krVdSt||d9}q.tjd|tdddS)NrgMbP?g?z)tests may fail, delete still pending for ) stacklevel) rJrTr"listdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamertimeoutLr r r _waitfors     rdcCsttj|dSr )rdrJunlink)filenamer r r _unlinksrgc CsHz t|Wn6tk rB}z|jtjtjfkr2W5d}~XYnXdSr )rgOSErrorerrnoENOENTENOTDIR)rferrorr r r res  recCsBzttj|Wn*tk r(YdStk r<YdSXdS)NFT)socket inet_ptonAF_INET6rhr$)addrr r r is_ipv6srq8000cCs2td|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]::rVz0.0.0.0z%r is not a valid port number.)rematchr"r!intr$r(lower)netloc default_portfdhostportr r r parse_addresss.        rcCs,t|tj}|tjO}t|tj|dSr )fcntlZF_GETFDZ FD_CLOEXECZF_SETFDr~flagsr r r close_on_execs rcCs(t|tjtjB}t|tj|dSr )rZF_GETFLrJ O_NONBLOCKZF_SETFLrr r r set_non_blockingsrcCs&z |Wntk r YnXdSr )closerh)sockr r r r s r) closerangec Cs8t||D](}zt|Wq tk r0Yq Xq dSr )rangerJrrh)Zfd_lowZfd_highr~r r r rs rcCsDt|tr|d}dt|}d|d|dg}||dS)Nzutf-8z%X s ) isinstancestrencoder)r-sendall)rdata chunk_sizechunkr r r write_chunks    rcCs|rt||S||dSr )rr)rrchunkedr r r write's rc CsJ|}|dkr:z|dt|||WS|dXn t|||SdS)Ngrr) gettimeout setblockingr)rrrrbr 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)textwrapdedenthtmlescaperr)rr)rZ status_intrrZ html_errorhttpr r r write_error9s  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. rVNFT)sysexc_infotb_framef_code__code__tb_next)r>tbr r r _called_with_wrong_argsPs 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)NrvrZ 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)rargr r r rszimport_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.rwz%Failed to find application object: %rz$Application object must be callable.)'r"r)r+r,rendswithrJrTexistsr#rparsebody SyntaxErrorrrNameidZCallr_argskeywordsr$loggingrootlevelDEBUGr.AttributeErrorr&print_exceptionrr TypeErrorrr-format_exception_onlystripcallable) modulepartsobjr7r4Z expressionrrkwargsZis_debugapper r r import_appjsn            rcCspzNttjd}tt}|j|jkrD|j|jkrDtjd}nt}Wntk rjt}YnX|S)NZPWD)rJstatenvirongetcwdst_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)rZemailutils formatdate) timestampsr r r http_datesrcCs|tkSr )r{r hop_headers)headerr r r is_hoppishsrcsdtjkrtrtdttr6tdtd|stddtttj t ddkr|t dt dt dnPtttj dkrt dt dfdd }|t jd|t jdd S) zo Standard daemonization of a process. http://www.faqs.org/faqs/unix-faq/programmer/faq/ section 1.7 Z GUNICORN_FDrTrrVcsLz2|}||kr0|r0t|t|Wntk rFYnXdSr )filenoisattyrJrdup2r)streamZ fd_expectr~Zfd_nullr r redirect s zdaemonize..redirectN)rJrfork_exitsetsidumaskropen REDIRECT_TOO_RDWRset_inheritablerrrstdoutstderr)Zenable_stdio_inheritancerr rr daemonizes,           rc CsHzttdWn.tk rBtdttfYnXdS)N@z%s.%s)randomseedrJurandomNotImplementedErrorrZgetpidr r r r r-src CsZz"t|d}|W5QRXWn2tk rT}ztd||fW5d}~XYnXdS)NrzError: '%s' isn't writable [%r])rrrhr()rTr>rr r r check_is_writable4s  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)hasattrrrrhioUnsupportedOperation)rr r r has_filenoFs  rcCsftdtjd|}t|D]*\}}|dkr6d|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r4linesiliner r r r]Ssr]cstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error)z Content-Typez text/plainzContent-Length)rr))rZstart_responser4r r rcs zmake_fail_app..app)r)r4rr r r make_fail_app`s r cCs<|dr0tjd|}|j|jdddStj|S)Nz//rr)rT)r!urllibrurlsplit_replacerT)r/rr r r split_request_urims rcCs:z*|dkr|}|j|k r$|||W5d}d}XdSr ) __traceback__with_traceback)tprrr r r reraisezs  rcCst|tr|St|dS)Nr)rr)rr r r bytes_to_strs rcCstj|dS)Nzlatin-1)r runquote_to_bytesdecode)stringr r r unquote_to_wsgi_strsr)rr)F)F)rr)F)F)N)F)r)N)Or email.utilsrrirrr+rrrrJrCrrxrmrrrZr&r\importlib.metadatametadatarModuleNotFoundErrorrZgunicorn.errorsrZgunicorn.workersr urllib.parser r.rsetr"rrr rr8 ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr=rBrGrRrSplatformr!rdrgrerqrrrrrrrrrrrrrrrrrrrr]r rrrrr r r r s       3   !      S  V