File: //lib/python3.6/site-packages/supervisor/__pycache__/rpcinterface.cpython-36.pyc
3
�k�`� � @ s~ d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
m Z d dl m
Z
d dl mZ d dl mZ d d l mZ d d
l mZ d d l mZ d d l mZ d d
l mZ d dlmZ d dlmZ d dlmZ d dlmZm Z m Z d dl m Z d dl m Z d dl m!Z! d dl m"Z" d dl m#Z#m$Z$m%Z% dZ&G dd� d�Z'dd� Z(d d � Z)d d � Z*d d!� Z+d"d#� Z,d$d%� Z-dS )&� N)� as_string)�as_bytes)�unicode)� Automatic�
signal_number)�readFile)�tailFile)�
NotExecutable)�NotFound)� NoPermission)�
make_namespec)�split_namespec)�VERSION)�notify)�RemoteCommunicationEvent)� NOT_DONE_YET)�
capped_int�Faults�RPCError)�SupervisorStates)� getSupervisorStateDescription)�
ProcessStates)�getProcessStateDescription)�RUNNING_STATES�STOPPED_STATES�SIGNALLABLE_STATESz3.0c @ sn e Zd Zdd� Zdd� Zdd� ZeZdd� Zd d
� Zd d � Z d
d� Z
dd� Z e Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � ZdTd d �Zd d!� ZdUd#d$�ZdVd%d&�ZdWd'd(�ZdXd)d*�ZdYd+d,�ZdZd-d.�Zd/d0� Zd1d2� Z d3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$e$Z%dCdD� Z&dEdF� Z'dGdH� Z(e(Z)dIdJ� Z*dKdL� Z+e+Z,dMdN� Z-dOdP� Z.dQdR� Z/dSS )[� SupervisorNamespaceRPCInterfacec C s
|| _ d S )N)� supervisord)�selfr � r �"/usr/lib/python3.6/rpcinterface.py�__init__0 s z(SupervisorNamespaceRPCInterface.__init__c C s4 || _ t| jjjt�r0| jjjtjk r0tt j
��d S )N) Z update_text�
isinstancer �options�mood�intr �RUNNINGr r ZSHUTDOWN_STATE)r �textr r r �_update3 s z'SupervisorNamespaceRPCInterface._updatec C s | j d� tS )zj Return the version of the RPC API used by supervisord
@return string version version id
�
getAPIVersion)r( � API_VERSION)r r r r r) ; s
z-SupervisorNamespaceRPCInterface.getAPIVersionc C s | j d� tS )zw Return the version of the supervisor package in use by supervisord
@return string version version id
�getSupervisorVersion)r( r )r r r r r+ E s
z4SupervisorNamespaceRPCInterface.getSupervisorVersionc C s | j d� | jjjS )zh Return identifying string of supervisord
@return string identifier identifying string
�getIdentification)r( r r# Z
identifier)r r r r r, M s
z1SupervisorNamespaceRPCInterface.getIdentificationc C s* | j d� | jjj}t|�}||d�}|S )z� Return current state of supervisord as a struct
@return struct A struct with keys int statecode, string statename
�getState)Z statecode� statename)r( r r# r$ r )r �stater. �datar r r r- U s
z(SupervisorNamespaceRPCInterface.getStatec C s | j d� | jjj� S )z@ Return the PID of supervisord
@return int PID
�getPID)r( r r# Zget_pid)r r r r r1 d s
z&SupervisorNamespaceRPCInterface.getPIDc C s� | j d� | jjj}|dks*tjj|� r6ttj |��yt
t |t |�t |���S t
k
r� } z |jd }ttt|���W Y dd}~X nX dS )z� Read length bytes from the main log starting at offset
@param int offset offset to start reading from.
@param int length number of bytes to read from the log.
@return string result Bytes of log
�readLogNr )r( r r# �logfile�os�path�existsr r �NO_FILEr r r% �
ValueError�args�getattr)r �offset�lengthr3 �inst�whyr r r r2 l s
z'SupervisorNamespaceRPCInterface.readLogc C s� | j d� | jjj}|dks,| jjj|� r6ttj��y| jjj|� W n" t t
fk
rj ttj ��Y nX x6| jjj j
D ]&}t|d�rz| jjj jd� |j� qzW dS )z^ Clear the main log.
@return boolean result always returns True unless error
�clearLogN�reopenzreopening log fileT)r( r r# r3 r6 r r r7 �remove�OSError�IOError�FAILEDZloggerZhandlers�hasattr�infor@ )r r3 Zhandlerr r r r? � s
z(SupervisorNamespaceRPCInterface.clearLogc C s | j d� tj| jj_dS )zk Shut down the supervisor process
@return boolean result always returns True unless error
�shutdownT)r( r ZSHUTDOWNr r# r$ )r r r r rG � s
z(SupervisorNamespaceRPCInterface.shutdownc C s | j d� tj| jj_dS )zi Restart the supervisor process
@return boolean result always return True unless error
�restartT)r( r Z
RESTARTINGr r# r$ )r r r r rH � s
z'SupervisorNamespaceRPCInterface.restartc C s� | j d� y| jjjdd� W n. tk
rL } zttj|��W Y dd}~X nX | jj� \}}}dd� |D �}dd� |D �}dd� |D �}|||ggS ) a�
Reload the configuration.
The result contains three arrays containing names of process
groups:
* `added` gives the process groups that have been added
* `changed` gives the process groups whose contents have
changed
* `removed` gives the process groups that are no longer
in the configuration
@return array result [[added, changed, removed]]
� reloadConfigF)Zdo_usageNc S s g | ]
}|j �qS r )�name)�.0�groupr r r �
<listcomp>� s [email protected].<locals>.<listcomp>c S s g | ]
}|j �qS r )rJ )rK rL r r r rM � s c S s g | ]
}|j �qS r )rJ )rK rL r r r rM � s ) r( r r# Zprocess_configr8 r r Z CANT_REREADZdiff_to_active)r �msgZaddedZchangedZremovedr r r rI � s
z,SupervisorNamespaceRPCInterface.reloadConfigc C sX | j d� x<| jjjD ].}|j|kr| jj|�}|s@ttj|��dS qW ttj |��dS )z� Update the config for a running process from config file.
@param string name name of process group to add
@return boolean result true if successful
�addProcessGroupTN)
r( r r# �process_group_configsrJ Zadd_process_groupr r Z
ALREADY_ADDED�BAD_NAME)r rJ �config�resultr r r rO � s
z/SupervisorNamespaceRPCInterface.addProcessGroupc C sB | j d� || jjkr"ttj|��| jj|�}|s>ttj|��dS )z� Remove a stopped process from the active configuration.
@param string name name of process group to remove
@return boolean result Indicates whether the removal was successful
�removeProcessGroupT)r( r �process_groupsr r rQ Zremove_process_groupZ
STILL_RUNNING)r rJ rS r r r rT � s
z2SupervisorNamespaceRPCInterface.removeProcessGroupFc C s� g }|rxt | jjj� �}|j� x�|D ]L}| jj| }t |jj� �}|j� x$|D ] }|j| }|j||f� qRW q&W nXt | jjj� �} | j� x>| D ]6}t |jj� �}
|
j� x|
D ]}|j||f� q�W q�W |S )N)�listr rU �keys�sort� processes�append�values) r �lexical�
all_processesZ group_names�
group_namerL Z
process_names� process_name�process�groupsrY r r r �_getAllProcesses� s&
z0SupervisorNamespaceRPCInterface._getAllProcessesc C sf t |�\}}| jjj|�}|d kr.ttj|��|d kr>|d fS |jj|�}|d kr^ttj|��||fS )N)r
r rU �getr r rQ rY )r rJ r^ r_ rL r` r r r �_getGroupAndProcess s z3SupervisorNamespaceRPCInterface._getGroupAndProcessTc
sP | j d� | j� �\}��dkr8t� �\}}| j||�S y�j� \}}W nj tk
r| } zttj|j d ��W Y dd}~X n8 t
t fk
r� } zttj |j d ��W Y dd}~X nX �j
� tkr�ttj� ���j
� tjkr�ttjd� ���j� | jj� �j�rttj� ���j� |�rL�j
� tjk�rL� �fdd�} d| _| | _| S dS ) z� Start a process
@param string name Process name (or ``group:name``, or ``group:*``)
@param boolean wait Wait for process to be fully started
@return boolean result Always true unless error
� startProcessNr z!%s is in an unknown process statec sH �j rttj� ���j� } | tjtjfkr6ttj� ��| tjkrDdS t S )NT)
�spawnerrr r � SPAWN_ERROR� get_stater ZSTARTINGr& ZABNORMAL_TERMINATIONr )r/ )rJ r` r r �onwaitN s
z<SupervisorNamespaceRPCInterface.startProcess.<locals>.onwaitg�������?T) r( rd r
�startProcessGroupZget_execv_argsr
r r r7 r9 r r ZNOT_EXECUTABLErh r ZALREADY_STARTEDr ZUNKNOWNrD Zspawnr �reaprf rg Z
transitionr& �delay� rpcinterface)
r rJ �waitrL r^ r_ �filename�argvr> ri r )rJ r` r re s6
"$
z,SupervisorNamespaceRPCInterface.startProcessc sv | j d� | jjj|�� � dkr,ttj|��t� jj � �}|j
� � fdd�|D �}t |t | j
|d�}d|_| |_|S )z� Start all processes in the group named 'name'
@param string name The group name
@param boolean wait Wait for each process to be fully started
@return array result An array of process status info structs
rj Nc s g | ] }� |f�qS r r )rK r` )rL r r rM r s zESupervisorNamespaceRPCInterface.startProcessGroup.<locals>.<listcomp>)rn g�������?)r( r rU rc r r rQ rV rY r[ rX � make_allfunc� isNotRunningre rl rm )r rJ rn rY �startallr )rL r rj b s
z1SupervisorNamespaceRPCInterface.startProcessGroupc C s4 | j d� | j� }t|t| j|d�}d|_| |_|S )z� Start all processes listed in the configuration file
@param boolean wait Wait for each process to be fully started
@return array result An array of process status info structs
�startAllProcesses)rn g�������?)r( rb rq rr re rl rm )r rn rY rs r r r rt { s
z1SupervisorNamespaceRPCInterface.startAllProcessesc s� | j d� | j|�\}� � dkr8t|�\}}| j||�S � j� tkrPttj|��� j � }|dk rlttj
|��| j j � |r�� j� t
kr�� fdd�}d|_| |_|S dS )a Stop a process named by name
@param string name The name of the process to stop (or 'group:name')
@param boolean wait Wait for the process to be fully stopped
@return boolean result Always return True unless error
� stopProcessNc s � j � � j� tkrtS dS )NT)Z stop_reportrh r r r )r` r r ri � s z;SupervisorNamespaceRPCInterface.stopProcess.<locals>.onwaitr T)r( rd r
�stopProcessGrouprh r r r � NOT_RUNNING�stoprD r rk r rl rm )r rJ rn rL r^ r_ rN ri r )r` r ru � s"
z+SupervisorNamespaceRPCInterface.stopProcessc sv | j d� | jjj|�� � dkr,ttj|��t� jj � �}|j
� � fdd�|D �}t |t | j
|d�}d|_| |_|S )z� Stop all processes in the process group named 'name'
@param string name The group name
@param boolean wait Wait for each process to be fully stopped
@return array result An array of process status info structs
rv Nc s g | ] }� |f�qS r r )rK r` )rL r r rM � s zDSupervisorNamespaceRPCInterface.stopProcessGroup.<locals>.<listcomp>)rn g�������?)r( r rU rc r r rQ rV rY r[ rX rq � isRunningru rl rm )r rJ rn rY �killallr )rL r rv � s
z0SupervisorNamespaceRPCInterface.stopProcessGroupc C s4 | j d� | j� }t|t| j|d�}d|_| |_|S )z� Stop all processes in the process list
@param boolean wait Wait for each process to be fully stopped
@return array result An array of process status info structs
�stopAllProcesses)rn g�������?)r( rb rq ry ru rl rm )r rn rY rz r r r r{ � s
z0SupervisorNamespaceRPCInterface.stopAllProcessesc C s� | j d� | j|�\}}|dkr:t|�\}}| j||d�S y t|�}W n tk
rf ttj|��Y nX |j � t
kr�ttj |��|j |�}|dk r�ttj
|��dS )z� Send an arbitrary UNIX signal to the process named by name
@param string name Name of the process to signal (or 'group:name')
@param string signal Signal to send, as name ('HUP') or number ('1')
@return boolean
�
signalProcessN)�signalT)r( rd r
�signalProcessGroupr r8 r r Z
BAD_SIGNALrh r rw r} rD ) r rJ r} rL r` r^ r_ ZsigrN r r r r| � s
z-SupervisorNamespaceRPCInterface.signalProcessc sz | j jj|�� | jd� � dkr,ttj|��t� jj � �}|j
� � fdd�|D �}t |t | j
|d�}|� }| jd� |S )z� Send a signal to all processes in the group named 'name'
@param string name The group name
@param string signal Signal to send, as name ('HUP') or number ('1')
@return array
r~ Nc s g | ] }� |f�qS r r )rK r` )rL r r rM s zFSupervisorNamespaceRPCInterface.signalProcessGroup.<locals>.<listcomp>)r} )r rU rc r( r r rQ rV rY r[ rX rq �
isSignallabler| )r rJ r} rY ZsendallrS r )rL r r~ s
z2SupervisorNamespaceRPCInterface.signalProcessGroupc C s. | j � }t|t| j|d�}|� }| jd� |S )z� Send a signal to all processes in the process list
@param string signal Signal to send, as name ('HUP') or number ('1')
@return array An array of process status info structs
)r} �signalAllProcesses)rb rq r r| r( )r r} rY Z signalallrS r r r r� s
z2SupervisorNamespaceRPCInterface.signalAllProcessesc C s� | j d� g }x�| jjjD ]�}|j| jjk}x�|jD ]�}|j|j|j |j|j
||j |j|j
|j |j
|j|j|j|j|j|j|jt|j�|j|j|j|j|j|j |j d�}|j dd� |j � D �� |j dd� |j � D �� |j |� q4W qW |j!dd� d� |S ) z� Get info about all available process configurations. Each struct
represents a single process (i.e. groups get flattened).
@return array result An array of process config info structs
�getAllConfigInfo)� autostart�command� exitcodesrL Z
group_prio�inuse� killasgrouprJ Z process_prio�redirect_stderr� startretries� startsecs�stdout_capture_maxbytes�stdout_events_enabled�stdout_logfile�stdout_logfile_backups�stdout_logfile_maxbytes�
stdout_syslog�
stopsignal� stopwaitsecs�stderr_capture_maxbytes�stderr_events_enabled�stderr_logfile�stderr_logfile_backups�stderr_logfile_maxbytes�
stderr_syslogc s s" | ]\}}|t kr|d fV qdS )�autoN)r )rK �k�vr r r � <genexpr>U s zCSupervisorNamespaceRPCInterface.getAllConfigInfo.<locals>.<genexpr>c s s" | ]\}}|d kr|dfV qd S )NZnoner )rK r� r� r r r r� V s c S s | d S )NrJ r )�rr r r �<lambda>Y s zBSupervisorNamespaceRPCInterface.getAllConfigInfo.<locals>.<lambda>)�key)"r( r r# rP rJ rU Zprocess_configsr� r� r� Zpriorityr� r� r� r� r� r� r� r� r� r� r% r� r� r� r� r� r� r� r� �update�itemsrZ rX )r Z
configinfoZgconfigr� Zpconfig�dr r r r� - sH
z0SupervisorNamespaceRPCInterface.getAllConfigInfoc C s� |d }|t jkr�|d }|d }tjtj|�d d� � }tjtj|�d d� � }|| }t|�dk rptjd�}d|d |f }nx|t jt jfkr�|d }|s�d |d
}nN|t j t j
fkr�|d r�|d } tjtj | �d d � � }
|
j d
�}q�d}nd}|S )Nr/ �start�now� r zpid %s, uptime %s�pidrf z unknown error (try "tail %s")rJ rx � z%b %d %I:%M %pz Not started� )
r r& �datetime�timeZgmtime�_total_seconds� timedeltaZFATALZBACKOFFZSTOPPEDZEXITEDZ localtimeZstrftime) r rF r/ r� r� Zstart_dtZnow_dtZuptimeZdescrx Zstop_dtr r r �_interpretProcessInfo\ s,
z5SupervisorNamespaceRPCInterface._interpretProcessInfoc C s� | j d� | j|�\}}|dkr,ttj|��t|j�}t|j�}t| j� �}|j � }|j
p\d}|j pfd} |j j
prd}
|j jp~d} |j j|j j||||t|�|| |
|
| |jd�
} | j| �}
|
| d< | S )z� Get info about a process named name
@param string name The name of the process (or 'group:name')
@return struct result A structure containing data about the process
�getProcessInfoNr� r )
rJ rL r� rx r� r/ r. rf �
exitstatusr3 r� r� r� � description)r( rd r r rQ r Z laststartZlaststop�_nowrh rf r� rR r� r� rJ r r� r� )r rJ rL r` r� rx r� r/ rf r� r� r� rF r� r r r r� { s8
z.SupervisorNamespaceRPCInterface.getProcessInfoc C s t j � S )N)r� )r r r r r� � s z$SupervisorNamespaceRPCInterface._nowc C sR | j d� | jdd�}g }x2|D ]*\}}t|jj|jj�}|j| j|�� q W |S )zh Get info about all processes
@return array result An array of process status results
�getAllProcessInfoT)r\ )r( rb r rR rJ rZ r� )r r] �outputrL r` rJ r r r r� � s
z1SupervisorNamespaceRPCInterface.getAllProcessInfoc
C s� | j |�\}}|d kr"ttj|��t|jd| �}|d ksHtjj|� rTttj |��yt
t |t |�t |���S t
k
r� } z |jd } ttt| ���W Y d d }~X nX d S )Nz
%s_logfiler )rd r r rQ r: rR r4 r5 r6 r7 r r r% r8 r9 )
r rJ r; r< �channelrL r` r3 r= r> r r r �_readProcessLog� s
z/SupervisorNamespaceRPCInterface._readProcessLogc C s | j d� | j|||d�S )aI Read length bytes from name's stdout log starting at offset
@param string name the name of the process (or 'group:name')
@param int offset offset to start reading from.
@param int length number of bytes to read from the log.
@return string result Bytes of log
�readProcessStdoutLog�stdout)r( r� )r rJ r; r< r r r r� � s
z4SupervisorNamespaceRPCInterface.readProcessStdoutLogc C s | j d� | j|||d�S )aI Read length bytes from name's stderr log starting at offset
@param string name the name of the process (or 'group:name')
@param int offset offset to start reading from.
@param int length number of bytes to read from the log.
@return string result Bytes of log
�readProcessStderrLog�stderr)r( r� )r rJ r; r< r r r r� � s
z4SupervisorNamespaceRPCInterface.readProcessStderrLogc C sf | j |�\}}|d kr"ttj|��t|jd| �}|d ksHtjj|� rRdddgS t |t
|�t
|��S )Nz
%s_logfiler� r F) rd r r rQ r: rR r4 r5 r6 r r% )r rJ r; r< r� rL r` r3 r r r �_tailProcessLog� s
z/SupervisorNamespaceRPCInterface._tailProcessLogc C s | j d� | j|||d�S )a�
Provides a more efficient way to tail the (stdout) log than
readProcessStdoutLog(). Use readProcessStdoutLog() to read
chunks and tailProcessStdoutLog() to tail.
Requests (length) bytes from the (name)'s log, starting at
(offset). If the total log size is greater than (offset +
length), the overflow flag is set and the (offset) is
automatically increased to position the buffer at the end of
the log. If less than (length) bytes are available, the
maximum number of available bytes will be returned. (offset)
returned is always the last offset in the log +1.
@param string name the name of the process (or 'group:name')
@param int offset offset to start reading from
@param int length maximum number of bytes to return
@return array result [string bytes, int offset, bool overflow]
�tailProcessStdoutLogr� )r( r� )r rJ r; r< r r r r� � s
z4SupervisorNamespaceRPCInterface.tailProcessStdoutLogc C s | j d� | j|||d�S )a�
Provides a more efficient way to tail the (stderr) log than
readProcessStderrLog(). Use readProcessStderrLog() to read
chunks and tailProcessStderrLog() to tail.
Requests (length) bytes from the (name)'s log, starting at
(offset). If the total log size is greater than (offset +
length), the overflow flag is set and the (offset) is
automatically increased to position the buffer at the end of
the log. If less than (length) bytes are available, the
maximum number of available bytes will be returned. (offset)
returned is always the last offset in the log +1.
@param string name the name of the process (or 'group:name')
@param int offset offset to start reading from
@param int length maximum number of bytes to return
@return array result [string bytes, int offset, bool overflow]
�tailProcessStderrLogr� )r( r� )r rJ r; r< r r r r�
s
z4SupervisorNamespaceRPCInterface.tailProcessStderrLogc C sb | j d� | j|�\}}|dkr,ttj|��y |j� W n$ ttfk
r\ ttj|��Y nX dS )z� Clear the stdout and stderr logs for the named process and
reopen them.
@param string name The name of the process (or 'group:name')
@return boolean result Always True unless error
�clearProcessLogsNT) r( rd r r rQ Z
removelogsrC rB rD )r rJ rL r` r r r r� s
z0SupervisorNamespaceRPCInterface.clearProcessLogsc s\ | j d� g �g � | j� }x"|D ]\}}� j||| jf� q W � �fdd�}d|_| |_|S )zm Clear all process log files
@return array result An array of process status info structs
�clearAllProcessLogsc s� � s�S � j d�\} }}t| jj|jj�}y ||� W nB tk
rx } z&�j|jj| jj|j|jd�� W Y d d }~X n X �j|jj| jjtj dd�� � r�t
S �S )Nr )rJ rL �statusr� �OK) �popr rR rJ r rZ �coder' r �SUCCESSr )rL r` �callbackrJ �e)� callbacks�resultsr r �clearallF s(
zESupervisorNamespaceRPCInterface.clearAllProcessLogs.<locals>.clearallg�������?)r( rb rZ �clearProcessLogrl rm )r r] rL r` r� r )r� r� r r� 8 s
z3SupervisorNamespaceRPCInterface.clearAllProcessLogsc C s� | j d� t|tttf�s&ttj|��t|�}| j |�\}}|dkrPttj
|��|j s^|j rjttj
|��y|j|� W nB tk
r� } z&|jd tjkr�ttj|��n� W Y dd}~X nX dS )a� Send a string of chars to the stdin of the process name.
If non-7-bit data is sent (unicode), it is encoded to utf-8
before being sent to the process' stdin. If chars is not a
string or is not unicode, raise INCORRECT_PARAMETERS. If the
process is not running, raise NOT_RUNNING. If the process'
stdin cannot accept input (e.g. it was closed by the child
process), raise NO_FILE.
@param string name The process name to send to (or 'group:name')
@param string chars The character data to send to the process
@return boolean result Always return True unless error
�sendProcessStdinNr T)r( r" �str�bytesr r r ZINCORRECT_PARAMETERSr rd rQ r� Zkillingrw �writerB r9 �errnoZEPIPEr7 )r rJ �charsrL r` r> r r r r� e s
z0SupervisorNamespaceRPCInterface.sendProcessStdinc C s: t |t�r|jd�}t |t�r(|jd�}tt||�� dS )aB Send an event that will be received by event listener
subprocesses subscribing to the RemoteCommunicationEvent.
@param string type String for the "type" key in the event header
@param string data Data for the event body
@return boolean Always return True unless error
zutf-8T)r" r �encoder r )r �typer0 r r r �sendRemoteCommEvent� s
z3SupervisorNamespaceRPCInterface.sendRemoteCommEventN)F)T)T)T)T)T)T)0�__name__�
__module__� __qualname__r! r( r) Z
getVersionr+ r, r- r1 r2 Z readMainLogr? rG rH rI rO rT rb rd re rj rt ru rv r{ r| r~ r� r� r� r� r� r� r� r� ZreadProcessLogr� r� r� ZtailProcessLogr� r� r� r� r� r� r r r r r / sZ
N
3
/ .
-&r c C s | j d | j d | j d S )Ni�Q �
r� i@B i@B )ZdaysZsecondsZ microseconds)r� r r r r� � s r� c K s" g }g }| |||||fdd�}|S )zl Return a closure representing a function that calls a
function for every process, and returns a result c S s� |s�x�| D ]�\}}t |jj|jj�}||�r
y||f|�} W nD tk
r� }
z(|j|jj|jj|
j|
jd�� w
W Y d d }
~
X nX t| tj �r�|j||| f� q
|j|jj|jjt
j dd�� q
W |s�|S x�|d d � D ]�} | \}}} y
| � }
W nN tk
�r> }
z0|j|jj|jj|
j|
jd�� |j | � W Y d d }
~
X q�X |
t
k r�|j|jj|jjt
j dd�� |j | � q�W |�r~t
S |S )N)rJ rL r� r� r� )r rR rJ r rZ r� r' r" �types� FunctionTyper r� rA r )rY � predicate�func� extra_kwargsr� r� rL r` rJ r� r� �struct�cb�valuer r r �allfunc� sT
z make_allfunc.<locals>.allfuncr )rY r� r� r� r� r� r� r r r rq � s Krq c C s | j � tkS )N)rh r )r` r r r ry � s ry c C s
t | � S )N)ry )r` r r r rr � s rr c C s | j � tkrdS d S )NT)rh r )r` r r r r s r c C s t | �S )N)r )r r r r �make_main_rpcinterface s r� ).r4 r� r� r� r� Zsupervisor.compatr r r Zsupervisor.datatypesr r Zsupervisor.optionsr r r r
r r r
r Zsupervisor.eventsr r Zsupervisor.httpr Zsupervisor.xmlrpcr r r Zsupervisor.statesr r r r r r r r* r r� rq ry rr r r� r r r r �<module> sN uZ