| Server IP : 192.250.235.158 / Your IP : 216.73.216.4 Web Server : LiteSpeed System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64 User : vmxfzbqj ( 1905) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/supervisor/__pycache__/ |
Upload File : |
a
0�g� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dlm
Z
d dlm Z d dl m
Z d dlmZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZmZ d dlmZ d dlm Z d dl m Z d dl m Z ej!G dd� de"��Z#G dd� de#�Z$ej!G dd� de"��Z%G dd� de%�Z&G dd� de&�Z'G d d � d e%�Z(G d d � d e"�Z)e)� Z)d d!� Z*dS )"� N)�maxint)�as_bytes)� as_string)�PY2)� asyncore_25)�
ProcessStates)�SupervisorStates)�getProcessStateDescription)�STOPPED_STATES)�decode_wait_status)�signame)�ProcessException�
BadCommand)�EventListenerStates)�events)�RestartUnconditionally)�
SocketManagerc @ sn e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZdZdZdZdZdZdd� Zdd� Zd d
� Zd d � Zd
d� Zdd� Ze j e j e j e j!e j"e j#e j$e j%e j&e j'e j(e j)e j*e j+e j,e j-iZ.d:dd�Z/dd� Z0dd� Z1dd� Z2dd� Z3d d � Z4d d � Z5d d!� Z6d"d#� Z7d$d%� Z8d&d'� Z9d(d)� Z:d*d+� Z;d,d-� Z<d.d/� Z=d0d1� Z>d2d3� Z?d4d5� Z@d6d7� ZAd8d9� ZBdS );�
Subprocessz A class to manage a subprocess.r NFc C s || _ i | _i | _tj| _dS )zDConstructor.
Argument is a ProcessConfig instance.
N)�config� dispatchers�pipesr �STOPPED�state��selfr � r �6/usr/lib/python3.9/site-packages/supervisor/process.py�__init__; s zSubprocess.__init__c C s& | j �� D ]}t|d�r
|�� q
d S )N�
removelogs)r �values�hasattrr �r �
dispatcherr r r r E s
zSubprocess.removelogsc C s& | j �� D ]}t|d�r
|�� q
d S )N�
reopenlogs)r r r r# r! r r r r# J s
zSubprocess.reopenlogsc C s4 | j �� D ]$}|�� r |�� |�� r
|�� q
d S �N)r r �readableZhandle_read_event�writableZhandle_write_eventr! r r r �drainO s
zSubprocess.drainc C sl | j r | jrttjd��| jd }|d u r6ttjd��| j| }|jrRttjd��| j|7 _|� � d S )NzProcess already closed�stdinz Process has no stdin channelz Process' stdin channel is closed)
�pid�killing�OSError�errno�EPIPEr r �closedZ input_buffer�flush)r �charsZstdin_fdr" r r r �writeZ s
zSubprocess.writec
C s zt �| jj�}W n< tyN } z$td| jjt|�f ��W Y d}~n
d}~0 0 |r^|d }ntd��d|v r�|}z| jj�|�}W n t y� d}Y n0 nh| j�
� }d}d}|D ]<}t j �
||�}z| jj�|�}W n t y� Y q�0 q�q�|du �r|}n|}| jj�|||� ||fS )z�Internal: turn a program name into a file name, using $PATH,
make sure it exists / is executable, raising a ProcessException
if not zcan't parse command %r: %sNr zcommand is empty�/)�shlex�splitr Zcommand�
ValueErrorr �str�options�statr+ Zget_path�os�path�joinZcheck_execv_args) r Z commandargs�eZprogram�filename�str: �found�dirr r r �get_execv_argsi s< �
zSubprocess.get_execv_argsTc C sr | j }||u rdS || _ |tjkrDt�� }| jd7 _|| j | _| j�|�}|d urn|| ||�}t� |� d S )NF� )
r r �BACKOFF�time�backoff�delay� event_map�getr �notify)r Z new_state�expectedZ old_state�nowZ event_class�eventr r r � change_state� s
zSubprocess.change_statec G sF | j |vrBt| j �}d�tt|��}t| jj�}td|||f ��d S )N� z%Assertion failed for %s: %s not in %s)r r r; �mapr r �name�AssertionError)r ZstatesZ
current_stateZallowable_states� processnamer r r �_assertInState� s
�zSubprocess._assertInStatec C s || _ | jjj�d| � d S )Nz spawnerr: %s)�spawnerrr r7 �logger�info�r �msgr r r �record_spawnerr� s zSubprocess.record_spawnerrc
C sF | j j}t| j j�}| jr2d| }|j�|� dS d| _d| _d| _ d| _
d| _ t � � | _
| �tjtjtjtj� | �tj� z| �� \}}W nN ty� } z6| �|jd � | �tj� | �tj� W Y d}~dS d}~0 0 z| j �| �\| _| _ W n� t t f�yz } zf|jd }|t j k�r,d| }nd|t j!�"||�f }| �|� | �tj� | �tj� W Y d}~dS d}~0 0 z |�#� } W n� t �y } z~|jd }|t j$k�r�d| }nd|t j!�"||�f }| �|� | �tj� | �tj� |�%| j � |�&| j � W Y d}~dS d}~0 0 | dk�r6| �'| �S | �(||�S dS ) z�Start the subprocess. It must not be running already.
Return the process id. If the fork() call fails, return None.
z process '%s' already runningNFr z!too many open files to spawn '%s'z-unknown error making dispatchers for '%s': %sz1Too many processes in process table to spawn '%s'z&unknown error during fork for '%s': %s))r r7 r rP r) rU �warnr* rT �
exitstatus� system_stop�administrative_stoprD � laststartrS r �EXITED�FATALrC r rM �STARTINGrA r
rY �argsZmake_dispatchersr r r+ �IOErrorr, ZEMFILE� errorcoderH �forkZEAGAIN�close_parent_pipes�close_child_pipes�_spawn_as_parent�_spawn_as_child)
r r7 rR rX r= �argvZwhat�why�coder) r r r �spawn� sp
�
�
��
zSubprocess.spawnc C s\ || _ | jj}|�| j� |j�dt| jj�|f � d | _ t
�
� | jj | _ | |j
|< |S )Nzspawned: '%s' with pid %s)r) r r7 rg r rU rV r rP rT rD � startsecsrF Z
pidhistory)r r) r7 r r r rh s
zSubprocess._spawn_as_parentc C sz | j j}|�| jd d� |�| jd d� | j jrH|�| jd d� n|�| jd d� td|j�D ]}|�|� qfd S )NZ child_stdinr � child_stdoutrB � � child_stderr� )r r7 �dup2r �redirect_stderr�range�minfds�close_fd)r r7 �ir r r �_prepare_child_fds s z Subprocess._prepare_child_fdsc
C s� | j j}�zZ|�� | �� | �� }|rh| j j}d||f }|�dd| � W |�dd� |�d� d S tj �
� }d|d< | j j }|d u r�| j jj }|r�||d< | j j |d < | j
r�| j
j j |d
< | j jd ur�|�| j j� | j j} z| d ur�|�| � W nv t�yn }
z\tj�|
jd |
jd �} d | | f }|�dd| � W Y d }
~
W |�dd� |�d� d S d }
~
0 0 z.| j jd u�r�|�| j j� |�|||� W n� t�y� }
zFtj�|
jd |
jd �} d
|d | f }|�dd| � W Y d }
~
nVd }
~
0 t�� \\} }
}}}}d||| |f }d
||f }|�dd| � Y n0 W |�dd� |�d� n|�dd� |�d� 0 d S )Nzcouldn't setuid to %s: %s
rp z supervisor: z*supervisor: child process was not spawned
� �1ZSUPERVISOR_ENABLEDZSUPERVISOR_SERVER_URLZSUPERVISOR_PROCESS_NAMEZSUPERVISOR_GROUP_NAMEr zcouldn't chdir to %s: %s
zcouldn't exec %s: %s
z%s, %s: file: %s line: %s) r r7 �setpgrpry �set_uid�uidr1 �_exitr9 �environ�copy� serverurlrP �groupZ environment�updateZ directory�chdirr+ r, rd rH rb �umaskZsetumask�execve�asyncoreZcompact_traceback)r r= rj r7 Z
setuid_msgr~ rX �envr� �cwdrk rl �fileZfun�line�t�vZtbinfo�errorr r r ri sl .
�
�$ � zSubprocess._spawn_as_childc C s� | j tjkrH|| jk r || _| jdkr�|| j| jj k r�|| jj | _n�| j tjkr�|| jkr�|| j| jj k r�|| jj | _nz| j tjkr�|| j k r�|| _ | jdkr�|| j| jj
k r�|| jj
| _n2| j tj kr�| jdkr�|| j| j k r�|| j | _dS )z�
Check if system clock has rolled backward beyond test_time. If so, set
affected timestamps to test_time.
r N)
r r ra r^ rF r rn �RUNNING�STOPPING�laststopreport� stopwaitsecsrC rE )r Z test_timer r r �+_check_and_adjust_for_system_clock_rollbacke s
z6Subprocess._check_and_adjust_for_system_clock_rollbackc C s d| _ d| _| �| jj�S )z Administrative stop Tr )r] r� �killr Z
stopsignal�r r r r �stop{ s zSubprocess.stopc C sR | j tjkrNt�� }| �|� || jd krN| jjj� dt
| jj � � || _dS )z8 Log a 'waiting for x to stop' message with throttling. rp zwaiting for %s to stopN) r r r� rD r� r� r r7 rU rV r rP )r rK r r r � stop_report� s
�zSubprocess.stop_reportc C s. d| _ d| _d| _| �tj� | �tj� d S )Nr T)rF rE r\ rS r rC rM r` r� r r r �give_up� s
zSubprocess.give_upc
C s� t � � }| jj}t| jj�}| jtjkrLd| }|j� |� | �
tj � dS | j srd|t
|�f }|j� |� |S | jtjkr�| jj}n| jj}d}|r�d}|j� d|| j |t
|�f � d| _|| jj | _| �tjtjtj� | �
tj� | j }|�r| j }z|z|�||� W nf t�yz } zL| jtjk�rdd|| j t| �f }|j� |� W Y d} ~ W dS � W Y d} ~ n
d} ~ 0 0 W nL t � � }
d || j |
f }|j� |� | �
tj � d
| _d | _| Y S 0 dS ) a Send a signal to the subprocess with the intention to kill
it (to make it exit). This may or may not actually kill it.
Return None if the signal was sent, or an error message string
if an error occurred or if the subprocess is not running.
z0Attempted to kill %s, which is in BACKOFF state.Nz6attempted to kill %s with sig %s but it wasn't running� zprocess group z$killing %s (pid %s) %swith signal %sTzDunable to signal %s (pid %s), it probably just exited on its own: %sz"unknown problem killing %s (%s):%sFr ) rD r r7 r rP r r rC rU �debugrM r r) r r� � killasgroupZ stopasgroupr* r� rF rS r� ra r� r+ r, �ESRCHr6 � traceback�
format_exc�critical�UNKNOWN) r �sigrK r7 rR rX r� Zas_groupr) �exc�tbr r r r� � sz �
�
��� � �
zSubprocess.killc
C s* | j j}t| j j�}| js:d|t|�f }|j�|� |S |j�d|| jt|�f � | �t j
t j t j � zzz|�
| j|� W nb ty� } zJ|jtjkr�d|| jt|�f }|j�|� W Y d}~W dS � W Y d}~n
d}~0 0 W n@ t�� }d|| j|f }|j�|� | �t j� | Y S 0 dS )z�Send a signal to the subprocess, without intending to kill it.
Return None if the signal was sent, or an error message string
if an error occurred or if the subprocess is not running.
z1attempted to send %s sig %s but it wasn't runningzsending %s (pid %s) sig %szHunable to signal %s (pid %s), it probably just now exited on its own: %sNz&unknown problem sending sig %s (%s):%s)r r7 r rP r) r rU r� rS r r� ra r� r� r+ r, r� r6 r� r� r� rM r� )r r� r7 rR rX r� r� r r r �signal� sP
� ��� �� �
zSubprocess.signalc C s& | � � t|�\}}t�� }| �|� || _t| jj�}|| jkrV|| j | jj k }n d}| jj
j � d|| j
f � || jjv }| jr�d| _d| _|| _d||f }| �tj� | �tj� |r�| jj
j �|� n| jj
j � |� n�|�r0d| _d| _d||d f }| �tj� | �tj� | jj
j � |� n�d| _d| _|| _| j tjk�r\| �tj � | �tj � |�r�d||d f }| jtj d
d � | jj
j �|� n:d | | _d||d f }| jtj dd � | jj
j � |� d| _
| jj
� | j � i | _ i | _!| j"du�r"t#�$t#�%| | j"�� d| _"dS )
zK The process was reaped and we need to report and manage its state
Fz�process '%s' (%s) laststart time is in the future, don't know how long process was running so assuming it did not exit too quicklyr zstopped: %s (%s)Nz1Exited too quickly (process log may have details)zexited: %s (%s)z; not expectedz
; expectedT)rJ zBad exit code %s)&r' r rD r� �laststopr r rP r^ rn r7 rU rZ r) � exitcodesr* rF r[ rS r r� rM r rV rT ra rC rE r r� r_ rf r r rL r rI �EventRejectedEvent) r r) �sts�esrX rK rR Z too_quicklyZ
exit_expectedr r r �finish sj
��
zSubprocess.finishc C s& | j jd u rd S | j j�| j j�}|S r$ )r r~ r7 Zdrop_privilegesrW r r r r} u s zSubprocess.set_uidc C s | j j|j jk S r$ �r �priority�r �otherr r r �__lt__{ s zSubprocess.__lt__c C s | j j|j jkS r$ r� r� r r r �__eq__~ s zSubprocess.__eq__c C s4 | j j}trt|��d�}dt| �|t| �� �f S )N�unicode-escapez+<Subprocess at %s with name %s in state %s>)r rP r r �encode�idr � get_state�r rP r r r �__repr__� s
�zSubprocess.__repr__c C s | j S r$ )r r� r r r r� � s zSubprocess.get_statec C s� t � � }| j}| �|� | jjj}| jjjtjkr�|t j
krr| jj r�| jj t u rZ| �
� q�| j| jjvr�| �
� nL|t jkr�| js�| jjr�| �
� n*|t jkr�| j| jjkr�|| jkr�| �
� t| jj�}|t jk�r,|| j | jjk�r,d| _d| _| �t j� | � t j � d| jj }|� d||f � |t jk�rh| j| jjk�r�| � � d}|� d||f � nF|t j k�r�| j| }|dk�r�| jjj�!d|| j"f � | �#t$j%� d S )Nr zNentered RUNNING state, process has stayed up for > than %s seconds (startsecs)zsuccess: %s %sz7entered FATAL state, too many start retries too quicklyzgave up: %s %sz killing '%s' (%s) with SIGKILL)&rD r r� r r7 rU Zmoodr Z
RESTARTINGr r_ Z autorestartr rm r[ r� r r^ Z autostartrC rE Z startretriesrF r rP ra rn rS rM r� rV r� r� rZ r) r� r� �SIGKILL)r rK r rU rR rX Z time_leftr r r �
transition� sX
��
��zSubprocess.transition)T)C�__name__�
__module__� __qualname__�__doc__r) r r �listener_staterL r^ r� r� rF r] r\ r* rE r r r[ rT r� r r r# r' r1 rA r rC r ZProcessStateBackoffEventr` ZProcessStateFatalEventr� ZProcessStateUnknownEventr ZProcessStateStoppedEventr_ ZProcessStateExitedEventr� ZProcessStateRunningEventra ZProcessStateStartingEventr� ZProcessStateStoppingEventrG rM rS rY rm rh ry ri r� r� r� r� r� r� r� r} r� r� r� r� r� r r r r r ! sl
/�
I G U/] r c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�FastCGISubprocessz7Extends Subprocess class to handle FastCGI subprocessesc C s t �| |� d | _d S r$ )r r � fcgi_sockr r r r r � s zFastCGISubprocess.__init__c C sH | j du rtd��t| j d�s6td| j t| j �f ��| j j�� | _dS )zU
The FastCGI socket needs to be created by the parent before we fork
Nz"No group set for FastCGISubprocess�socket_managerz No SocketManager set for %s:%s)r� �NotImplementedErrorr r@ r� �
get_socketr� r� r r r � before_spawn� s
�z FastCGISubprocess.before_spawnc C s$ | � � t�| �}|du r d| _|S )zR
Overrides Subprocess.spawn() so we can hook in before it happens
N)r� r rm r� )r r) r r r rm � s
zFastCGISubprocess.spawnc C s
d| _ dS )zM
Releases reference to FastCGI socket when process is reaped
N)r� r� r r r � after_finish� s z FastCGISubprocess.after_finishc C s t �| ||�}| �� |S )zR
Overrides Subprocess.finish() so we can hook in after it happens
)r r� r� )r r) r� Zretvalr r r r� � s zFastCGISubprocess.finishc C s~ | j �� }| jj}|�|d� |�| jd d� | jjrL|�| jd d� n|�| jd d� td|j�D ]}|� |� qjdS )z�
Overrides Subprocess._prepare_child_fds()
The FastCGI socket needs to be set to file descriptor 0 in the child
r ro rB rp rq rr N)
r� �filenor r7 rs r rt ru rv rw )r Zsock_fdr7 rx r r r ry � s
z$FastCGISubprocess._prepare_child_fdsN)
r� r� r� r� r r� rm r� r� ry r r r r r� � s r� c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�ProcessGroupBasec C s0 || _ i | _| j jD ]}|�| �| j|j< qd S r$ )r � processesZprocess_configsZ make_processrP )r r Zpconfigr r r r s zProcessGroupBase.__init__c C s | j j|j jk S r$ r� r� r r r r� s zProcessGroupBase.__lt__c C s | j j|j jkS r$ r� r� r r r r� s zProcessGroupBase.__eq__c C s. | j j}trt|��d�}d| jt| �|f S )Nr� z <%s instance at %s named %s>)r rP r r r� � __class__r� r� r r r r� s �zProcessGroupBase.__repr__c C s | j �� D ] }|�� q
d S r$ )r� r r �r �processr r r r % s zProcessGroupBase.removelogsc C s | j �� D ] }|�� q
d S r$ )r� r r# r� r r r r# ) s zProcessGroupBase.reopenlogsc C sn t | j�� �}|�� |�� |D ]F}|�� }|tjkrB|�� q"|tj krV|�� q"|tj
kr"|� � q"d S r$ ) �listr� r �sort�reverser� r r� r� ra rC r� )r r� �procr r r r �stop_all- s
zProcessGroupBase.stop_allc C s dd� | j �� D �S )z@ Processes which aren't in a state that is considered 'stopped' c S s g | ]}|� � tvr|�qS r )r� r
)�.0�xr r r �
<listcomp>@ s �z<ProcessGroupBase.get_unstopped_processes.<locals>.<listcomp>)r� r r� r r r �get_unstopped_processes> s z(ProcessGroupBase.get_unstopped_processesc C s$ i }| j �� D ]}|�|j� q|S r$ )r� r r� r )r r r� r r r �get_dispatchersC s z ProcessGroupBase.get_dispatchersc C s d S r$ r r� r r r �
before_removeI s z ProcessGroupBase.before_removeN)
r� r� r� r r� r� r� r r# r� r� r� r� r r r r r�
s r� c @ s e Zd Zdd� ZdS )� ProcessGroupc C s | j �� D ] }|�� q
d S r$ )r� r r� )r r� r r r r� M s zProcessGroup.transitionN)r� r� r� r� r r r r r� L s r� c @ s e Zd Zdd� ZdS )�FastCGIProcessGroupc
K sz t �| |� |�dt�}||j|jjd�| _z| j�� W n: t yt } z"t
d| j� � |f ��W Y d }~n
d }~0 0 d S )NZ
socketManager)rU z&Could not create FastCGI socket %s: %s) r� r rH r Z
socket_configr7 rU r� r� � Exceptionr5 r )r r �kwargsZsockManagerKlassr< r r r r S s �
��z FastCGIProcessGroup.__init__N�r� r� r� r r r r r r� Q s r� c @ s^ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zdd d
�Zdd� Z dd� Z
dd� Z dd� Z dS )�EventListenerPoolc C s0 t �| |� g | _d| _d| _d| _| �� d S )N���r )r� r � event_buffer�serial�
last_dispatch�dispatch_throttle�
_subscriber r r r r c s zEventListenerPool.__init__c C s, |j }| j�� }||v r(| j|jdd� d S )NT��head)r� r� r � _acceptEventrL )r rL r� Zprocsr r r �handle_rejectedk s
z!EventListenerPool.handle_rejectedc C s~ | j �� }d}|D ](}|�� |jtjkr|jtjkrd}q|rz| j rrt
�
� }|| j k r^|| _ || j | j k rrd S | � � d S )NFT)
r� r r� r r r� r� r �READYr� rD r� �dispatch)r r� Zdispatch_capabler� rK r r r r� r s
z EventListenerPool.transitionc C s | � � d S r$ )� _unsubscriber� r r r r� � s z EventListenerPool.before_removec C s@ | j r2| j �d�}| �|�}|s | j|dd� q2q t�� | _d S )Nr Tr� )r� �pop�_dispatchEventr� rD r� )r rL �okr r r r� � s
zEventListenerPool.dispatchFc C s� t | jj�}t|d�s tt�|_t|d�s0i |_| jj|jvrRt| �|j| jj< n(| jjj �
d|j|t | j �| jj
f � t | j �| jj
kr�| j r�| j �d�}| jjj �d||jf � |r�| j �d|� n | j �|� d S )Nr� � pool_serialsz6rebuffering event %s for pool %s (buf size=%d, max=%d)r z4pool %s event buffer overflowed, discarding event %s)r r rP r �
new_serial� GlobalSerialr� r� r7 rU r� �lenr� Z buffer_sizer� r� �insert�append)r rL r� rR Zdiscarded_eventr r r r� � s2
���
��z EventListenerPool._acceptEventc
C s
|j | jj }| j�� D ]�}|jtjkr*q|jt j
krt |jj�}|� � }z.|j
}|j}| �||||�}|�t|�� W n\ ty� } zD| jd tjkr�� | jjj�d|j|f � W Y d } ~ qW Y d } ~ n
d } ~ 0 0 t j|_||_| jjj�d|j|f � dS qdS )Nr zNepipe occurred while sending event %s to listener %s, listener state unchangedz event %s sent to listener %sTF)r� r rP r� r r r r� r� r r� r �payloadr� r� �_eventEnveloper1 r r+ rb r, r- r7 rU r� ZBUSYrL )
r rL � pool_serialr� rR r� �
event_typer� Zenveloperk r r r r� � sB �
���"
��z EventListenerPool._dispatchEventc C s: t �|�}t|�}d| jjj|| jj||||d�}d| S )Nz3.0)ZverZsidr� Z pool_namer� �
event_namer� r� z�ver:%(ver)s server:%(sid)s serial:%(serial)s pool:%(pool_name)s poolserial:%(pool_serial)s eventname:%(event_name)s len:%(len)s
%(payload)s)r ZgetEventNameByTyper� r r7 Z
identifierrP )r r� r� r� r� r� Z payload_len�Dr r r r� � s
�
�z EventListenerPool._eventEnvelopec C s0 | j jD ]}t�|| j� qt�tj| j� d S r$ )r � pool_eventsr Z subscriber� r� r� �r r� r r r r� � s z EventListenerPool._subscribec C s0 | j jD ]}t�|| j� qt�tj| j� d S r$ )r r� r Z unsubscriber� r� r� r� r r r r� � s z EventListenerPool._unsubscribeN)F)
r� r� r� r r� r� r� r� r� r� r� r� r� r r r r r� b s
"r� c @ s e Zd Zdd� ZdS )r� c C s
d| _ d S )Nr� )r� r� r r r r � s zGlobalSerial.__init__Nr� r r r r r� � s r� c C s$ | j tkrd| _ | j d7 _ | j S )Nr� rB )r� r )�instr r r r� � s
r� )+r, � functoolsr9 r� r3 rD r� Zsupervisor.compatr r r r Zsupervisor.medusar r� Zsupervisor.statesr r r r
Zsupervisor.optionsr r r
r Zsupervisor.dispatchersr Z
supervisorr Zsupervisor.datatypesr Zsupervisor.socket_managerr �total_ordering�objectr r� r� r� r� r� r� r� r r r r �<module> sN 3=>