U c^K@sddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZddlZee ddZed Z!zddl"m"Z"dd Z#Wne$k rd d Z#YnXdZd dZ%e j&j'e j&j(fZ)ddZ*ddZ+d[ddZ,ddZ-ej./drvd\ddZ0ddZ1ne j2Z1ddZ2dd Z3d]d"d#Z4d$d%Z5d&d'Z6d(d)Z7zdd*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: %srtitler 3/tmp/pip-install-u9bp_5q1/gunicorn/gunicorn/util.py _setproctitle3sr cCsdSNr rr r r r 6s gunicorn.workers.sync.SyncWorkergunicorn.workersc Csnt|r|S|dr|dd}z|dd\}}Wntk rV|}|}YnXzt|||WSt }d}t |||fYnXn|d}t |dkr|dr|dd}|t krt |d}qztd||WSt }d}t |||fYqXq| d} ztd|} Wn(t }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 componentsklassmodr r r load_class:sN       r.cCs4t|}d}|jD]}|jtkr|d7}q|S)Nrr)r signature parametersvalueskind positionals)fsigarityparamr r r get_arityqs    r8cCs t|jS)z get the username for a user id)pwdgetpwuidpw_name)uidr r r get_username|sr=FcCst|rb|r.z t|}Wntk r,d}YnXt|d@}|rLt||n|tkrbt||rpt|dS)z) set user and group of workers processes FiN)r=KeyErrorabsos initgroupsgetgidsetgidsetuid)r<gidrAusernamer r r set_owner_processs     rGcCst|||dSr )r@chown)pathr<rEr r r rHsrHwincCs|||r|}ntj|\}}|p(d}d}|dkrjt|}|rJ|sVn||krVdSt||d9}q.tjd|tdddS)NrgMbP?g?z)tests may fail, delete still pending for ) stacklevel) r@rIrlistdirtimesleepwarningswarnRuntimeWarning)funcpathnameZwaitalldirnamer(timeoutLr r r _waitfors     rYcCsttj|dSr )rYr@unlink)filenamer r r _unlinksr\c CsHz t|Wn6tk rB}z|jtjtjfkr2W5d}~XYnXdSr )r\OSErrorerrnoENOENTENOTDIR)r[errorr r r rZs  rZcCsDzttj|Wn,tjk r*YdStk r>YdSXdS)NFT)socket inet_ptonAF_INET6rar)addrr r r is_ipv6srf8000cCs2td|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]::rKz0.0.0.0z%r is not a valid port number.)rematchrrintrrlower)netloc default_portfdhostportr r r parse_addresss.        rvcCs,t|tj}|tjO}t|tj|dSr )fcntlZF_GETFDZ FD_CLOEXECZF_SETFDrsflagsr r r close_on_execs rzcCs(t|tjtjB}t|tj|dSr )rwZF_GETFLr@ O_NONBLOCKZF_SETFLrxr r r set_non_blockingsr|cCs(z |Wntjk r"YnXdSr )closerbra)sockr r r r}s r}) closerangec Cs8t||D](}zt|Wq tk r0Yq Xq dSr )ranger@r}r])Zfd_lowZfd_highrsr r r r s rcCsDt|tr|d}dt|}d|d|dg}||dS)Nzutf-8z%X s ) isinstancestrencoderr"sendall)r~data chunk_sizechunkr r r write_chunks    rcCs|rt||S||dSr )rr)r~rchunkedr r r writes rc CsJ|}|dkr:z|dt|||WS|dXn t|||SdS)Ngrr) gettimeout setblockingr)r~rrrWr 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)textwrapdedenthtmlescaperrrr)r~Z status_intrrZ html_errorhttpr r r write_error-s  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. rKNFT)sysexc_infotb_framef_code__code__tb_next)r4tbr r r _called_with_wrong_argsDs 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)NrkrZ 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.rlz%Failed to find application object: %rz$Application object must be callable.)'rrr r! ImportErrorendswithr@rIexistsrrparsebody SyntaxErrorrrNameidZCallrTargskeywordsrloggingrootlevelDEBUGr#AttributeErrorrprint_exceptionrr TypeErrorrr"format_exception_onlystripcallable) modulepartsobjr-r*Z expressionr(rkwargsZis_debugapper r r import_app^sn            rcCshzNttjd}tt}|j|jkrD|j|jkrDtjd}nt}Wnt}YnX|S)NZPWD)r@statenvirongetcwdst_inost_dev)abcwdr r r rs  rcCs&|dkrt}tjj|ddd}|S)z@Return the current date and time formatted for a message header.NFT) localtimeusegmt)rOemailutils formatdate) timestampsr r r http_datesrcCs|tkSr )rpr hop_headers)headerr r r is_hoppishsrcsdtjkrtrtdttr6tdtd|stddtttj dkrpt dt dt dnPtttj dkrt dt 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_FDrrrKcsLz2|}||kr0|r0t|t|Wntk rFYnXdSr )filenoisattyr@r}dup2r)streamZ fd_expectrsZfd_nullr r redirects zdaemonize..redirectN)r@rfork_exitsetsidumaskropen REDIRECT_TOO_RDWRrr}rstdoutstderr)Zenable_stdio_inheritancerr rr daemonizes*          rc CsHzttdWn.tk rBtdttfYnXdS)N@z%s.%s)randomseedr@urandomNotImplementedErrorrOgetpidr r r r rsrc CsNzt|d}Wn2tk r@}ztd||fW5d}~XYnX|dS)NrzError: '%s' isn't writable [%r])rIOErrorrr})rIr4rr r r check_is_writeable%s "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)hasattrrrrioUnsupportedOperation)rr r r has_fileno7s  rcCsftdtjd|}t|D]*\}}|dkr6d|}td|tjdqtdtjdtjdS)Nz!!!)filerz WARNING: %sz!!! %sz!!! )printrr splitlines enumerateflush)r*linesiliner r r rRDsrRcstfdd}|S)Ncs |dddttfggS)Nz500 Internal Server Error)z Content-Typez text/plainzContent-Length)rr)rZstart_responser*r r rTs zmake_fail_app..app)r)r*rr rr make_fail_appQs rcCs<|dr0tjd|}|j|jdddStj|S)Nz//rr)rI)rurllibrurlsplit_replacerI)r$rr r r split_request_uri^s rcCs:z*|dkr|}|j|k r$|||W5d}d}XdSr ) __traceback__with_traceback)tprrr r r reraiseks  r cCst|tr|St|dS)Nr)rr)rr r r bytes_to_strws r cCstj|dS)Nzlatin-1)rrunquote_to_bytesdecode)stringr r r unquote_to_wsgi_str}srcCsdd}ddlm}tj|r$|Sdddg}dtjkrLtjdd |}|D]}tj||}||rztj|Stj|d |}d D]B}|d ||D],}||s|d krtj|SqqqPdS)Nc SsFz2t|d}|ddkW5QRWSQRXWnYdSXdS)NrbrLsELFF)rread)filepathfhr r r _is_elfs  &z!_findWalk_ldpath.._is_elfr)globz/libz/usr/local/libz/usr/libZLD_LIBRARY_PATHrklib)sozso.*z*.so.*rz{0}.{1}r) rr@rIisabsrrr"basenameformat)r(rrpathsdr4prefixsuffixr r r _findWalk_ldpaths     r cCstj|pt|Sr )ctypesutil find_libraryr )r(r r r r#sr#)r r)F)F)rg)F)F)N)F)r)N)OrZ ctypes.utilr! email.utilsrr^rwrr rrrr@r9rrmrbrrrOrrQrZgunicorn.errorsrZgunicorn.workersr urllib.parserr#rsetrrrr rr. ParameterPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr3r8r=rGrHplatformrrYr\rZrfrvrzr|r}rrrrrrrrrrrrrrrrRrrr r rr r#r r r r s      2   !      S  S