`fbdZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl m Z ddlmZmZddlmZddlmZddlmZdd lmZmZmZdd lmZ dd lmZn #e $rdZYnwxYwed Z!ed Z"edZ#edZ$edZ%dZ&e'eddZ(dZ)e'eddZ*e'eddZ+e'eddZ,ej-Z.e.dkZ/e.dkZ0dZ1ej2ej3zej4zZ5ej6ej7zdzej6dzzej6zZ8dZ9dZ:d Z;d!Zd#e>DZ?d$Z@Gd%d&eAZBGd'd(ZCeCZDd)ZEd*ZFd+ZGGd,d-ZH dId/ZId0ZJd1ZKd2ZLd3ZMd4ZNd5ZOd6ZPdJd7ZQd8ZReSe d9rd:ZTnd;ZTGd<d=ZUeUZVeVjWZXeVjYZZeVj[Z\eVj]Z^d>Z_d?Z`d@ZdKdAZaejbcdBrdCZdndJdDZddEZee dFZfdGZgdHZhdS)LziPlatforms. Utilities dealing with platform specifics: signals, daemonization, users, groups, and so on. N)contextmanager)close_open_fds get_fdmax) set_pdeathsig) maybe_fileno)safe_str) SecurityErrorSecurityWarningreraise) try_import)current_process setproctitleresourcepwdgrpzmultiprocessing.util)EX_OK EX_FAILUREEX_UNAVAILABLEEX_USAGESYSTEMIS_macOS IS_WINDOWSSIGMAPpyimplementation LockFailedrPidfilecreate_pidlockr DaemonContextdetached parse_uid parse_gid setgroups initgroupssetgidsetuidmaybe_drop_privilegessignals signal_nameset_process_titleset_mp_process_titleget_errno_name ignore_errno fd_by_pathrrEr@ EX_CANTCREATIDarwinWindows/zLERROR: Pidfile ({0}) already exists. Seems we're already running? (pid: {1})a>Running a worker with superuser privileges when the worker accepts messages serialized with pickle is a very bad idea! If you really want to continue then you have to set the C_FORCE_ROOT environment variable (but please think about this before you do). User information: uid={uid} euid={euid} gid={gid} egid={egid} zYou're running the worker with superuser privileges: this is absolutely not recommended! Please specify a different user using the --uid option. User information: uid={uid} euid={euid} gid={gid} egid={egid} ziAn entry for the specified gid or egid was not found. We're assuming this is a potential security issue. cDh|]}|drd|v|S)SIG_) startswith).0sigs B/var/www/html/env/lib/python3.11/site-packages/celery/platforms.py r?[s=     ~~e !$C!/c:i|]}tt||S)getattr_signal)r<names r> rF_s$ < < <4''4 $ < < z#pyimplementation..is(??SVV??????r@Nr7-c34K|]}t|VdSrMrNrPs r>rRz#pyimplementation..ks(II!s1vvIIIIIIr@zPyPy CPython)hasattr _platformrHsysplatformr;joinrJ)vs r>rrbsy122 .000   ( (3<'' ) * * HH??S%:2A2%>??? ? ?   $ J rwwIIs/DQRR/HIIIIII IA{yr@ceZdZdZdS)rz'Raised if a PID lock can't be acquired.N)__name__ __module__ __qualname____doc__rBr@r>rrqs1111r@rcNeZdZdZdZdZdZeZdZdZ e Z dZ dZ d Z d ZdS) raFPidfile. This is the type returned by :func:`create_pidlock`. See Also: Best practice is to not use this directly but rather use the :func:`create_pidlock` function instead: more convenient and also removes stale pidfiles (when the process holding the lock is no longer running). NcNtj||_dSrM)ospathabspath)selfres r>__init__zPidfile.__init__sGOOD)) r@c  |n^#t$rQ}tttt |t jdYd}~nd}~wwxYw|S)z Acquire lock.N) write_pidOSErrorr rrOrYexc_info)rgexcs r>acquirezPidfile.acquires} I NN     I I I J 3s88 4 4clnnQ6G H H H H H H H H I s A2AA--A2cJtj|jS)z#Return true if the pid lock exists.)rdreexistsrgs r> is_lockedzPidfile.is_lockedsw~~di(((r@c.|dS)z Release lock.N)removergargss r>releasezPidfile.releases r@ctd5t|j5}|}||krt d|j t |cdddcdddS#t $rt d|jdwxYw#1swxYwY ddddS#1swxYwYdS)z Read and return the current pid.ENOENTzPartial or invalid pidfile Nzpidfile z contents invalid.)r-openrereadlinestrip ValueErrorint)rgfhlines r>read_pidzPidfile.read_pids ( # # B Bdi BB{{}}::<<4''$AdiAACCCBtzz||,, B B B B B B B B B B B B B B B"BBB$@49@@@BBBB B B B B B B B B B B B B B B B B B B B B B B B B B B BsGC"AC * B# C"##CC  C C"C C""C&)C&cttjtj5t j|jddddS#1swxYwYdS)zRemove the lock.N)r-errnorzEACCESrdunlinkrerrs r>ruzPidfile.removes %, 5 5 ! ! Idi  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !sA  AAcr |}n@#t$r3tdtj|YdSwxYw|s|dS t j|dn#t$ri}|j tj ks|j tj kr5tdtj|Yd}~dSYd}~nCd}~wt$r3tdtj|YdSwxYwdS)zhRemove the lock if the process isn't running. I.e. process does not respond to signal. z#Broken pidfile found - Removing it.fileTrz#Stale pidfile exists - Removing it.NF) rr~printrYstderrrurdkillrlrESRCHEPERM SystemError)rgpidrns r>remove_if_stalezPidfile.remove_if_stalesP  --//CC    7cj I I I I KKMMM44   KKMMM4  GCOOOO   yEK''39 +C+C;#*MMMM ttttt,D+C+C+C+C    7cj I I I I KKMMM44 us.9AA0B D4AC44rkzPidfile.write_pids$ikk***WTY |DD )J,,  MM' " " " MMOOO $$$$!     MMOOOOGMMOOOO49oo xxzzW$$ MOOO% IIKKKKKCIIKKKKs<)B8>BB8 B B8B  B88C&'D$$D:)r^r_r`rarerhro __enter__rsrx__exit__rrurrkrBr@r>rrus   D***I)))H B B B!!! 8r@rcVt|}tj|j|S)aCreate and verify pidfile. If the pidfile already exists the program exits with an error message, however if the process it refers to isn't running anymore, the pidfile is deleted and the program continues. This function will automatically install an :mod:`atexit` handler to release the lock at exit, you can skip this by calling :func:`_create_pidlock` instead. Returns: Pidfile: used to manage the lock. Example: >>> pidlock = create_pidlock('/var/run/app.pid') )_create_pidlockatexitregisterrxrpidlocks r>rrs("g&&G OGO$$$ Nr@cPt|}|rn|sZtt||tjtt| |S)Nr) rrsrr PIDLOCKEDformatrrYr SystemExitr1rors r>rrsgG'7#:#:#<#<' iw(8(8(:(:;;#*MMMM&&& OO Nr@ct|D]} tj|tj}n#t$rY/wxYw tj|ddtj|x#tj|wxYwfdfdttdDS)a[Return a list of file descriptors. This method returns list of file descriptors corresponding to file paths passed in paths variable. Arguments: paths: List[str]: List of file paths. Returns: List[int]: List of file descriptors. Example: >>> keep = fd_by_path(['/dev/urandom', '/my/precious/']) r r7cd tj|ddvS#t$rYdSwxYw)Nr r7F)rdfstatrl)fdstatss r> fd_in_statszfd_by_path..fd_in_stats!sF 8B<<!$- -   55 s ! //c*g|]}| |SrBrB)r<_fdrs r> zfd_by_path..'s( F F FC[[5E5E FC F F Fr@i) setrdr{O_RDONLYrladdrrranger)pathsrerrrs @@r>r.r.s EEE r{++BB    H   IIbhrll1Q3' ( ( ( HRLLLLBHRLLLL G F F F5411 F F FFs6 AA/B  B!cBeZdZdZdZ d dZdZdZeZdZ e Z d Z dS) rz(Context manager daemonizing the process.FNTc "t|tr't||drdnd}|pt|_||_||_||_||_ tj tj tj f|_dS)N0 ) isinstancerOrr;DAEMON_WORKDIRworkdirumaskfake after_chdir after_forkersrYstdinstdoutrstdfds)rgrrrrrrkwargss r>rhzDaemonContext.__init__/s eS ! ! CE$4$4S$9$9AqqrBBE0.   &*y#*cj9 r@c|@tjtjtj}tj||dSdSrM)rdr{devnullO_RDWRdup2)rgrdests r>redirect_to_nullzDaemonContext.redirect_to_null<s; >72:ry11D GD"      >r@c"|js|js|tj|j|jtj|j|jr||jst|j tdgz}t||j D]$}| t|%|jr ttd|_dSdS)Nz /dev/urandomT)_is_openr_detachrdchdirrrrlistrr.rrrrmputil_run_after_forkers)rgkeeprs r>r{zDaemonContext.openAs } !9   HT\ " " "z%$$$ #  """9 0DK((:~6F+G+GGt$$$+<rzDaemonContext.close[s! = "!DMMM " "r@ctjdkr?tjtjdkrtjdntjd|SNr)rdforksetsid_exitrrs r>rzDaemonContext._detachasK 799>> IKKKwyy1}} HQKKK r@)NNNFNT) r^r_r`rarrhrr{rrrrrBr@r>rr*s22H9==A : : : : !!!0I"""Hr@rFc tstd|tjn|}tdt ||fd}t||||S)aDetach the current process in the background (daemonize). Arguments: logfile (str): Optional log file. The ability to write to this file will be verified before the process is detached. pidfile (str): Optional pid file. The pidfile won't be created, as this is the responsibility of the child. But the process will exit if the pid lock exists and the pid written is still running. uid (int, str): Optional user id or user name to change effective privileges to. gid (int, str): Optional group id or group name to change effective privileges to. umask (str, int): Optional umask that'll be effective in the child process. workdir (str): Optional new working directory. fake (bool): Don't actually detach, intended for debugging purposes. **opts (Any): Ignored. Example: >>> from celery.platforms import detached, create_pidlock >>> with detached( ... logfile='/var/log/app.log', ... pidfile='/var/run/app.pid', ... uid='nobody'): ... # Now in detached child process with effective user set to nobody, ... # and we know that our logfile can be written to, and that ... # the pidfile isn't locked. ... pidlock = create_pidlock('/var/run/app.pid') ... ... # Run the program ... program.run(logfile='/var/log/app.log') z&This platform does not support detach.NSIGCLDuidgidco!tdr#tdSdS)Na)r{rrrx)logfilersr>after_chdir_doz detached..after_chdir_dosV .D#&&,,..  / G $ $ , , . . . . . / /r@)rrrr)r RuntimeErrorrdgetcwdr(resetr'r) rrrrrrroptsrs `` r>r r lsH ECDDD$_bikkk'G MM(cs++++////// W4^   r@c t|S#t$rJ t|jcYS#t t f$rt d|wxYwwxYw)zParse user id. Arguments: uid (str, int): Actual uid, or the username of a user. Returns: int: The actual uid. zUser does not exist: )rr~rgetpwnampw_uidrKeyErrorrs r>r!r!s:3xx ::: :<<$$+ + + +) : : :838899 9 :: A%=A%$A!!A%c t|S#t$rJ t|jcYS#t t f$rt d|wxYwwxYw)zParse group id. Arguments: gid (str, int): Actual gid, or the name of a group. Returns: int: The actual gid of the group. zGroup does not exist: )rr~rgetgrnamgr_gidrrrs r>r"r"s;3xx ;;; ;<<$$+ + + +) ; ; ;9C99:: : ;;rc>|dd} tj|S#t$r&t|dkr|dd|dd<YnNt$rB}|jt jkst|dkr|dd|dd<Yd}~nd}~wwxYw)Nr )rdr#r~lenrlrEINVAL)groupsrns r>_setgroups_hackrsAAAYF $ $<'' ' $ $ $6{{ass F111III $ $ $yEL((CKK1,<,<ss F111IIIIII $ $s!-B B8BBc:d} tjd}n#t$rYnwxYw td|S#t$rN}|jt jkrtfdtjDrYd}~dSd}~wwxYw)z+Set active groups from a list of group ids.NSC_NGROUPS_MAXc3 K|]}|vV dSrMrB)r<grouprs r>rRzsetgroups..s(??uuF"??????r@) rdsysconf Exceptionrrlrrany getgroups)r max_groupsrns` r>r#r#sJ Z 011      vkzk2333  9 # #  ???? ??? ? ?        s$ ''A B ABBctsdSt|dttdrtj|Sfdt D}t|dS)zyInit process group permissions. Compat version of :func:`os.initgroups` that was first added to Python 2.7. Nrr$c0g|]}|jv |jSrB)gr_memr)r<grusernames r>rzinitgroups..s1(((BRY&&i&&&r@)rgetpwuidrWrdr$rgetgrallr#)rrrr s @r>r$r$s ||C  #Hr<  ,}Xs+++((((#,,..(((F fr@cHtjt|dS)z4Version of :func:`os.setgid` supporting group names.N)rdr%r"rs r>r%r%Iinnr@cHtjt|dS)z2Version of :func:`os.setuid` supporting usernames.N)rdr&r!rs r>r&r&rr@ctjdkrdStjr"tjst d|ot |}|ot|}|rt||n|ot||r5tjs"tjst d|r5tj s$tj st ddSdSdS)aChange process privileges to new user/group. If UID and GID is specified, the real user/group is changed. If only UID is specified, the real user is changed, and the group is changed to the users primary group. If only GID is specified, only the group is changed. win32Nzcontact supportz%Still root uid after drop privileges!z%Still root gid after drop privileges!) rYrZrdgeteuidgetuidr r!r"_setuidr%getgidgetegidrs r>r'r's |w z||3y{{ 3 122 2 )C..C )C..C S s  E29;;Erz||ECDDD E29;;Erz||ECDDDEEEEEEr@cH|s&trt|j}t|t ||t | t dt d#t$r!}|jtj krYd}~dSd}~wwxYw)Nrz6non-root user able to restore privileges after setuid.) rr pw_gidr%r$r&r rlrr)rrrns r>rr"s '3'll3& 3KKKsC 3KKK Fq  DFF F  9 # #  $ # # # # #sA66 B!BB! setitimercDtjtj|dSrM)rDr ITIMER_REALsecondss r> _arm_alarmr?s'-w77777r@cRtjtj|dSrM)rDalarmmathceilrs r>rrBs" di(()))))r@cfeZdZdZejZejZdZ dZ dZ dZ dZ dZdZd Zd d Zd S) SignalsaEConvenience interface to :mod:`signals`. If the requested signal isn't supported on the current platform, the operation will be ignored. Example: >>> from celery.platforms import signals >>> from proj.handlers import my_handler >>> signals['INT'] = my_handler >>> signals['INT'] my_handler >>> signals.supported('INT') True >>> signals.signum('INT') 2 >>> signals.ignore('USR1') >>> signals['USR1'] == signals.ignored True >>> signals.reset('USR1') >>> signals['USR1'] == signals.default True >>> from proj.handlers import exit_handler, hup_handler >>> signals.update(INT=exit_handler, ... TERM=exit_handler, ... HUP=hup_handler) c t|SrM)r)rgrs r> arm_alarmzSignals.arm_alarmls'"""r@c*tjdSr)rDr!rrs r> reset_alarmzSignals.reset_alarmos}Qr@cT ||dS#t$rYdSwxYw)z@Return true value if signal by ``name`` exists on this platform.TF)signumrrgrEs r> supportedzSignals.supportedrsD  KK   4   55 s  ''ct|tjr|St|tr|st d|dsd|z}tt|S)zGet signal number by name.z%signal name must be uppercase string.r9) rnumbersIntegralrOisupper TypeErrorr;rCrDr,s r>r+zSignals.signum{s| dG, - - K$$$ E||~~ ECDD Du%% 4rRz Signals.reset..s*@@CS$,'@@@@@@r@Nupdate)rg signal_namess` r>rz Signals.resets2 @@@@<@@@@@@@@r@cJfd|DdS)zIgnore signal using :const:`SIG_IGN`. Does nothing if the platform has no support for signals, or the specified signal in particular. c3*K|] }|jfVdSrM)ignoredr6s r>rRz!Signals.ignore..s*99CS$,'999999r@Nr7)rgnamess` r>ignorezSignals.ignores2 9999599999999r@cPtj||SrM)rD getsignalr+r,s r> __getitem__zSignals.__getitem__s T!2!2333r@c tj|||dS#ttf$rYdSwxYw)zInstall signal handler. Does nothing if the current platform has no support for signals, or the specified signal in particular. N)rDsignalr+rr~)rgrEhandlers r> __setitem__zSignals.__setitem__sR   N4;;t,,g 6 6 6 6 6 +    DD s(,AANc ^t|pifi|D] \}}|||< dS)z#Set signal handlers from a mapping.N)dictitems)rg_d_sigmaprErDs r>r8zSignals.updatesJ!#)66v66<<>> ! !MD' DJJ ! !r@rM)r^r_r`rarDSIG_IGNr<SIG_DFLr5r'r)r-r+rr>rArEr8rBr@r>r%r%Fs  DoGoG###    & & &AAA:::444   !!!!!!r@r%c,t|ddS)z)Return name of signal from signal number.r7N)r)r+s r>r)r)s &>!"" r@cd|dvrdnd}t||krd||dSdS)Nmanagerrjr  rT)rr[)argv arg_starts r>strargvrSsJa((aI 4yy9xxYZZ())) 2r@ctdr; ttddS#t$rYdSwxYwdS)z@Sends signal ``name`` to process when parent process terminates.SIGKILLN)r(r-_set_pdeathsigr+rl)rEs r>rrsi##  7>>)44 5 5 5 5 5    DD s'A AAcd|d}|r|d|n|}tr'tt||S)zxSet the :command:`ps` name for the currently running process. Only works if :pypi:`setproctitle` is installed. []rP) _setproctitlerr)prognameinfo proctitles r>r*r*sX  HI)-<9%%t%%%9I8""8I#6#6777 r@NOSETPScdS)zDisabled feature.NrB)rks r>r+r+sr@cx|r|d|}trtjnd}t|d||S)z|Set the :command:`ps` name from the current process name. Only works if :pypi:`setproctitle` is installed. z: MainProcess:)r\)rrEr*)r[r\hostnamerEs r>r+r+sX  1"00h00H)8K  %%m H!5!5t!5!5DAAAAr@cZt|trtt|S|S)z(Get errno for string (e.g., ``ENOENT``).)rrOrCr)ns r>r,r,s)!S!ua   Hr@c/K|dptf}d|D} dVdS#|$r&}t|ds|j|vrYd}~dSd}~wwxYw)aContext manager to ignore specific POSIX error codes. Takes a list of error codes to ignore: this can be either the name of the code, or the code integer itself:: >>> with ignore_errno('ENOENT'): ... with open('foo', 'r') as fh: ... return fh.read() >>> with ignore_errno(errno.ENOENT, errno.EPERM): ... pass Arguments: types (Tuple[Exception]): A tuple of exceptions to ignore (when the errno matches). Defaults to :exc:`Exception`. typesc,g|]}t|SrB)r,)r<rs r>rz ignore_errno..s 8 8 8nU## 8 8 8r@Nr)getrrWr)errnosrrhrns r>r-r-s$ JJw   /IrRz#check_privileges..sHKK2t$$KKKKKKr@)rrrrz$suspicious platform, contact supportr)sudowheelc3 K|]}|vV dSrMrB)r<r gids_in_uses r>rRz#check_privileges../s<>>{*>>>>>>r@)rrrWrdrrrrallr getgrgidrwarningswarnr ASSUMING_ROOT_warn_or_raise_security_errorr) accept_contentpickle_or_serializerreuidegid gid_entry egid_entry gid_grp_name egid_grp_namegroups_with_security_riskis_rootrts @r>check_privilegesrs( {ck#~5UBnT!X.. 9")+++EC X.. 9")+++EC"2y11 <2:<<>>>#<>>>>>;%dD#s&9 ; ; ; ; ;;;s4D55AE<;E<c tjdd}|r-|s+tt||||t jtt||||dS)N C_FORCE_ROOTF)rr}rr~) rdenvironrjr ROOT_DISALLOWEDrrwrxr ROOT_DISCOURAGED)r~r}rrr| c_force_roots r>rzrz5s:>>.%88L < O22$Cd3      M/"2"9"9 d$#:##r@)NNNNrNF)NNrM)irarrr"r/rdrZrXrCrDrYrw contextlibrbilliard.compatrr billiard.utilrrVkombu.utils.compatrkombu.utils.encodingr exceptionsr r r localr billiard.processr ImportErrorrZrrrr__all__rCrrrrr1systemrrrrO_CREATO_EXCLO_WRONLYrR_OKW_OKrrrrrydirSIGNAMESrrrrrPIDFilerrr.rr r!r"rr#r$r%r&r'rrWrr%r(r+ get_signalrEinstall_signal_handlerr reset_signalr> ignore_signalr)rSr*rrjr+r,r-rrzrBr@r>rs    %%%%%%55555555999999++++++))))))??????????0000000OOO >** :j ! !jj * + +  GQ  -r22 72z2 & &wr>2..     X  y  RY&4 27"q(bg!^<H  +    3w<<    = <8 < < <   22222222mmmmmmmm` , G G GF????????DDE %5555p:::";;;"$$$&"      EEEE<FFF8 77K  *8888***a!a!a!a!a!a!a!a!H ')) ^  ,}       :>>)B    BBBB   8*;*;*;Z     sAA)(A)