Edit File: 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(
Back to File Manager