File: //lib/python3/dist-packages/supervisor/__pycache__/supervisord.cpython-310.pyc
o
�X[_�8 � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddl m
Z
ddl m Z ddl m Z ddl
mZ dd lmZ dd
lmZ G d d � d �Zd
d� Zdd� Zddd�Zdd� Zedkr_e� dS dS )a� supervisord -- run a set of applications as daemons.
Usage: %s [options]
Options:
-c/--configuration FILENAME -- configuration file path (searches if not given)
-n/--nodaemon -- run in the foreground (same as 'nodaemon=true' in config file)
-s/--silent -- no logs to stdout (maps to 'silent=true' in config file)
-h/--help -- print this usage message and exit
-v/--version -- print supervisord version number and exit
-u/--user USER -- run supervisord as this user (or numeric uid)
-m/--umask UMASK -- use this umask for daemon subprocess (default is 022)
-d/--directory DIRECTORY -- directory to chdir to when daemonized
-l/--logfile FILENAME -- use FILENAME as logfile path
-y/--logfile_maxbytes BYTES -- use BYTES to limit the max size of logfile
-z/--logfile_backups NUM -- number of backups to keep when max bytes reached
-e/--loglevel LEVEL -- use LEVEL as log level (debug,info,warn,error,critical)
-j/--pidfile FILENAME -- write a pid file for the daemon process to FILENAME
-i/--identifier STR -- identifier used for this instance of supervisord
-q/--childlogdir DIRECTORY -- the log directory for child process logs
-k/--nocleanup -- prevent the process from performing cleanup (removal of
old automatic child log files) at startup.
-a/--minfds NUM -- the minimum number of file descriptors for start success
-t/--strip_ansi -- strip ansi escape codes from process output
--minprocs NUM -- the minimum number of processes available for start success
--profile_options OPTIONS -- run supervisord under profiler and output
results based on OPTIONS, which is a comma-sep'd
list of 'cumulative', 'calls', and/or 'callers',
e.g. 'cumulative,callers')
� N)� asyncore_25)� as_string)�
ServerOptions)�decode_wait_status)�signame)�events)�SupervisorStates)�getProcessStateDescriptionc @ s� e Zd ZdZdZdZdZdd� Zdd� Zdd � Z d"d
d �Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zd"dd�Zd#d d �Zd d � Zd d!� ZdS )$�
SupervisorFr Nc C s || _ i | _i | _d S �N)�options�process_groups�ticks)�selfr � r �8/usr/lib/python3/dist-packages/supervisor/supervisord.py�__init__6 s
zSupervisor.__init__c C sV | j js | j �� | j �� | j jr| j �� | j �� | j js%| j �� | �� d S r ) r �first� cleanup_fds�set_uid_or_exit�set_rlimits_or_exit� make_logger� nocleanup�clear_autochildlogdir�run�r r r r �main; s
zSupervisor.mainc C s� i | _ d | _t�� z:| jjD ]}| �|� q| j�� | j�| � | j� � | jj
s4| jj r4| j� � | j�
� | �� W | j�� d S | j�� w r )r
� stop_groupsr �clearr �process_group_configs�add_process_group�process_environment�openhttpservers�
setsignals�nodaemonr � daemonize�
write_pidfile�
runforever�cleanup)r �configr r r r P s
zSupervisor.runc s� |s| j j}dd� | j�� D �}ttdd� |D �|��� ttdd� |D �|���� fdd�|D �}�fdd�|D �}� fdd�|D �}|||fS )Nc S � g | ]}|j �qS r )r) )�.0�groupr r r �
<listcomp>f � z-Supervisor.diff_to_active.<locals>.<listcomp>c S r* r ��name�r+ �cfgr r r r- h r. c S r* r r/ r1 r r r r- i r. c � g | ] }|j � vr|�qS r r/ �r+ �cand��curdictr r r- k � c r3 r r/ r4 )�newdictr r r- l r8 c s" g | ]
}|� � |j|�kr|�qS r )�getr0 r4 r6 r r r- n s �)r r r
�values�dict�zip)r �new�cur�added�removed�changedr )r7 r9 r �diff_to_activec s
zSupervisor.diff_to_activec C s> |j }|| jvr |�� |�� | j|< t�t�|�� dS dS )NTF)r0 r
� after_setuid�
make_groupr �notify�ProcessGroupAddedEvent)r r) r0 r r r r s s
z Supervisor.add_process_groupc C s< | j | �� r dS | j | �� | j |= t�t�|�� dS )NFT)r
�get_unstopped_processes�
before_remover rF �ProcessGroupRemovedEvent)r r0 r r r �remove_process_group| s z Supervisor.remove_process_groupc C s& i }| j �� D ] }|�|�� � q|S r )r
r; �update�get_dispatchers)r � process_mapr, r r r �get_process_map� s zSupervisor.get_process_mapc C s� g }| j �� D ] }|�|�� � q|rNt�� }|| jd krNdd� |D �}d�|�}| jj� d| � || _|D ]}t
|� � �}| jj� d|j
j|f � q8|S )N� c S s g | ]}t |jj��qS r )r r) r0 )r+ �pr r r r- � s z.Supervisor.shutdown_report.<locals>.<listcomp>z, zwaiting for %s to diez %s state: %s)r
r; �extendrH �time�lastshutdownreport�joinr �logger�infor � get_state�blatherr) r0 )r � unstoppedr, �now�names�namestr�proc�stater r r �shutdown_report� s
�zSupervisor.shutdown_reportc C s | j r | j d �� d S d S )N���)r �stop_allr r r r �ordered_stop_groups_phase_1� s �z&Supervisor.ordered_stop_groups_phase_1c C s0 | j r| j �� }|�� r| j �|� d S d S d S r )r �poprH �append)r r, r r r �ordered_stop_groups_phase_2� s
�z&Supervisor.ordered_stop_groups_phase_2c
C s* t �t �� � d}| j�� } i }|�|� |�| �� � t| j� � �}|�
� | jj t j
k rN| jsCd| _|d d � | _t �t �� � | �� | �� sNtj�|�� D ]\}}|�� ra| jj�|� |�� rl| jj�|� qR| jj�|�\}}|D ]8}||v r�z || }| jj j d|d� |� � |�� s�| jj� |� W qx tjy� � || � � Y qxqx|D ]8}||v r�z || }| jj j d|d� |�!� |�� s�| jj�"|� W q� tjy� � || � � Y q�q�|D ]} | �#� q�| �$� | �%� | �&� | jj t j
k �r
| �'� | jj(�rd S q)N� Tz#read event caused by %(dispatcher)r)�
dispatcherz$write event caused by %(dispatcher)r))r rF �SupervisorRunningEventr �get_socket_maprL rO �listr
r; �sort�moodr �RUNNING�stoppingr �SupervisorStoppingEventrc r` �asyncore�ExitNow�items�readable�poller�register_readable�writable�register_writable�pollrV rY �handle_read_event�unregister_readable� handle_error�handle_write_event�unregister_writable�
transition�reap�
handle_signal�tickrf �test)
r �timeout�
socket_map� combined_map�pgroups�fdrh �r�wr, r r r r' � s�
�������
�zSupervisor.runforeverc C sz |du rt � � }tjD ]/}|j}| j�|�}|du r$t||� }| j|< t||�}||kr:|| j|< t�||| �� q dS )zo Send one or more 'tick' events when the timeslice related to
the period for the event type rolls over N)rS r � TICK_EVENTS�periodr r: � timeslicerF )r r[ �eventr� � last_tick� this_tickr r r r� s
��zSupervisor.tickc C s� |dkrd S | j �� \}}|rE| j j�|d �}|d u r-t|�\}}| j j�d||f � n |�||� | j j|= |sG| jd|d d� d S d S d S )N�d zreaped unknown pid %s (%s)Frg )�once�recursionguard) r �waitpid�
pidhistoryr: r rV rW �finishr� )r r� r� �pid�sts�process�_�msgr r r r� s
�zSupervisor.reapc C s$ | j �� }|r�|tjtjtjfv r#| j j�dt|� � t j
| j _ d S |tj krN| j j t j
kr<| j j�dt|� � d S | j j�dt|� � t j
| j _ d S |tjkr`| j j�dt|� � d S |tjkr�| j j�dt|� � | j �� | j�� D ]}|�� qzd S | j j�dt|� � d S d S )Nz#received %s indicating exit requestz<ignored %s indicating restart request (shutdown in progress)z&received %s indicating restart requestz#received %s indicating a child quitz)received %s indicating log reopen requestz received %s indicating nothing)r �
get_signal�signal�SIGTERM�SIGINT�SIGQUITrV �warnr r �SHUTDOWNrm �SIGHUP�
RESTARTING�SIGCHLD�debug�SIGUSR2rW �
reopenlogsr
r; rY )r �sigr, r r r r� " s@
�
�
�
�
�
�
��zSupervisor.handle_signalc C s | j jS r )r rm r r r r rX > s zSupervisor.get_stater )Fr )�__name__�
__module__� __qualname__ro rT r
r r r r rC r rK rO r` rc rf r' r� r� r� rX r r r r r
0 s(
P
r
c C s t ||| �S r )�int)r� �whenr r r r� A s r� c C s� zdd l }W n
ty dd l}Y nw dd l}dd l}|�� \}} z5|�| ||| � |�| �}
|
�� |
j |p9d� |rC|
�
d� n
|
� d� W t �
| � d S W t �
| � d S t �
| � w )Nr )�
cumulative�callsrS g333333�?)�cProfile� ImportError�profile�pstats�tempfile�mkstemp�runctx�Stats�
strip_dirs�
sort_stats�
print_callers� print_stats�os�remove) �cmd�globals�locals�
sort_order�callersr� r� r� r� �fn�statsr r r r� E s& �
�r� Fc C s� t jdks J d��d} t� }|j| td� ||_||_|jr/|j\}}tdt � t
� ||� nt |� |� � |�
� d}|sE|jtjk rGd S q )N�posixz)This code makes Unix-specific assumptionsTrg )�docz go(options)F)r� r0 r �realize�__doc__r r� �profile_optionsr� r� r� �go�close_httpservers� close_loggerrm r r� )�argsr� r r r� r� r r r r \ s"
�r c C s. t | �}z|�� W d S tjy Y d S w r )r
r rq rr )r �dr r r r� p s �r� �__main__)NF)r� r� rS r� �supervisor.medusar rq �supervisor.compatr �supervisor.optionsr r r �
supervisorr �supervisor.statesr r r
r� r� r r� r� r r r r �<module> s,
�