o iK @sddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZzddlmZWneefycddlZYnwddlmZddlmZddlZee ddZ e!d"Z#ej$dkrdd Z%nzdd l&m&Z&m'Z'e'd d Z%Wn eyd d Z%Ynwd dZ(  dZddZ)ej*j+ej*j,fZ-ddZ.ddZ/d[ddZ0ddZ1ej$2drd[ddZ3dd Z4ne j5Z4d!d"Z5d#d$Z6d\d&d'Z7d(d)Z8d*d+Z9d,d-Z:zdd.l m;Z;Wneyd/d0Z;Ynwd1d2Zd7d8Z?d9d:Z@d;d<ZAd=d>ZBd]d?d@ZCdAdBZDd[dCdDZEdEdFZFdGdHZGd^dJdKZHdLdMZIdNdOZJdPdQZKdRdSZLd]dTdUZMdVdWZNdXdYZOdS)_N)AppImportError)SUPPORTED_WORKERSdevnullz /dev/nullz connection keep-alive proxy-authenticate proxy-authorization te trailers transfer-encoding upgrade server date darwincCdSNtitlerrA/home/ubuntu/.local/lib/python3.10/site-packages/gunicorn/util.py _setproctitle4r ) setproctitle getproctitlecCstd|dS)Nz gunicorn: %s)rr rrr r ?cCrrrr rrr r Br csBt|}fdd|jD}|stdff|dS)Ncs$g|]}|jkr|jkr|qSrgroupname).0eprrr Hsz$load_entry_point..zEntry point %r not foundr)importlib_metadata distribution entry_points ImportErrorload)rrrdist_objepsrrr load_entry_pointFs  r gunicorn.workers.sync.SyncWorkergunicorn.workersc Csdt|r|S|drH|dd}z |dd\}}Wn ty*|}|}Ynwzt|||WStyGt }d}t |||fw|d}t |dkr |dr_|dd}|t vrkt |d}nztd||WStyt }d}t |||fw| d} z td|} Wntyt }d}t |||fwt| | S) Nzegg:#z)class uri %r invalid or not found: [%s].Tgunicorn)inspectisclass startswithsplitrsplit ValueErrorr Exception traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsection entry_strdistrexcmsg componentsklassmodrrr load_classOsV            r@cCs4t|}d}|jD] }|jtvr|d7}q |S)Nrr!)r& signature parametersvalueskind positionals)fsigarityparamrrr get_aritys  rJcCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidrrr get_usernames rOFcCsz|r*|rzt|}Wn tyd}Ynw|rt||n |tkr*t||r9|tkr;t|dSdSdS)z) set user and group of workers processes FN)rOKeyErroros initgroupsgetgidsetgidgetuidsetuid)rNgidrRusernamerrr set_owner_processs    rYcCst|||dSr)rQchown)pathrNrWrrr rZrZwincCs|||r |}n tj|\}}|pd}d}|dkr9t|}|r&|s,dS||vr,dSt||d9}|dkstjd|tdddS)Nr#gMbP?g?z)tests may fail, delete still pending for ) stacklevel) rQr[r)listdirtimesleepwarningswarnRuntimeWarning)funcpathnamewaitalldirnamertimeoutLrrr _waitfors$    rmcCsttj|dSr)rmrQunlink)filenamerrr _unlinkrrpc CsJzt|WdSty$}z|jtjtjfvrWYd}~dSd}~wwr)rpOSErrorerrnoENOENTENOTDIR)roerrorrrr rnsrncCs<z ttj|WdStyYdStyYdSw)NFT)socket inet_ptonAF_INET6rqr+)addrrrr is_ipv6s  rz8000cCs$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:(//)?r%zfd://z"%r is not a valid file descriptor.ztcp://r![]rz]::r^z0.0.0.0z%r is not a valid port number.)rematchr)r(intr+r/lower)netloc default_portfdhostportrrr parse_addresss2            rcCs,t|tj}|tjO}t|tj|dSr)fcntlF_GETFD FD_CLOEXECF_SETFDrflagsrrr close_on_execs rcCs(t|tjtjB}t|tj|dSr)rF_GETFLrQ O_NONBLOCKF_SETFLrrrr set_non_blockingsrcCs$z|WdStyYdSwr)closerq)sockrrr rs  r) closerangec Cs4t||D]}zt|WqtyYqwdSr)rangerQrrq)fd_lowfd_highrrrr rs rcCsDt|tr |d}dt|}d|d|dg}||dS)Nzutf-8z%X s ) isinstancestrencoder0r4sendall)rdata chunk_sizechunkrrr write_chunk&s   rcCs|rt||S||dSr)rr)rrchunkedrrr write.s rc CsL|}|dkr z|dt|||W|dS|dwt|||S)Ngrr!) gettimeout setblockingr)rrrrkrrr write_nonblock4s   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)textwrapdedenthtmlescaperr0rr)r status_intrr html_errorhttprrr 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. r^NFT)sysexc_infotb_framef_code__code__tb_next)rFtbrrr _called_with_wrong_argsWs   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)Nrr! applicationrz.pyz1Failed to find application, did you mean '%s:%s'?r#eval)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)rargrrr rszimport_app..cSsi|] }|jt|jqSr)rrrvalue)rkwrrr szimport_app..z/Failed to parse arguments as literal values: %rz"Failed to find attribute %r in %r.rz%Failed to find application object: %rz$Application object must be callable.)'r)r0r2r3rendswithrQr[existsr*rparsebody SyntaxErrorrrNameidCallrgargskeywordsr+loggingrootlevelDEBUGr5AttributeErrorr-print_exceptionrr TypeErrorrr4format_exception_onlystripcallable) modulepartsobjr?r< expressionrrkwargsis_debugapperrr import_appqsz            rcCsrz*ttjd}tt}|j|jkr$|j|jkr$tjd}W|St}W|Sty8t}Y|Sw)NPWD)rQstatenvirongetcwdst_inost_devr,)abcwdrrr rs   rcCs&|durt}tjj|ddd}|S)z@Return the current date and time formatted for a message header.NFT) localtimeusegmt)rbemailutils formatdate) timestampsrrr http_datesrcCs|tvSr)rr hop_headers)headerrrr is_hoppishrrcsdtjvrvtrtdttrtdtd|sLtddtttj t ddkr>t dt dt dd Stttj dkrbt dt dfdd }|t jd|t jdd Sd S) zo Standard daemonization of a process. http://www.faqs.org/faqs/unix-faq/programmer/faq/ section 1.7 GUNICORN_FDrTr!r^csVz |}||kr|rt|t|WdSWdSWdSty*YdSwr)filenoisattyrQrdup2r)stream fd_expectrfd_nullrr redirect's  zdaemonize..redirectN)rQrfork_exitsetsidumaskropen REDIRECT_TOO_RDWRset_inheritablerrrstdoutstderr)enable_stdio_inheritancerrrr daemonizes.            r c CsFz ttdWdSty"tdttfYdSw)N@z%s.%s)randomseedrQurandomNotImplementedErrorrbgetpidrrrr r4s   rc Csfzt|d}|WdWdS1swYWdSty2}ztd||fd}~ww)NrzError: '%s' isn't writable [%r])rrrqr/)r[rFrrrr check_is_writable;s  &rutf8cCs.t|tr|St|tstd|||S)z+Converts a string argument to a byte stringz%r is not a string)rbytesrrr)rencodingrrr to_bytestringCs    rc Cs:t|dsdSz|WdStttjfyYdSw)NrFT)hasattrrrrqioUnsupportedOperation)rrrr has_filenoMs  rcCsftdtjd|}t|D]\}}|dkrd|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr  splitlines enumerateflush)r<linesilinerrr reZsrecstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error)z Content-Typez text/plainzContent-Length)rr0)rstart_responser<rr rjs zmake_fail_app..app)r)r<rrr&r make_fail_appgs r'cCs<|drtjd|}|j|jdddStj|S)Nz//r#r!)r[)r(urllibrurlsplit_replacer[)r6rrrr split_request_urits  r+cCs2z|dur|}|j|ur|||d}d}wr) __traceback__with_traceback)tprrrrr reraises  r/cCst|tr|St|dS)Nr)rr)rrrr bytes_to_strs  r0cCstj|dS)Nzlatin-1)r(runquote_to_bytesdecode)stringrrr unquote_to_wsgi_strr\r4)rr )F)r{r)r)Pr email.utilsrrrrrr2r&rrrQrKrrrvrrrbr-rdimportlib.metadatametadatarModuleNotFoundErrorrgunicorn.errorsrgunicorn.workersr urllib.parser(r5rsetr)rplatformr rrrr@ ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDrErJrOrYrZr(rmrprnrzrrrrrrrrrrrrrrr rrrrrer'r+r/r0r4rrrr s            3    !     S  V