o [hJ @sddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZzddlmZWneefycddlZYnwddlmZddlmZddlZee ddZ e!d"Z#z ddl$m$Z$dd Z%Wn eyd d Z%Ynwd d Z& dXddZ'ej(j)ej(j*fZ+ddZ,ddZ-dYddZ.ddZ/ej01drdYddZ2ddZ3ne j4Z3dd Z4d!d"Z5dZd$d%Z6d&d'Z7d(d)Z8d*d+Z9zdd,l m:Z:Wn eyd-d.Z:Ynwd/d0Z;dYd1d2Zd7d8Z?d9d:Z@d;d<ZAd[d=d>ZBd?d@ZCdYdAdBZDdCdDZEdEdFZFd\dHdIZGdJdKZHdLdMZIdNdOZJdPdQZKd[dRdSZLdTdUZMdVdWZNdS)]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 t/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/gunicorn/util.py _setproctitle4r cCsdSNr rr r r r 7scsBt|}fdd|jD}|stdff|dS)Ncs$g|]}|jkr|jkr|qSr groupname).0eprr r =sz$load_entry_point..zEntry point %r not foundr)importlib_metadata distribution entry_points ImportErrorload)rrrZdist_objepsr rr load_entry_point;s  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].TZgunicorn)inspectisclass startswithsplitrsplit ValueErrorr Exception traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsectionZ entry_strdistrexcmsg componentsklassmodr r r load_classDsV            r:cCs4t|}d}|jD] }|jtvr|d7}q |S)Nrr)r! signature parametersvalueskind positionals)fsigZarityparamr r r get_arity|s  rCcCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidr r r get_usernames rHFcCs|r0|rzt|}Wn tyd}Ynwt|d@}|r%t||n |tkr0t||r?|tkrAt|dSdSdS)z) set user and group of workers processes FiN) rHKeyErrorabsos initgroupsgetgidsetgidgetuidsetuid)rGgidrLusernamer r r set_owner_processs     rScCst|||dSr )rKchown)pathrGrQr r r rTrTwincCs|||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) rKrUr$listdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamertimeoutLr r r _waitfors$    rfcCsttj|dSr )rfrKunlink)filenamer r r _unlinkr ric CsJzt|WdSty$}z|jtjtjfvrWYd}~dSd}~wwr )riOSErrorerrnoENOENTENOTDIR)rherrorr r r rgsrgcCs<z ttj|WdStyYdStyYdSw)NFT)socket inet_ptonAF_INET6rjr&)addrr r r is_ipv6s  rs8000cCs$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]::rXz0.0.0.0z%r is not a valid port number.)rematchr$r#intr&r*lower)netloc default_portfdhostportr r r parse_addresss2            rcCs,t|tj}|tjO}t|tj|dSr )fcntlF_GETFD FD_CLOEXECF_SETFDrflagsr r r close_on_execs rcCs(t|tjtjB}t|tj|dSr )rF_GETFLrK O_NONBLOCKF_SETFLrr r r set_non_blockingsrcCs$z|WdStyYdSwr )closerj)sockr r r r s  r) closerangec Cs4t||D]}zt|WqtyYqwdSr )rangerKrrj)Zfd_lowZfd_highrr 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 CsL|}|dkr z|dt|||W|dS|dwt|||S)Ngrr) gettimeout setblockingr)rrrrdr 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  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. rXNFT)sysexc_infotb_framef_code__code__tb_next)r@tbr r r _called_with_wrong_argsPs   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)NrxrZ 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.ryz%Failed to find application object: %rz$Application object must be callable.)'r$r+r-r.rendswithrKrUexistsr%rparsebody SyntaxErrorrrNameidCallraargskeywordsr&loggingrootlevelDEBUGr0AttributeErrorr(print_exceptionrr TypeErrorrr/format_exception_onlystripcallable) modulepartsobjr9r6 expressionrrkwargsZis_debugapper r r import_appjsz            rcCsrz*ttjd}tt}|j|jkr$|j|jkr$tjd}W|St}W|Sty8t}Y|Sw)NZPWD)rKstatenvirongetcwdst_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)r\emailutils formatdate) timestampsr r r http_datesrcCs|tvSr )r}r hop_headers)headerr r r is_hoppishr rcsdtjvrvtrtdttrtdtd|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 Z GUNICORN_FDrTrrXcsVz |}||kr|rt|t|WdSWdSWdSty*YdSwr )filenoisattyrKrdup2r)streamZ fd_expectrZfd_nullr r redirect s  zdaemonize..redirectN)rKrfork_exitsetsidumaskropen REDIRECT_TOO_RDWRset_inheritablerrrstdoutstderr)Zenable_stdio_inheritancerr rr daemonizes.            rc CsFz ttdWdSty"tdttfYdSw)N@z%s.%s)randomseedrKurandomNotImplementedErrorr\getpidr r r r r-s   rc Csfzt|d}|WdWdS1swYWdSty2}ztd||fd}~ww)NrzError: '%s' isn't writable [%r])rrrjr*)rUr@rr r r check_is_writable4s  &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)hasattrrrrjioUnsupportedOperation)rr r r has_filenoFs  r cCsftdtjd|}t|D]\}}|dkrd|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r6linesiliner r r r_Ssr_cstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error)z Content-Typez text/plainzContent-Length)rr+)rZstart_responser6r r rcs zmake_fail_app..app)r)r6rr rr make_fail_app`s rcCs<|drtjd|}|j|jdddStj|S)Nz//rr)rU)r#urllibrurlsplit_replacerU)r1rr r r split_request_urims  rcCs2z|dur|}|j|ur|||d}d}wr ) __traceback__with_traceback)tprrr r r reraisezs  rcCst|tr|St|dS)Nr)rr)rr r r bytes_to_strs  rcCstj|dS)Nzlatin-1)rrunquote_to_bytesdecode)stringr r r unquote_to_wsgi_strrVr!)rr)F)rtr )r)Or email.utilsrrkrrr-r!rrrKrDrrzrorrr\r(r^importlib.metadatametadatarModuleNotFoundErrorrZgunicorn.errorsrZgunicorn.workersr urllib.parserr0rsetr$rrr rr: ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr?rCrHrSrTplatformr#rfrirgrsrrrrrrrrrrrrrrrrrrr r_rrrrr!r r r r s           3    !      S  V