3 Z]K@sddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZddlZee ddZedj Z!yddl"m"Z"dd Z#Wne$k rd d Z#YnXdZd dZ%e j&j'e j&j(fZ)ddZ*ddZ+d[ddZ,ddZ-ej.j/drvd\ddZ0ddZ1ne j2Z1ddZ2dd Z3d]d"d#Z4d$d%Z5d&d'Z6d(d)Z7ydd*l m8Z8Wne$k rd+d,Z8YnXd-d.Z9d^d/d0Z:d_d1d2Z;d3d4Zd9d:Z?d`d;d<Z@d=d>ZAdad?d@ZBdAdBZCdCdDZDdbdFdGZEdHdIZFdJdKZGdLdMZHdNdOZIdcdPdQZJdRdSZKdTdUZLdVdWZMdXdYZNdS)dN)AppImportError)SUPPORTED_WORKERSdevnullz /dev/nullz connection keep-alive proxy-authenticate proxy-authorization te trailers transfer-encoding upgrade server date ) setproctitlecCstd|dS)Nz gunicorn: %s)r)titler1/tmp/pip-build-w1as9q70/gunicorn/gunicorn/util.py _setproctitle3sr cCsdS)Nr)rrrrr 6s gunicorn.workers.sync.SyncWorkergunicorn.workersc Csltj|r|S|jdr|jdd}y|jdd\}}Wntk rV|}|}YnXytj|||Stj }d}t |||fYnXn|jd}t |dkrxj|jdr|dd}|t krt |jd}Pytjd||Stj }d}t |||fYqXqW|j d} ytjdj|} Wn(tj }d}t |||fYnXt| | SdS)Nzegg:#z)class uri %r invalid or not found: [%s].Zgunicorn)inspectisclass startswithsplitrsplit ValueError pkg_resourcesload_entry_point traceback format_exc RuntimeErrorlenrpop importlib import_modulejoingetattr) uridefaultsectionZ entry_strdistnameexcmsg componentsklassmodrrr load_class:sL       r+cCs8tj|}d}x$|jjD]}|jtkr|d7}qW|S)Nrr )r signature parametersvalueskind positionals)fsigarityparamrrr get_arityqs    r5cCs tj|jS)z get the username for a user id)pwdgetpwuidpw_name)uidrrr get_username|sr:Fc Cst|rb|r.y t|}Wntk r,d}YnXt|d@}|rLtj||n|tjkrbtj||rptj|dS)z) set user and group of workers processes FiN)r:KeyErrorabsos initgroupsgetgidsetgidsetuid)r9gidr>usernamerrrset_owner_processs     rDcCstj|||dS)N)r=chown)pathr9rBrrrrEsrEwincCs|||r|}ntjj|\}}|p(d}d}x>|dkrltj|}|rL| n||krXdStj||d9}q0Wtjd|tdddS)NrgMbP?g?z)tests may fail, delete still pending for ) stacklevel) r=rFrlistdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamer%timeoutLrrr_waitfors     rVcCsttj|dS)N)rVr=unlink)filenamerrr_unlinksrYcCsHy t|Wn6tk rB}z|jtjtjfkr2WYdd}~XnXdS)N)rYOSErrorerrnoENOENTENOTDIR)rXerrorrrrrWs  rWc Cs@ytjtj|Wn(tjk r(dStk r:dSXdS)NFT)socket inet_ptonAF_INET6r^r)addrrrris_ipv6src8000cCs0tjd|rtjd|dS|jdr^|dd}yt|Stk r\td|dYnX|jdrv|jdd}||}}d|krd|kr|jdd dd}|jd |gd}n8d |kr|jd |gdd \}}n|d krd|}}y t|}Wn"tk r"td|YnX|j|fS)Nz unix:(//)?r zfd://z"%r is not a valid file descriptor.ztcp://[]rz]::rHz0.0.0.0z%r is not a valid port number.r)rematchrrintrrlower)netloc default_portfdhostportrrr parse_addresss.       rscCs,tj|tj}|tjO}tj|tj|dS)N)fcntlF_GETFD FD_CLOEXECF_SETFD)rpflagsrrr close_on_execs rycCs(tj|tjtjB}tj|tj|dS)N)rtF_GETFLr= O_NONBLOCKF_SETFL)rprxrrrset_non_blockingsr}c Cs(y |jWntjk r"YnXdS)N)closer_r^)sockrrrr~s r~) closerangec Cs<x6t||D](}ytj|Wq tk r2Yq Xq WdS)N)ranger=r~rZ)Zfd_lowZfd_highrprrrr s rcCsDt|tr|jd}dt|}dj|jd|dg}|j|dS)Nzutf-8z%X s ) isinstancestrencoderrsendall)rdata chunk_sizechunkrrr write_chunks    rcCs|rt||S|j|dS)N)rr)rrchunkedrrrwrites rc CsF|j}|dkr6z|jdt|||S|jdXn t|||SdS)Ngrr ) gettimeout setblockingr)rrrrTrrrwrite_nonblock!s  rcCsLtjd|tj|d}tjdt||t||f}t||jddS)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_errorhttprrr write_error-s  rc Cs@tjd}z*x$|dk r2|jj|jkr*dS|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. rHNFT)sysexc_infotb_framef_code__code__tb_next)r1tbrrr_called_with_wrong_argsDs   rc 1CsN|jdd}t|dkrd}n|d|d}}ytj|}WnLtk r|jdrtjj|rd}t||j ddd|fYnXyt j |dd j }Wn t k rtd |YnXt|t jr|j}d}}nt|t jrZt|jt jstd ||jj}y$d d |jD}dd|jD}Wn"tk rVtd|YnXn td |tjjtjk} yt||} Wn:tk r| rtjtj td||fYnX|dk r"y| ||} WnJt!k r } z,t"| rtdj#tj$t!| j%WYdd} ~ XnX| dkr8td|t&| sJtd| S)Nrhr Z 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|]}tj|qSr)ast literal_eval).0argrrr szimport_app..cSsi|]}tj|j|jqSr)rrvaluer)rkwrrr szimport_app..z/Failed to parse arguments as literal values: %rz"Failed to find attribute %r in %r.riz%Failed to find application object: %rz$Application object must be callable.)'rrrr ImportErrorendswithr=rFexistsrrparsebody SyntaxErrorrrNameidCallrQargskeywordsrloggingrootlevelDEBUGr AttributeErrorrprint_exceptionrr TypeErrorrrformat_exception_onlystripcallable) modulepartsobjr*r'Z expressionr%rkwargsZis_debugapperrr import_app^sf           rc CshyNtjtjd}tjtj}|j|jkrD|j|jkrDtjd}ntj}Wntj}YnX|S)NZPWD)r=statenvirongetcwdst_inost_dev)abcwdrrrrs  rcCs&|dkrtj}tjj|ddd}|S)z@Return the current date and time formatted for a message header.NFT) localtimeusegmt)rLemailutils formatdate) timestampsrrr http_datesrcCs|jjtkS)N)rmr hop_headers)headerrrr is_hoppishsrcsdtjkrtjrtjdtjtjr6tjdtjd|stddtjttj dkrptj dtj dtj dnPtjttj dkrtj dtj 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_FDrr rHc sLy2|j}||kr0|jr0tj|tj|Wntk rFYnXdS)N)filenoisattyr=r~dup2r)streamZ fd_expectrp)fd_nullrrredirects zdaemonize..redirectN)r=rfork_exitsetsidumaskropen REDIRECT_TOO_RDWRrr~rstdoutstderr)Zenable_stdio_inheritancerr)rr daemonizes*          rc CsHytjtjdWn.tk rBtjdtjtjfYnXdS)N@z%s.%s)randomseedr=urandomNotImplementedErrorrLgetpidrrrrrsrcCsNyt|d}Wn2tk r@}ztd||fWYdd}~XnX|jdS)NrzError: '%s' isn't writable [%r])rIOErrorrr~)rFr1rrrrcheck_is_writeable%s "rutf8cCs.t|tr|St|ts$td||j|S)z+Converts a string argument to a byte stringz%r is not a string)rbytesrrr)rencodingrrr to_bytestring-s    rc Cs<t|dsdSy |jWntttjfk r6dSXdS)NrFT)hasattrrrrioUnsupportedOperation)rrrr has_fileno7s  rcCsjtdtjd|j}x6t|D]*\}}|dkr8d|}td|tjdq WtdtjdtjjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r'linesilinerrrrODsrOcstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error Content-Type text/plainzContent-Length)rr)rr)rZstart_response)r'rrrTszmake_fail_app..app)r)r'rr)r'r make_fail_appQs rcCs<|jdr0tjjd|}|j|jdddStjj|S)Nz//rr )rF)rurllibrurlsplit_replacerF)r!rrrrsplit_request_uri^s r c Cs:z*|dkr|}|j|k r$|j||Wdd}d}XdS)N) __traceback__with_traceback)tprrrrrreraiseks  rcCst|tr|St|dS)Nr)rr)rrrr bytes_to_strws rcCstjj|jdS)Nzlatin-1)rrunquote_to_bytesdecode)stringrrrunquote_to_wsgi_str}srcCsdd}ddlm}tjj|r$|Sdddg}dtjkrLtjdjd |}x|D]|}tjj||}||rxtjj|Stjj|d |}xBdD]:}x4|dj||D] }||s|dkrtjj|SqWqWqRWdS)NcSs4y$t|d}|jddkSQRXWn dSdS)NrbrIsELFF)rread)filepathfhrrr_is_elfs  z!_findWalk_ldpath.._is_elfr)globz/libz/usr/local/libz/usr/libLD_LIBRARY_PATHrhlibsoso.**.so.*rz{0}.{1})rrrr) rr=rFisabsrrrbasenameformat)r%rrpathsdr1prefixsuffixrrr_findWalk_ldpaths        r&cCstjj|pt|S)N)ctypesutil find_libraryr&)r%rrrr)sr))r r )F)F)rd)F)F)N)F)r)N)Or ctypes.utilr' email.utilsrr[rtrrrrrr=r6rrjr_rrrLrrNrZgunicorn.errorsrZgunicorn.workersr urllib.parserr rsetrrrr rr+ ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr0r5r:rDrEplatformrrVrYrWrcrsryr}r~rrrrrrrrrrrrrrrrOrr rrrr&r)rrrrs       1    !      S  S