Edit File: supervisorctl.cpython-36.pyc
3 �k�`�� � @ sn d Z ddlZddlZddlZddlZddlZddlZddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddl mZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ G dd� d�ZG dd� d�Zejjejj ejj fZ G dd� dej �Z G dd� dej!�Z"dd� Z#G dd� d�Z$dd � Z%d d � Z&G d d � d e$�Z'd$d!d"�Z(e)d#k�rje(� dS )%a� supervisorctl -- control applications run by supervisord from the cmd line. Usage: %s [options] [action [arguments]] Options: -c/--configuration FILENAME -- configuration file path (searches if not given) -h/--help -- print usage message and exit -i/--interactive -- start an interactive shell after executing commands -s/--serverurl URL -- URL on which supervisord server is listening (default "http://localhost:9001"). -u/--username USERNAME -- username to use for authentication with server -p/--password PASSWORD -- password to use for authentication with server -r/--history-file -- keep a readline history (if readline is available) action [arguments] -- see below Actions are commands like "tail" or "stop". If -i is specified or no action is specified on the command line, a "shell" interpreting actions typed interactively is started. Use the action "help" to find out about available actions. � N)� xmlrpclib)�urlparse)�unicode)� raw_input)� as_string)� asyncore_25)� ClientOptions)� make_namespec)�split_namespec)�xmlrpc)�states)� http_clientc @ s( e Zd ZdZdZdZdZdZdZdZ dS ) �LSBInitExitStatusesr � � � � � � N) �__name__� __module__� __qualname__�SUCCESS�GENERIC� INVALID_ARGS�UNIMPLEMENTED_FEATURE�INSUFFICIENT_PRIVILEGES� NOT_INSTALLED� NOT_RUNNING� r r �#/usr/lib/python3.6/supervisorctl.pyr / s r c @ s e Zd ZdZdZdS )�LSBStatusExitStatusesr r N)r r r r �UNKNOWNr r r r r! 8 s r! c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�fgthreadz� A subclass of threading.Thread, with a kill() method. To be used for foreground output/error streaming. http://mail.python.org/pipermail/python-list/2004-May/260937.html c C sh t jj| � d| _|| _|| _tj� | _tj | j| jj j | jj j �| _ tj | j| jj j | jj j �| _d S )NF)� threading�Thread�__init__�killed�program�ctlr �Listener�listener� HTTPHandler�options�username�password�output_handler� error_handler)�selfr( r) r r r r& F s zfgthread.__init__c C s | j | _| j| _ tjj| � d S )N)�run�_fgthread__run_backup�_fgthread__runr$ r% �start)r2 r r r r6 S s zfgthread.startc C s@ | j j| jjjd| j � | jj| jjjd| j � tj� d S )Nz/logtail/%s/stdoutz/logtail/%s/stderr) r0 �getr) r- � serverurlr( r1 �asyncore�loop)r2 r r r r3 Y s z fgthread.runc C s t j| j� | j� | j| _d S )N)�sys�settrace� globaltracer4 r3 )r2 r r r Z__run` s zfgthread.__runc C s |dkr| j S d S d S )NZcall)� localtrace)r2 �frame�why�argr r r r= f s zfgthread.globaltracec C s | j r|dkrt� �| jS )N�line)r' � SystemExitr> )r2 r? r@ rA r r r r> l s zfgthread.localtracec C s | j j� | jj� d| _d S )NT)r0 �closer1 r' )r2 r r r �killr s z fgthread.killN) r r r �__doc__r& r6 r3 r5 r= r> rE r r r r r# @ s r# c @ s� e Zd Zd+dd�Zdd� Zdd� Zd d � Zd,d d �Zd d� Zdd� Z dd� Z dd� Z d-dd�Z dd� Z d.dd�Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� ZdS )/� Controller�tabNc C s� || _ | j jd | _g | j _dg| _d | _tj| _tj j | |||� xt| j j D ]h\}}}|| f|�}x<t |�D ]0} | j d�rntt|| ��rn| jj| dd � � qnW | j jj|� ||_qNW d S )Nz> �help�do_r )r- �prompt�plugins�vocab�_complete_infor r � exitstatus�cmd�Cmdr& Zplugin_factories�dir� startswith�callable�getattr�append�name) r2 r- Z completekey�stdin�stdoutrW �factory�kwargs�plugin�ar r r r& y s zController.__init__c C s d S )Nr )r2 r r r � emptyline� s zController.emptylinec C s | j d| � tj| _d S )Nz*** Unknown syntax: %s)�outputr r rO )r2 rB r r r �default� s zController.defaultc s� y�dd l ��j� }|jdd�}|jdd�}|jdd�}�j|� � jr�y�j� j� W n tk rj Y nX � �fdd�}dd l}|j|� W n t k r� Y nX y| j j d� | j � W n t k r� | jd� Y nX d S ) Nr �:� �*�-c s* y�j � j� W n tk r$ Y nX d S )N)�write_history_file� history_file�IOErrorr )r- �readliner r �save� s z%Controller.exec_cmdloop.<locals>.save�status)rh Zget_completer_delims�replaceZset_completer_delimsrf �read_history_filerg �atexit�register� ImportErrorZcmdqueuerV Zcmdloop�KeyboardInterruptr_ )r2 �argsr- Zdelimsri rm r )r- rh r � exec_cmdloop� s. zController.exec_cmdloopc C s0 ||t jjfkrn|tkr$tj| _ntj| _d S )N)r �Faultsr �DEAD_PROGRAM_FAULTSr r rO r )r2 Z faultcodeZignored_faultcoder r r � set_exitstatus_from_xmlrpc_fault� s z+Controller.set_exitstatus_from_xmlrpc_faultc C sj | j |�\}}}|s | j� S |dkr.| j|�S d| _|| _|dkrL| j|�S | j|�}|dkrh| j|�S y�y||�S tjk �r } zx|jdkr�| j j r�| j d� t d�}t j dd�}| j d� || j _|| j _| j|�S | j d� tj| _n tj| _� W Y dd}~X nX ||� W nN tk �rd tj� \\}} }} } } d| | ||f } | j | � tj| _Y nX dS ) z� Override the onecmd method to: - catch and print all exceptions - call 'do_foo' on plugins rather than ourself Nrb i� z Server requires authenticationz Username:z Password:)rK z error: %s, %s: file: %s line: %s)Z parseliner^ r` rN Zlastcmd� _get_do_funcr Z ProtocolErrorZerrcoder- � interactiver_ r �getpassr. r/ �onecmdr r rO � Exceptionr9 Zcompact_traceback)r2 rB rP rA Zdo_func�er. r/ �fileZfun�t�vZtbinfo�errorr r r ry � sF zController.onecmdc C sD d| }t | |d �}|s@x&| jjD ]}t ||d �}|d k r"P q"W |S )NrJ )rU r- rL )r2 rP Z func_name�funcr\ r r r rv � s zController._get_do_funcc C s( t |t�r|jd�}| jj|d � d S )Nzutf-8� )� isinstancer �encoderY �write)r2 �messager r r r_ � s zController.outputc C s | j d�S )N� supervisor)�get_server_proxy)r2 r r r �get_supervisor� s zController.get_supervisorc C s$ | j j� }|d kr|S t||�S d S )N)r- ZgetServerProxyrU )r2 � namespace�proxyr r r r� � s zController.get_server_proxyc C s. yJ| j � }|j� }ddlm} ||jkrH| jd|j|f � tj| _dS W n� t j k r� } z4|j t j jkr�| jd� tj| _dS tj| _� W Y d d }~X n� tjk �r( } zn|jd tjkr�| jd| jj � tj| _dS |jd tjk�r| jd| jj � tj| _dS tj| _� W Y d d }~X nX dS ) Nr )� rpcinterfacezsSorry, this version of supervisorctl expects to talk to a server with API version %s, but the remote version is %s.Fz�Sorry, supervisord responded but did not recognize the supervisor namespace commands that supervisorctl uses to control it. Please check that the [rpcinterface:supervisor] section is enabled in the configuration file (see sample.conf).z%s refused connectionz%s no such fileT)r� Z getVersionr� r� Z API_VERSIONr_ r r rO r �Fault� faultCoder rs ZUNKNOWN_METHODr r �socketr rq �errno� ECONNREFUSEDr- r8 r �ENOENTr )r2 r� Zapir� r{ r r r �upcheck s< zController.upcheckc C s� |dkrddl }|j� }g }|j� s0| j|�}nn|j� }|d }t|�dkrd|jd� rd| j|�}n:|dkrx| j|�}n&|dkr�| j|�}n|dkr�| j|�}t|�|kr�|| S dS )aa Completer function that Cmd will register with readline using readline.set_completer(). This function will be called by readline as complete(text, state) where text is a fragment to complete and state is an integer (0..n). Each call returns a string with a new completion. When no more are available, None is returned.Nr r � rI �add�remove�update�clear�fg�pid�restart�signalr6 rj �stop�tail)r� r� r� ) r� r� r� r� r� r6 rj r� r� ) rh Zget_line_buffer�strip�_complete_actions�split�len�endswith�_complete_groups�_complete_processes)r2 �text�staterB rh ZmatchesZwords�actionr r r �complete% s& zController.completec s � fdd�| j D �S )z5Build a completion list of action names matching textc s g | ]}|j � �r|d �qS )r� )rS )�.0r] )r� r r � <listcomp>H s z0Controller._complete_actions.<locals>.<listcomp>)rM )r2 r� r )r� r r� F s z Controller._complete_actionsc sB g }x*| j � D ] }|d |kr|j|d � qW � fdd�|D �S )z4Build a completion list of group names matching text�groupc s g | ]}|j � �r|d �qS )r� )rS )r� �g)r� r r r� P s z/Controller._complete_groups.<locals>.<listcomp>)�_get_complete_inforV )r2 r� �groups�infor )r� r r� J s zController._complete_groupsc s� g }xt| j � D ]h}d� ks*|d |d krh|jd|d |d f � d|d |krv|jd|d � q|j|d � qW � fdd�|D �S )z6Build a completion list of process names matching textra rW r� z%s:%sz%s:*c s g | ]}|j � �r|d �qS )r� )rS )r� �p)r� r r r� \ s z2Controller._complete_processes.<locals>.<listcomp>)r� rV )r2 r� Z processesr� r )r� r r� R s z Controller._complete_processesc C s | j dkr| j� j� | _ | j S )z�Get all process info used for completion. We cache this between commands to reduce XML-RPC calls because readline may call complete() many times if the user hits tab only once.N)rN r� �getAllProcessInfo)r2 r r r r� ^ s z Controller._get_complete_infoc C s6 |j � dkr| j� n x| jjD ]}|j|� q W d S )NrI )r� � help_helpr- rL �do_help)r2 rA r\ r r r r� f s zController.do_helpc C s | j d� | j d� d S )Nz'help Print a list of available actionsz%help <action> Print help for <action>)r_ )r2 r r r r� m s zController.help_helpc C s | j d� dS )Nrb r )r_ )r2 rA r r r �do_EOFq s zController.do_EOFc C s | j d� d S )Nz(To quit, type ^D or use the quit command)r_ )r2 r r r �help_EOFu s zController.help_EOF)rH NN)N)N)N)r r r r& r^ r` rr ru ry rv r_ r� r� r� r� r� r� r� r� r� r� r� r� r r r r rG w s* - % ! rG c C sD g }| j g}x2|r>|jd�}|jr0|t|j� }|t|� }qW |S )Nr )� __class__�pop� __bases__�listrR )Zinst�names�classesZaclassr r r � get_namesx s r� c @ s0 e Zd ZdZdd� Zdd� Zee�Zdd� ZdS ) �ControllerPluginBaseZunnamedc C s || _ d S )N)r) )r2 Z controllerr r r r& � s z ControllerPluginBase.__init__c C s d| j S )Nz %s commands (type help <topic>):)rW )r2 r r r � _doc_header� s z ControllerPluginBase._doc_headerc C st |r�yt | d| �}W nh tk r~ y(t | d| �j}|rL| jj|� d S W n tk rb Y nX | jj| jj|f � d S X |� n�t| �}g }g }i }x,|D ]$}|d d� dkr�d||dd � < q�W |j� d} xx|D ]p}|d d� dkr�|| k� r�q�|} |dd � } | |k�r(|j| � || = q�t | |�j�rB|j| � q�|j| � q�W | jjd� | jj | j |dd� d S ) NZhelp_rJ r r rb r � �P ) rU �AttributeErrorrF r) r_ Znohelpr� �sortrV Z print_topics� doc_header) r2 rA r� �docr� Zcmds_docZ cmds_undocrI rW ZprevnamerP r r r r� � sJ z ControllerPluginBase.do_helpN) r r r rW r& r� �propertyr� r� r r r r r� � s r� c C s, t tjdd �pd} | j� jd�r$d S tjjS )N�encodingrb �utf)rU r; rY �lowerrS r� )�encr r r � not_all_langs� s r� c C s t � }|r| jd| � d S )Nz�Warning: sys.stdout.encoding is set to %s, so Unicode output may fail. Check your LANG and PYTHONIOENCODING environment settings.)r� r_ )r) Zproblematic_encr r r �check_encoding� s r� c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z e Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zdfd$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"d>d?� Z#d@dA� Z$dBdC� Z%dDdE� Z&dFdG� Z'dHdI� Z(dJdK� Z)dLdM� Z*dNdO� Z+dPdQ� Z,dRdS� Z-dTdU� Z.dVdW� Z/dXdY� Z0dZd[� Z1d\d]� Z2d^d_� Z3d`da� Z4dbdc� Z5dgddde�Z6dS )h�DefaultControllerPluginr` Nc C s� t | j� | jjd� | jjj}| jjj}d }yF| jd krDtj� }n| j}tj |||�}|j | jjj |� t j � W n, tk r� |r�|j� | jjd� d S X d S )Nz ==> Press Ctrl-C to exit <==rb )r� r) r_ r- r. r/ r+ r r* r, r7 r8 r9 r: rp rD )r2 �pathr. r/ Zhandlerr+ r r r �_tailf� s" z DefaultControllerPlugin._tailfc C sx | j j� sd S |j� }t|�dk rD| j jd� tj| j _| j� d S t|�dkrr| j jd� tj| j _| j� d S d }|d j d�r�|j d�}t|�dkr�|d }d}nZ|r�|d }|d j � }|dkr�| j jd | � tj| j _d S n| j jd � tj| j _d S d }|d k �r^|dd � }|d k�r,d }n2y t |�}W n$ | j jd | � tj| j _d S | j j � }|d k�r�| jd||f �S t| j � y0|dk�r�|j|| d�} n|j|| d�} W n� tjk �rf } z�tj| j _d} | jtjjk�r| j j| |df � nN| jtjjk�r.| j j| |df � n(| jtjjk�rT| j j| |df � n� W Y d d } ~ X nX | j j| � d S )Nr zError: too few argumentsr zError: too many argumentsr rd rY �stderrzError: bad channel %rz!Error: tail requires process namei@ �fzError: bad argument %sz/logtail/%s/%sz%s: ERROR (%s)z no log filezunknown error reading logzno such process name���r� )r� rY )r) r� r� r� r_ r r rO � help_tailrS r� r� �intr� r� r� ZreadProcessStdoutLogZreadProcessStderrLogr r� r� r rs �NO_FILE�FAILED�BAD_NAME) r2 rA rq ZmodifierrW Zchannel�bytes�whatr� r_ r{ �templater r r �do_tail� s~ z DefaultControllerPlugin.do_tailc C s | j jd� d S )Nz�tail [-f] <name> [stdout|stderr] (default stdout) Ex: tail -f <name> Continuous tail of named process stdout Ctrl-C to exit. tail -100 <name> last 100 *bytes* of process stdout tail <name> stderr last 1600 *bytes* of process stderr)r) r_ )r2 r r r r� 3 s z!DefaultControllerPlugin.help_tailc C s� | j j� sd S |j� }t|�dkrD| j jd� tj| j _| j� d S t|�dkr�|d j d�r�|d dd � }|dkr�d}| j |�S y t |�}W n( | j jd|d � tj| j _d S |}q�| j jd|d � tj| j _d S nd}| j j � }y|j | d�}W nz tjk �r~ } zZtj| j _d } |jtjjk�rJ| j j| d � n$|jtjjk�rl| j j| d � n� W Y d d }~X nX | j j|� d S )Nr zError: too many argumentsr rd r� z /mainlogtailzError: bad argument %si@ z%s: ERROR (%s)� supervisord� no log file�unknown error reading log)r� r� )r� r� )r) r� r� r� r_ r r rO � help_maintailrS r� r� r� ZreadLogr r� r� r rs r� r� ) r2 rA rq r� r� r� r� r_ r{ r� r r r � do_maintail= sL z#DefaultControllerPlugin.do_maintailc C s | j jd� d S )Nz�maintail -f Continuous tail of supervisor main log file (Ctrl-C to exit) maintail -100 last 100 *bytes* of supervisord main log file maintail last 1600 *bytes* of supervisor main log file )r) r_ )r2 r r r r� p s z%DefaultControllerPlugin.help_maintailc C s | j j|�S )N)r) r� )r2 rA r r r �do_quitx s z DefaultControllerPlugin.do_quitc C s | j jd� d S )Nz quit Exit the supervisor shell.)r) r_ )r2 r r r � help_quit{ s z!DefaultControllerPlugin.help_quitc C s | j jd� d S )Nz exit Exit the supervisor shell.)r) r_ )r2 r r r � help_exit� s z!DefaultControllerPlugin.help_exitc C s� g d }}xHt |�D ]<\}}|jt|d |d �� t|| �|krt|| �}qW dt|d � d }x<t |�D ]0\}}||| |d |d d � }| jj|� qrW d S ) N� r� rW z %(namespec)-r zs%(state)-10s%(desc)sZ statename� description)Znamespecr� Zdesc)� enumeraterV r r� �strr) r_ )r2 Z process_infosZ namespecs�maxlen�ir� r� rB r r r �_show_statuses� s z&DefaultControllerPlugin._show_statusesc C s | j j� stj| j _d S | j j� }|j� }t|�j� }| sDd|krJ|}n�g }x�|D ]�}d}t |�\}} xB|D ]:} | d |k} | d k r�| o�| d | k} | rnd}|j | � qnW |rT| d kr�d| } nd| } | j j | � tj| j _qTW | j |� x$|D ] } | d t jkr�tj| j _q�W d S ) N�allTr� rW Fz%s: ERROR (no such group)z%s: ERROR (no such process)r� )r) r� r! r" rO r� r� r r� r rV r_ r� r ZSTOPPED_STATESr ) r2 rA r� Z all_infosr� Zmatching_infosrW Zbad_name� group_name� process_namer� Zmatched�msgr r r � do_status� s: z!DefaultControllerPlugin.do_statusc C s4 | j jd� | j jd� | j jd� | j jd� d S )Nz.status <name> Get status for a single processz8status <gname>:* Get status for all processes in a groupz<status <name> <name> Get status for multiple named processesz$status Get all process status info)r) r_ )r2 r r r � help_status� s z#DefaultControllerPlugin.help_statusc C s | j j� }| j j� sd S |j� }|s>|j� }| j jt|�� n�d|krnx�|j� D ]}| j jt|d �� qPW n�x�|D ]�}y|j|�}W nP t j k r� } z2t j | j _ |jtjjkr�| j jd| � n� W Y d d }~X qtX |d }| j jt|�� |dkrtt j| j _ qtW d S )Nr� r� zNo such process %sr )r) r� r� r� ZgetPIDr_ r� r� �getProcessInfor r� r r rO r� r rs r� r )r2 rA r� r� r� r� rW r{ r r r �do_pid� s, z DefaultControllerPlugin.do_pidc C s( | j jd� | j jd� | j jd� d S )Nz!pid Get the PID of supervisord.z:pid <name> Get the PID of a single child process by name.z;pid all Get the PID of every child process, one per line.)r) r_ )r2 r r r �help_pid� s z DefaultControllerPlugin.help_pidc C s� t |d |d �}|d }d}|tjjkr6||df S |tjjkrN||df S |tjjkrf||df S |tjjkr~||df S |tjjkr�||d f S |tjjkr�||d f S |tjj kr�d | S t d ||f ��d S ) Nr� rW rj z%s: ERROR (%s)zno such processz no such filezfile is not executablezalready startedz spawn errorzabnormal terminationz %s: startedz Unknown result code %s for %s) r r rs r� r� ZNOT_EXECUTABLE�ALREADY_STARTED� SPAWN_ERROR�ABNORMAL_TERMINATIONr � ValueError)r2 �resultrW �coder� r r r � _startresult� s$ z$DefaultControllerPlugin._startresultc C s� | j j� sd S |j� }| j j� }|sF| j jd� tj| j _| j� d S d|kr�|j � }x4|D ],}| j j| j |�� | j j |d t j j� q\W �n\�xX|D �]N}t|�\}}|d k�r^yD|j|�}x4|D ],}| j j| j |�� | j j |d t j j� q�W W nb tjk �rZ } zB| jt j jk�r>d| } | j j| � tj| j _n tj| j _� W Y d d } ~ X nX q�y|j|�}W n` tjk �r� } z@| j||| jd�} | j j| j | �� | j j | d t j j� W Y d d } ~ X q�X t||�}| j jd| � q�W d S )Nz$Error: start requires a process namer� rj z%s: ERROR (no such group))rj rW r� r� z %s: started)r) r� r� r� r_ r r rO � help_startZstartAllProcessesr� ru r rs r� r ZstartProcessGroupr r� r� r� r Z startProcess� faultStringr ) r2 rA r� r� �resultsr� rW r� r� r{ r r r r �do_start� sP ( z DefaultControllerPlugin.do_startc C s4 | j jd� | j jd� | j jd� | j jd� d S )Nz start <name> Start a processz/start <gname>:* Start all processes in a groupz6start <name> <name> Start multiple processes or groupsz start all Start all processes)r) r_ )r2 r r r r� , s z"DefaultControllerPlugin.help_start� signalledc C s� t |d |d �}|d }|d }d}|tjjkr>||df S |tjjkrV||df S |tjjkrn||df S |tjjkr�d ||f S |tjjkr�|S td ||f ��d S ) Nr� rW rj r� z%s: ERROR (%s)zno such processzbad signal namez not runningz%s: %sz Unknown result code %s for %s) r r rs r� Z BAD_SIGNALr r r� r� )r2 r� �successrW r� Z fault_stringr� r r r � _signalresult3 s z%DefaultControllerPlugin._signalresultc C s | j |dd�S )N�stopped)r� )r )r2 r� r r r � _stopresultE s z#DefaultControllerPlugin._stopresultc C s� | j j� sd S |j� }| j j� }|sF| j jd� tj| j _| j� d S d|kr�|j � }x4|D ],}| j j| j |�� | j j |d t j j� q\W �nR�xN|D �]D}t|�\}}|d k�rTyD|j|�}x4|D ],}| j j| j |�� | j j |d t j j� q�W W nX tjk �rP } z8tj| j _| jt j jk�r>d| } | j j| � n� W Y d d } ~ X nX q�y|j|� W n` tjk �r� } z@| j||| jd�} | j j| j | �� | j j | d t j j� W Y d d } ~ X q�X t||�}| j jd| � q�W d S )Nz#Error: stop requires a process namer� rj z%s: ERROR (no such group))rj rW r� r� z %s: stopped)r) r� r� r� r_ r r rO � help_stopZstopAllProcessesr ru r rs r r �stopProcessGroupr r� r� r� Z stopProcessr� r ) r2 rA r� r� r� r� rW r� r� r{ r r r r �do_stopH sN ( z DefaultControllerPlugin.do_stopc C s4 | j jd� | j jd� | j jd� | j jd� d S )Nzstop <name> Stop a processz-stop <gname>:* Stop all processes in a groupz4stop <name> <name> Stop multiple processes or groupsz stop all Stop all processes)r) r_ )r2 r r r r y s z!DefaultControllerPlugin.help_stopc C s� | j j� sd S |j� }t|�dk rD| j jd� | j� tj| j _d S |d }|dd � }| j j � }d|kr�|j |�}x.|D ]&}| j j| j |�� | j j |d � qzW �nJ�xF|D �]<}t |�\} } | d k�rhy@|j| |�}x.|D ]&}| j j| j |�� | j j |d � q�W W nX tjk �rd } z8| jtjjk�rRd| } | j j| � tj| j _n� W Y d d } ~ X nX q�y|j||� W nZ tjk �r� } z:| j| | | jd�} | j j| j | �� | j j | d � W Y d d } ~ X q�X t| | �}| j jd | � q�W d S ) Nr z7Error: signal requires a signal name and a process namer r r� rj z%s: ERROR (no such group))rj rW r� r� z %s: signalled)r) r� r� r� r_ � help_signalr r rO r� ZsignalAllProcessesr ru r ZsignalProcessGroupr r� r� r rs r� Z signalProcessr� r ) r2 rA rq Zsigr� r� r� r� rW r� r� r{ r r r r � do_signal sV " z!DefaultControllerPlugin.do_signalc C s4 | j jd� | j jd� | j jd� | j jd� d S )Nz-signal <signal name> <name> Signal a processz?signal <signal name> <gname>:* Signal all processes in a groupzFsignal <signal name> <name> <name> Signal multiple processes or groupsz.signal <signal name> all Signal all processes)r) r_ )r2 r r r r � s z#DefaultControllerPlugin.help_signalc C sT | j j� sd S |j� }|s<| j jd� tj| j _| j� d S | j|� | j |� d S )Nz&Error: restart requires a process name) r) r� r� r_ r r rO � help_restartr r� )r2 rA r� r r r � do_restart� s z"DefaultControllerPlugin.do_restartc C s@ | j jd� | j jd� | j jd� | j jd� | j jd� d S )Nz!restart <name> Restart a processz2restart <gname>:* Restart all processes in a groupz:restart <name> <name> Restart multiple processes or groupsz"restart all Restart all processeszLNote: restart does not reread config files. For that, see reread and update.)r) r_ )r2 r r r r � s z$DefaultControllerPlugin.help_restartc C s* | j jjr"td�}|j� jd�}nd}|�r&| j j� }y |j� W n� tj k r� } z.|j t j j krr| j jd� n tj| j _� W Y d d }~X n� tjk �r } zltj| j _|jd tjkr�d}| j j|| j jj � n0|jd tjk�rd}| j j|| j jj � n� W Y d d }~X nX | j jd� d S ) Nz5Really shut the remote supervisord process down y/N? �yr z ERROR: already shutting downr z1ERROR: %s refused connection (already shut down?)z+ERROR: %s no such file (already shut down?)z Shut down)r) r- rw r r� rS r� Zshutdownr r� r� r rs �SHUTDOWN_STATEr_ r r rO r� r rq r� r� r8 r� )r2 rA �yesno�reallyr� r{ r� r r r � do_shutdown� s. z#DefaultControllerPlugin.do_shutdownc C s | j jd� d S )Nz+shutdown Shut the remote supervisord down.)r) r_ )r2 r r r � help_shutdown� s z%DefaultControllerPlugin.help_shutdownc C s� |r&| j jd� tj| j _| j� d S | j jjrHtd�}|j � j d�}nd}|r�| j j � }y |j � W nL t jk r� } z.tj| j _|jtjjkr�| j jd� n� W Y d d }~X nX | j jd� d S )Nz"Error: reload accepts no argumentsz3Really restart the remote supervisord process y/N? r r z ERROR: already shutting downzRestarted supervisord)r) r_ r r rO � help_reloadr- rw r r� rS r� r� r r� r� r rs r )r2 rA r r r� r{ r r r � do_reload� s& z!DefaultControllerPlugin.do_reloadc C s | j jd� d S )Nz(reload Restart the remote supervisord.)r) r_ )r2 r r r r s z#DefaultControllerPlugin.help_reloadc C s� |\}}}i }x@|df|df|dfgD ]&\}}|j tt||gt|� ��� q&W |r�t|j� �}|j� x2|D ] } | jjd| || f � qnW n | jjd� d S )NZ available�changedZ disappearedz%s: %sz No config updates to processes) r� �dict�zipr� r� �keysr� r) r_ ) r2 Zadded_changed_dropped_tuple�addedr ZdroppedZ changedict�nr} r� rW r r r �_formatChanges s " z&DefaultControllerPlugin._formatChangesc C sr t |d |d �}d|i}|d r,d|d< nd|d< |d rFd|d< nd|d< d |d |d f |d < d }|| S )Nr� rW Zinusezin useZavailZ autostart�autoZmanualz%s:%sZ group_prioZ process_prioZpriorityz4%(name)-32s %(inuse)-9s %(autostart)-9s %(priority)s)r )r2 � configinforW Z formattedr� r r r �_formatConfigInfo" s z)DefaultControllerPlugin._formatConfigInfoc C s� |r&| j jd� tj| j _| j� d S | j j� }y |j� }W nL tj k r� } z.tj| j _|j t j j krv| j jd� n� W Y d d }~X n"X x |D ]}| j j| j|�� q�W d S )Nz!Error: avail accepts no argumentsz ERROR: supervisor shutting down)r) r_ r r rO � help_availr� ZgetAllConfigInfor r� r� r rs r r )r2 rA r� r r{ Zpinfor r r �do_avail3 s z DefaultControllerPlugin.do_availc C s | j jd� d S )Nz(avail Display all configured processes)r) r_ )r2 r r r r G s z"DefaultControllerPlugin.help_availc C s� |r&| j jd� tj| j _| j� d S | j j� }y |j� }W nn tj k r� } zPtj| j _|j t j j krv| j jd� n$|j t j jkr�| j jd|j � n� W Y d d }~X nX | j|d � d S )Nz"Error: reread accepts no argumentsz ERROR: supervisor shutting downz ERROR: %sr )r) r_ r r rO � help_rereadr� � reloadConfigr r� r� r rs r Z CANT_REREADr� r )r2 rA r� r� r{ r r r � do_rereadJ s z!DefaultControllerPlugin.do_rereadc C s | j jd� d S )NzDreread Reload the daemon's configuration files without add/remove)r) r_ )r2 r r r r _ s z#DefaultControllerPlugin.help_rereadc C s� |j � }| jj� }x�|D ]�}y|j|� W n� tjk r� } z~|jtjj krd| jj d� t j | j_ nR|jtjjkr�| jj d� n6|jtjjkr�| jj d| � t j | j_ n t j | j_ � W Y d d }~X qX | jj d| � qW d S )NzERROR: shutting downz#ERROR: process group already activez ERROR: no such process/group: %sz%s: added process group)r� r) r� �addProcessGroupr r� r� r rs r r_ r r rO Z ALREADY_ADDEDr� )r2 rA r� r� rW r{ r r r �do_addb s" z DefaultControllerPlugin.do_addc C s | j jd� d S )NzBadd <name> [...] Activates any updates in config for process/group)r) r_ )r2 r r r �help_addx s z DefaultControllerPlugin.help_addc C s� |j � }| jj� }x�|D ]�}y|j|� W np tjk r� } zRtj| j_|j t j j krh| jj d| � n"|j t j jkr�| jj d| � n� W Y d d }~X qX | jj d| � qW d S )Nz&ERROR: process/group still running: %sz ERROR: no such process/group: %sz%s: removed process group)r� r) r� �removeProcessGroupr r� r r rO r� r rs Z STILL_RUNNINGr_ r� )r2 rA r� r� rW r{ r r r � do_remove| s z!DefaultControllerPlugin.do_removec C s | j jd� d S )Nz<remove <name> [...] Removes process/group from active config)r) r_ )r2 r r r � help_remove� s z#DefaultControllerPlugin.help_removec s � fdd�}� j j� }y |j� }W nN tjk rp } z0tj� j _|jt j j kr^� j j d� d S � W Y d d }~X nX |d \}}}t |j� �} d| kr�t � } | �r t � } x |j� D ]} | j| d � q�W | j|� x.| D ]&} | | krֈ j j d| � tj� j _q�W x�|D ]x} | �r | | k�r �q|j| �} || d� d d � | D �}|�rh� j j d | d f � tj� j _�q|j| � || d � �qW xT|D ]L} | �r�| | k�r��q�|j| � || d� |j| � |j| � || d� �q�W x6|D ].} | �r�| | k�r��q�|j| � || d� �q�W d S )Nc s � j jd| |f � d S )Nz%s: %s)r) r_ )rW r� )r2 r r �log� s z.DefaultControllerPlugin.do_update.<locals>.logz ERROR: already shutting downr r� r� zERROR: no such group: %sr c S s g | ]}|d t jjkr|�qS )rj )r rs r� )r� �resr r r r� � s z5DefaultControllerPlugin.do_update.<locals>.<listcomp>z%s: %szhas problems; not removingzremoved process groupzupdated process groupzadded process group)r) r� r r r� r r rO r� r rs r r_ �setr� r� r� r� r r$ r! )r2 rA r' r� r� r{ r r ZremovedZ valid_gnamesr� r� Zgnamer� Zfailsr )r2 r � do_update� s` z!DefaultControllerPlugin.do_updatec C s( | j jd� | j jd� | j jd� d S )NzVupdate Reload config and add/remove as necessary, and will restart affected programszYupdate all Reload config and add/remove as necessary, and will restart affected programsz+update <gname> [...] Update specific groups)r) r_ )r2 r r r � help_update� s z#DefaultControllerPlugin.help_updatec C sv t |d |d �}|d }d}|tjjkr6||df S |tjjkrN||df S |tjjkrbd| S td||f ��d S ) Nr� rW rj z%s: ERROR (%s)zno such processZfailedz %s: clearedz Unknown result code %s for %s)r r rs r� r� r r� )r2 r� rW r� r� r r r � _clearresult� s z$DefaultControllerPlugin._clearresultc C s* | j j� sd S |j� }|s<| j jd� tj| j _| j� d S | j j� }d|kr�|j � }x�|D ]&}| j j| j |�� | j j |d � q\W n�x�|D ]�}t |�\}}y|j |� W nZ tjk �r } z:| j||| jd�} | j j| j | �� | j j | d � W Y d d } ~ X q�X t||�}| j jd| � q�W d S )Nz$Error: clear requires a process namer� rj )rj rW r� r� z %s: cleared)r) r� r� r_ r r rO � help_clearr� ZclearAllProcessLogsr, ru r ZclearProcessLogsr r� r� r� r ) r2 rA r� r� r� r� rW r� r� r{ r r r r �do_clear� s6 " z DefaultControllerPlugin.do_clearc C s( | j jd� | j jd� | j jd� d S )Nz)clear <name> Clear a process' log files.z5clear <name> <name> Clear multiple process' log filesz'clear all Clear all process' log files)r) r_ )r2 r r r r- s z"DefaultControllerPlugin.help_clearc C s` |j � }tj|�}|d dkr8| jjd� tj| j_d S || jj_| jj}| j d� || j_d S )Nr �unix�httpz%ERROR: url must be http:// or unix://rb )r/ r0 ) r� r r) r_ r r rO r- r8 r� )r2 rA Zurl�partsZold_exitstatusr r r �do_open s z DefaultControllerPlugin.do_openc C s | j jd� | j jd� d S )Nz3open <url> Connect to a remote supervisord process.z3 (for UNIX domain socket, use unix:///socket/path))r) r_ )r2 r r r � help_open s z!DefaultControllerPlugin.help_openc C sR |r&| j jd� tj| j _| j� d S | j j� s4d S | j j� }| j j|j� � d S )Nz#Error: version accepts no arguments) r) r_ r r rO � help_versionr� r� ZgetSupervisorVersion)r2 rA r� r r r � do_version" s z"DefaultControllerPlugin.do_versionc C s | j jd� d S )Nz<version Show the version of the remote supervisord process)r) r_ )r2 r r r r4 . s z$DefaultControllerPlugin.help_versionc $ C s< | j j� sd S |j� }|s<| j jd� tj| j _| j� d S t|�dkrb| j jd� tj| j _d S |d }| j j � }y|j |�}W n\ t j k r� } z>|j tjjkr�| j jd� tj| j _n| j jdt|� � d S d }~X nX |d tjjk�r | j jd� tj| j _d S | j jd � d }y�t|| j �}|j� x�t� d }y|j||� W nj t j k �r� } zJ|j tjjk�r�| j jd � n| j jdt|� � | j jd � |j� d S d }~X nX |j |�}|d tjjk�r4| j jd � | j jd � |j� d S �q4W W n4 tt fk �r6 | j jd � |�r2|j� Y nX d S ) Nz ERROR: no process name suppliedr z&ERROR: too many process names suppliedr z ERROR: bad process name suppliedzERROR: r� zERROR: process not runningz ==> Press Ctrl-C to exit <==r� zProcess got killedzExiting foreground) r) r� r� r_ r r rO �help_fgr� r� r� r r� r� r rs r� r� r Z ProcessStatesZRUNNINGr# r6 r ZsendProcessStdinr rE rp �EOFError) r2 rA r� rW r� r� r{ r] Zinpr r r �do_fg3 sh z DefaultControllerPlugin.do_fgc C s | j jd� | j jd� d S )Nz4fg <process> Connect to a process in foreground modez Ctrl-C to exit)r) r_ )r2 rq r r r r6 u s z DefaultControllerPlugin.help_fg)r� )N)7r r r rW r+ r� r� r� r� r� r� r� Zdo_exitr� r� r� r� r� r� r� r� r� r r r r r r r r r r r r r r r r r r r" r# r% r& r* r+ r, r. r- r2 r3 r5 r4 r8 r6 r r r r r� � sh S 3+1 16 D # Br� c C sh |d krt � }|j| td� t|�}|jrH|jdj|j�� tj|j � |j rd|j | |� tjd� d S )N)r� r� r ) r ZrealizerF rG rq ry �joinr; �exitrO rw rr )rq r- �cr r r �mainz s r< �__main__)NN)*rF rP r� rx r� r; r$ Zsupervisor.compatr r r r r Zsupervisor.medusar r9 Zsupervisor.optionsr r r r� r r r r r! rs r� r� r rt r% r# rQ rG r� r� r� r� r� r< r r r r r �<module> sT 7 5 ?
Back to File Manager