File: //proc/self/root/lib/python3.6/site-packages/supervisor/__pycache__/supervisord.cpython-36.pyc
3
�k�`�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 )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 � 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 �!/usr/lib/python3.6/supervisord.py�__init__6 s zSupervisor.__init__c C sV | j js| j j� | j j� | j jr.| j j� | j j� | j jsJ| j j� | j� d S )N) r �firstZ cleanup_fdsZset_uid_or_exitZset_rlimits_or_exitZ make_loggerZ nocleanupZclear_autochildlogdir�run)r r r r �main; s
zSupervisor.mainc
C s� i | _ d | _tj� zdx| jjD ]}| j|� q W | jj| � | jj� | jj rd| jj
rd| jj � | jj � | j
� W d | jj� X d S )N)r � stop_groupsr �clearr �process_group_configs�add_process_groupZopenhttpserversZ
setsignalsZnodaemonr Z daemonizeZ
write_pidfile�
runforeverZcleanup)r �configr r r r P s
zSupervisor.runc s� | j j}dd� | jj� D �}ttdd� |D �|��� ttdd� |D �|���� fdd�|D �}�fdd�|D �}� fdd�|D �}|||fS )Nc S s g | ]
}|j �qS r )r )�.0�groupr r r �
<listcomp>d s z-Supervisor.diff_to_active.<locals>.<listcomp>c S s g | ]
}|j �qS r )�name)r �cfgr r r r f s c S s g | ]
}|j �qS r )r )r r r r r r g s c s g | ]}|j � kr|�qS r )r )r �cand)�curdictr r r i s c s g | ]}|j � kr|�qS r )r )r r )�newdictr r r j s c s" g | ]}|� j |j|�kr|�qS r )�getr )r r )r! r r r l s )r r r �values�dict�zip)r �newZcurZaddedZremovedZchangedr )r! r" r �diff_to_activeb s zSupervisor.diff_to_activec C s> |j }|| jkr:|j� |j� | j|< tjtj|�� dS dS )NTF)r r Z after_setuidZ
make_groupr �notifyZProcessGroupAddedEvent)r r r r r r r q s
z Supervisor.add_process_groupc C s< | j | j� rdS | j | j� | j |= tjtj|�� dS )NFT)r �get_unstopped_processesZ
before_remover r) ZProcessGroupRemovedEvent)r r r r r �remove_process_groupz s z Supervisor.remove_process_groupc C s* i }x | j j� D ]}|j|j� � qW |S )N)r r$ �updateZget_dispatchers)r Z process_mapr r r r �get_process_map� s zSupervisor.get_process_mapc C s� g }x | j j� D ]}|j|j� � qW |r�tj� }|| jd kr�dd� |D �}dj|�}| jjj d| � || _x2|D ]*}t
|j � �}| jjj d|j
j|f � qvW |S )N� c S s g | ]}t |jj��qS r )r r r )r �pr r r r � s z.Supervisor.shutdown_report.<locals>.<listcomp>z, zwaiting for %s to diez %s state: %s)r r$ �extendr* �time�lastshutdownreport�joinr �logger�infor � get_state�blatherr r )r Z unstoppedr �now�namesZnamestr�proc�stater r r �shutdown_report� s
zSupervisor.shutdown_reportc C s | j r| j d j� d S )N� ���)r Zstop_all)r r r r �ordered_stop_groups_phase_1� s z&Supervisor.ordered_stop_groups_phase_1c C s( | j r$| j j� }|j� r$| j j|� d S )N)r �popr* �append)r r r r r �ordered_stop_groups_phase_2� s
z&Supervisor.ordered_stop_groups_phase_2c
C s\ t jt j� � d}| jj� }�x8i }|j|� |j| j� � t| jj � �}|j
� | jj t j
k r�| js�d| _|d d � | _t jt j� � | j� | j� s�tj�x@|j� D ]4\}}|j� r�| jjj|� |j� r�| jjj|� q�W | jjj|�\}}x�|D ]|}||kr�y>|| }| jj j d|d� |j � |j� �s@| jjj |� W q� tjk
�r\ � Y q� || j � Y q�X q�W x�|D ]�}||k�r~y>|| }| jj j d|d� |j!� |j� �s�| jjj"|� W n0 tjk
�r� � Y n || j � Y nX �q~W x|D ]} | j#� �qW | j$� | j%� | j&� | jj t j
k �rJ| j'� | jj(r P q W d S )Nr= Tz#read event caused by %(dispatcher)r)�
dispatcherz$write event caused by %(dispatcher)r))r r) ZSupervisorRunningEventr Zget_socket_mapr, r- �listr r$ �sort�moodr ZRUNNING�stoppingr ZSupervisorStoppingEventr? r< �asyncore�ExitNow�items�readableZpollerZregister_readable�writableZregister_writableZpollr4 r7 Zhandle_read_eventZunregister_readableZ handle_errorZhandle_write_eventZunregister_writableZ
transition�reap�
handle_signal�tickrB �test)
r ZtimeoutZ
socket_mapZ combined_mapZpgroups�fdrC �r�wr r r r r � sx
zSupervisor.runforeverc C s~ |dkrt j � }xhtjD ]^}|j}| jj|�}|dkrJt||� }| j|< t||�}||kr|| j|< tj||| �� qW dS )zo Send one or more 'tick' events when the timeslice related to
the period for the event type rolls over N)r1 r Z TICK_EVENTS�periodr
r# � timeslicer) )r r8 ZeventrT Z last_tickZ this_tickr r r rO � s
zSupervisor.tickc C s� |dkr d S | j j� \}}|r�| j jj|d �}|d krZt|�\}}| j jjd||f � n|j||� | j j|= |s�| jd|d d� d S )N�d zreaped unknown pid %s (%s)Fr= )�once�recursionguard) r �waitpidZ
pidhistoryr# r r4 r5 ZfinishrM )r rW rX �pid�stsZprocess�_�msgr r r rM s
zSupervisor.reapc C s | j j� }|�r|tjtjtjfkrF| j jjdt|� � t j
| j _ n�|tj kr�| j j t j
krv| j jjdt|� � n | j jjdt|� � t j
| j _ n�|tjkr�| j jjdt|� � n`|tjk�r| j jjdt|� � | j j� x2| jj� D ] }|j� q�W n| j jjdt|� � 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 Z
get_signal�signal�SIGTERM�SIGINT�SIGQUITr4 �warnr r ZSHUTDOWNrF �SIGHUP�
RESTARTING�SIGCHLD�debug�SIGUSR2r5 Z
reopenlogsr r$ r7 )r Zsigr r r r rN s0
zSupervisor.handle_signalc C s | j jS )N)r rF )r r r r r6 < s zSupervisor.get_state)N)Fr )�__name__�
__module__� __qualname__rG r2 r r r r r r( r r+ r- r< r? rB r rO rM rN r6 r r r r r
0 s&
P
r
c C s t ||| �S )N)�int)rT Zwhenr r r rU ? s rU c C s� y dd l }W n tk
r( dd l}Y nX dd l}dd l}|j� \}} zN|j| ||| � |j| �}
|
j� |
j |ptd� |r�|
j
d� n
|
j d� W d t j
| � X d S )Nr �
cumulative�callsr1 g333333�?)rl rm r1 )ZcProfile� ImportError�profile�pstats�tempfileZmkstempZrunctxZStatsZ
strip_dirsZ
sort_statsZ
print_callersZ print_stats�os�remove) �cmd�globals�locals�
sort_order�callersro rp rq rQ �fnZstatsr r r ro C s
ro Fc C s� t jdkstd��d}xxt� }|j| td� ||_||_|jr^|j\}}t dt
� t � ||� nt |� |j
� |j� d}|s�|jtjk rP qW d S )N�posixz)This code makes Unix-specific assumptionsT)�docz go(options)F)rr r �AssertionErrorr Zrealize�__doc__r rP Zprofile_optionsro ru rv �goZclose_httpserversZ close_loggerrF r rd )�argsrP r r rw rx r r r r Z s
r c C s0 t | �}y |j� W n tjk
r* Y nX d S )N)r
r rH rI )r �dr r r r~ n s
r~ �__main__)NF)r} rr r1 r^ Zsupervisor.medusar rH Zsupervisor.compatr Zsupervisor.optionsr r r Z
supervisorr Zsupervisor.statesr r r
rU ro r r~ rh r r r r �<module> s(