o dTH@sddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlmZddlmZddlZee ddZedZz ddl m Z dd Z!Wn e"yd d Z!Ynw dVd dZ#ej$j%ej$j&fZ'ddZ(ddZ)dWddZ*ddZ+ej,-drdWddZ.ddZ/ne j0Z/ddZ0dd Z1dXd"d#Z2d$d%Z3d&d'Z4d(d)Z5zdd*l m6Z6Wn e"yd+d,Z6Ynwd-d.Z7dWd/d0Z8dWd1d2Z9d3d4Z:d5d6Z;d7d8Zd=d>Z?dWd?d@Z@dAdBZAdCdDZBdZdFdGZCdHdIZDdJdKZEdLdMZFdNdOZGdYdPdQZHdRdSZIdTdUZJdS)[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 A/app/.heroku/python/lib/python3.10/site-packages/gunicorn/util.py _setproctitle2r cCsdSNr rr r r r 5s gunicorn.workers.sync.SyncWorkergunicorn.workersc Cs`t|r|S|drI|dd}z |dd\}}Wn ty*|}|}Ynwzt|||WStyHt }d}t |||fw|d}t |dkr |dr`|dd}|t vrlt |d}nztd||WStyt }d}t |||fw|d} z td|} Wnt }d}t |||ft| | S) Nzegg:#z)class uri %r invalid or not found: [%s].TZgunicorn)inspectisclass startswithsplitrsplit ValueError pkg_resourcesload_entry_point Exception traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsectionZ entry_strdistnameexcmsg componentsklassmodr r r load_class9sT           r0cCs4t|}d}|jD] }|jtvr|d7}q |S)Nrr)r signature parametersvalueskind positionals)fsigarityparamr r r get_arityqs  r:cCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidr r r get_username|s r?FcCsv|r0|rzt|}Wn tyd}Ynwt|d@}|r%t||n |tkr0t||r9t|dSdS)z) set user and group of workers processes FiN)r?KeyErrorabsos initgroupsgetgidsetgidsetuid)r>gidrCusernamer r r set_owner_processs     rIcCst|||dSr )rBchown)pathr>rGr r r rJrJwincCs|||r |}n tj|\}}|pd}d}|dkr9t|}|r&|s,dS||vr,dSt||d9}|dkstjd|tdddS)NrgMbP?g?z)tests may fail, delete still pending for ) stacklevel) rBrKrlistdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamer*timeoutLr r r _waitfors$    r\cCsttj|dSr )r\rBunlink)filenamer r r _unlinkr r_c CsJzt|WdSty$}z|jtjtjfvrWYd}~dSd}~wwr )r_OSErrorerrnoENOENTENOTDIR)r^errorr r r r]sr]cCs>z ttj|WdStjyYdStyYdSw)NFT)socket inet_ptonAF_INET6rdr)addrr r r is_ipv6s ri8000cCs$td|rtd|dS|dr-|dd}zt|WSty,td|dw|dr9|dd}||}}d|vr\d |vr\|d d dd}|d |gd}nd |vro|d |gdd \}}n |dkrxd|}}zt|}Wn tytd|w||fS)Nz unix:(//)?rzfd://z"%r is not a valid file descriptor.ztcp://r[]rz]::rNz0.0.0.0z%r is not a valid port number.)rematchrrintrrlower)netloc default_portfdhostportr r r parse_addresss2            rycCs,t|tj}|tjO}t|tj|dSr )fcntlF_GETFD FD_CLOEXECF_SETFDrvflagsr r r close_on_execs rcCs(t|tjtjB}t|tj|dSr )rzF_GETFLrB O_NONBLOCKF_SETFLr~r r r set_non_blockingsrcCs&z|WdStjyYdSwr )closererd)sockr r r rs r) closerangec Cs4t||D]}zt|WqtyYqwdSr )rangerBrr`)Zfd_lowZfd_highrvr r r r s 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 writes rc CsL|}|dkr z|dt|||W|dS|dwt|||S)Ngrr) gettimeout setblockingr)rrrrZr 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_error.s  rcCsFtd}z|dur|jj|jurW~dS|j}|dus W~dS~w)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. rNNFT)sysexc_infotb_framef_code__code__tb_next)r6tbr r r _called_with_wrong_argsEs   rc Cs|dd}t|dkrd}n |d|d}}zt|}Wn#tyB|drAtj|rAd}t|| ddd|fwz t j |dd j }Wn t yZtd |wt|t jri|j}d}}n=t|t jrt|jt js|td ||jj}zd d |jD}dd|jD}Wntytd|wtd |tjjtjk} zt||} Wnty| rtjt td||fw|durz | |i|} Wnt!y} zt"| rtd#t$t!| %d} ~ ww| durtd|t&| s td| S)NrnrZ 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.roz%Failed to find application object: %rz$Application object must be callable.)'rr r"r# ImportErrorendswithrBrKexistsrrparsebody SyntaxErrorrrNameidCallrWargskeywordsrloggingrootlevelDEBUGr%AttributeErrorrprint_exceptionrr TypeErrorrr$format_exception_onlystripcallable) modulepartsobjr/r,Z expressionr*rkwargsZis_debugapper r r import_app_sz            rcCsrz*ttjd}tt}|j|jkr$|j|jkr$tjd}W|St}W|Sty8t}Y|Sw)NZPWD)rBstatenvirongetcwdst_inost_devr)abcwdr r r rs   rcCs&|durt}tjj|ddd}|S)z@Return the current date and time formatted for a message header.NFT) localtimeusegmt)rRemailutils formatdate) timestampsr r r http_datesrcCs|tvSr )rsr hop_headers)headerr r r is_hoppishr rcsdtjvrptrtdttrtdtd|sFtddtttj dkr8t dt dt dd Stttj dkr\t dt dfdd}|t j d|t jdd Sd S) z~ Standard daemonization of a process. http://www.svbug.com/documentation/comp.unix.programmer-FAQ/faq_2.html#SEC16 Z GUNICORN_FDrrrNcsVz |}||kr|rt|t|WdSWdSWdSty*YdSwr )filenoisattyrBrdup2r)streamZ fd_expectrvZfd_nullr r redirects  zdaemonize..redirectN)rBrfork_exitsetsidumaskropen REDIRECT_TOO_RDWRrrrstdoutstderr)Zenable_stdio_inheritancerr rr daemonizes,           rc CsFz ttdWdSty"tdttfYdSw)N@z%s.%s)randomseedrBurandomNotImplementedErrorrRgetpidr r r r rs   rc CsDzt|d}Wnty}ztd||fd}~ww|dS)NrzError: '%s' isn't writable [%r])rIOErrorrr)rKr6rr r r check_is_writeable&s rutf8cCs.t|tr|St|tstd|||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|WdStttjfyYdSw)NrFT)hasattrrrrioUnsupportedOperation)rr r r has_fileno8s  rcCsftdtjd|}t|D]\}}|dkrd|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r,linesiliner r r rUEsrUcstfdd}|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 r r make_fail_appRs r cCs<|drtjd|}|j|jdddStj|S)Nz//rr)rK)rurllibrurlsplit_replacerK)r&rr r r split_request_uri_s  rcCs2z|dur|}|j|ur|||d}d}wr ) __traceback__with_traceback)tprrr r r reraisels  rcCst|tr|St|dS)Nr)rr)rr r r bytes_to_strxs  rcCstj|dS)Nzlatin-1)r runquote_to_bytesdecode)stringr r r unquote_to_wsgi_str~rLr)rr)F)rjr )r)Kr email.utilsrrarzrr"rrrrBr;rrprerrrRrrTrZgunicorn.errorsrZgunicorn.workersr urllib.parser r%rsetrrrr rr0 ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr5r:r?rIrJplatformrr\r_r]riryrrrrrrrrrrrrrrrrrrrUr rrrrr r r r s         3    !      S  S