Gemfury

doctorondemand / supervisor python

Repository URL to install this package:
Details
supervisor / __pycache__ / supervisorctl.cpython-38.pyc
U

B]Õã@sndZddlZddlZddlZddlZddlZddlZddlmZddlm	Z	ddlm
Z
ddlmZddlmZddl
mZdd	lmZdd
lmZddlmZddlmZdd
lmZddlmZGdddZGdddZejjejjejjfZGdddejZ Gdddej!Z"ddZ#GdddZ$ddZ%ddZ&Gdd d e$Z'd$d!d"Z(e)d#krje(dS)%asupervisorctl -- 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(eZdZdZdZdZdZdZdZdZ	dS)	ÚLSBInitExitStatusesrééééééN)
Ú__name__Ú
__module__Ú__qualname__ÚSUCCESSÚGENERICÚINVALID_ARGSÚUNIMPLEMENTED_FEATUREÚINSUFFICIENT_PRIVILEGESÚ
NOT_INSTALLEDÚNOT_RUNNING©r r ú'./build/lib/supervisor/supervisorctl.pyr/src@seZdZdZdZdS)ÚLSBStatusExitStatusesrrN)rrrrÚUNKNOWNr r r r!r"8sr"c@sHeZdZdZddZddZddZdd	Zd
dZdd
Z	ddZ
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
    cCshtj |¡d|_||_||_t ¡|_t 	|j|jj
j|jj
j¡|_
t 	|j|jj
j|jj
j¡|_dS)NF)Ú	threadingÚThreadÚ__init__ÚkilledÚprogramÚctlrÚListenerÚlistenerÚHTTPHandlerÚoptionsÚusernameÚpasswordÚoutput_handlerÚ
error_handler)Úselfr)r*r r r!r'Fs
þþzfgthread.__init__cCs |j|_|j|_tj |¡dS©N)ÚrunÚ_fgthread__run_backupÚ_fgthread__runr%r&Ústart©r3r r r!r8Sszfgthread.startcCs@|j |jjjd|j¡|j |jjjd|j¡t ¡dS)Nz/logtail/%s/stdoutz/logtail/%s/stderr)	r1Úgetr*r.Ú	serverurlr)r2ÚasyncoreÚloopr9r r r!r5Ysÿÿzfgthread.runcCs t |j¡| ¡|j|_dSr4)ÚsysÚsettraceÚglobaltracer6r5r9r r r!Z__run`szfgthread.__runcCs|dkr|jSdSdS)NZcall)Ú
localtrace©r3ÚframeZwhyÚargr r r!r@fszfgthread.globaltracecCs|jr|dkrt|jS)NÚline)r(Ú
SystemExitrArBr r r!rAlszfgthread.localtracecCs|j ¡|j ¡d|_dS)NT)r1Úcloser2r(r9r r r!Úkillrs

z
fgthread.killN)rrrÚ__doc__r'r8r5r7r@rArHr r r r!r$@s
r$c@s´eZdZd+ddZddZddZd	d
Zd,ddZd
dZddZ	ddZ
ddZd-ddZddZ
d.ddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*ZdS)/Ú
ControllerÚtabNc
Cs¶||_|jjd|_g|j_dg|_d|_tj|_tj	 
||||¡|jjD]d\}}}||f|}t|D]0}	|	 
d¡rjtt||	rj|j |	dd¡qj|jj |¡||_qLdS)Nz> ÚhelpÚdo_r)r.ÚpromptÚpluginsÚvocabÚ_complete_inforrÚ
exitstatusÚcmdÚCmdr'Zplugin_factoriesÚdirÚ
startswithÚcallableÚgetattrÚappendÚname)
r3r.ZcompletekeyÚstdinÚstdoutrZÚfactoryÚkwargsÚpluginÚar r r!r'yszController.__init__cCsdSr4r r9r r r!Ú	emptylineszController.emptylinecCs| d|¡tj|_dS)Nz*** Unknown syntax: %s)ÚoutputrrrR)r3rEr r r!ÚdefaultszController.defaultcsàzddl ¡}| dd¡}| dd¡}| dd¡} |¡jrz j¡Wntk
rjYnXfdd}ddl}| |¡Wnt	k
r¢YnXz|j
 d¡| ¡Wnt
k
rÚ| d¡YnXdS)	Nrú:ÚÚ*ú-cs*z j¡Wntk
r$YnXdSr4)Úwrite_history_fileÚhistory_fileÚIOErrorr ©r.Úreadliner r!Úsave¡sz%Controller.exec_cmdloop.<locals>.saveÚstatus)rlZget_completer_delimsÚreplaceZset_completer_delimsriÚread_history_filerjÚatexitÚregisterÚImportErrorZcmdqueuerYZcmdloopÚKeyboardInterruptrb)r3Úargsr.Zdelimsrmrqr rkr!Úexec_cmdloops.

zController.exec_cmdloopcCs0||tjjfkrn|tkr$tj|_ntj|_dSr4)rÚFaultsrÚDEAD_PROGRAM_FAULTSrrrRr)r3Z	faultcodeZignored_faultcoder r r!Ú set_exitstatus_from_xmlrpc_fault²s

z+Controller.set_exitstatus_from_xmlrpc_faultc
Csz| |¡\}}}|s| ¡S|dkr.| |¡Sd|_||_|dkrL| |¡S| |¡}|dkrh| |¡Sz¾z||WWStjk
r}z|jdkr|j	j
rì| d¡td}t
j
dd}| d¡||j	_||j	_| |¡WY¢&WS| d¡tj|_n
tj|_W5d}~XYnX||WnNtk
rtt ¡\\}}	}}
}}d|
|||f}
| |
¡tj|_YnXdS)	z Override the onecmd method to:
          - catch and print all exceptions
          - call 'do_foo' on plugins rather than ourself
        NreizServer requires authenticationz	Username:z	Password:)rNz error: %s, %s: file: %s line: %s)Z	parselinerarcrQZlastcmdÚ_get_do_funcrZ
ProtocolErrorZerrcoder.ÚinteractiverbrÚgetpassr/r0ÚonecmdrrrRÚ	Exceptionr<Zcompact_traceback)r3rErSrDZdo_funcÚer/r0ÚfileZfunÚtÚvZtbinfoÚerrorr r r!r}ºsF








zController.onecmdcCsBd|}t||d}|s>|jjD]}t||d}|dk	r q>q |S)NrM)rXr.rO)r3rSZ	func_nameÚfuncr_r r r!rzçszController._get_do_funccCs(t|tr| d¡}|j |d¡dS)Nzutf-8Ú
)Ú
isinstancerÚencoder\Úwrite)r3Úmessager r r!rbñs

zController.outputcCs
| d¡S)NÚ
supervisor)Úget_server_proxyr9r r r!Úget_supervisoröszController.get_supervisorcCs$|j ¡}|dkr|St||SdSr4)r.ZgetServerProxyrX)r3Ú	namespaceÚproxyr r r!rùs
zController.get_server_proxyc
CsBzL| ¡}| ¡}ddlm}||jkrJ| d|j|f¡tj|_WdSWnðt	j
k
r¤}z8|jtj
jkr| d¡tj|_WY¢dStj|_W5d}~XYntjk
r<}zx|jdtjkrì| d|jj¡tj|_WY¢HdS|jdtjkr"| d|jj¡tj|_WY¢dStj|_W5d}~XYnXdS)	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)rZ
getVersionrrZAPI_VERSIONrbrrrRrÚFaultÚ	faultCoderrwZUNKNOWN_METHODrrÚsocketrruÚerrnoÚECONNREFUSEDr.r;rÚENOENTr)r3rZapirrr r r!ÚupchecksB
þÿ
ÿ


zController.upcheckcCs´|dkrddl}| ¡}g}| ¡s0| |¡}nl| ¡}|d}t|dkrb| d¡sb| |¡}n:|dkrv| |¡}n&|dkr| |¡}n|dkr| |¡}t||kr°||SdS)aaCompleter 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.Nrrú rL)ÚaddÚremoveÚupdate)	ÚclearZfgÚpidÚrestartÚsignalr8rnÚstopÚtail)	rlZget_line_bufferÚstripÚ_complete_actionsÚsplitÚlenÚendswithÚ_complete_groupsÚ_complete_processes)r3ÚtextÚstaterErlZmatchesZwordsÚactionr r r!Úcomplete%s$
zController.completecsfdd|jDS)z5Build a completion list of action names matching textcsg|]}| ¡r|dqS©r©rV)Ú.0r`©r¨r r!Ú
<listcomp>Hs
z0Controller._complete_actions.<locals>.<listcomp>)rP)r3r¨r r¯r!r¢FszController._complete_actionscs>g}| ¡D]}|d|kr| |d¡qfdd|DS)z4Build a completion list of group names matching textÚgroupcsg|]}| ¡r|dqSr¬r)r®Úgr¯r r!r°Ps
z/Controller._complete_groups.<locals>.<listcomp>©Ú_get_complete_inforY)r3r¨ÚgroupsÚinfor r¯r!r¦Js
zController._complete_groupscsg}| ¡D]h}dks(|d|dkrf| d|d|df¡d|d|krt| d|d¡q| |d¡qfdd|DS)z6Build a completion list of process names matching textrdrZr±ú%s:%sz%s:*csg|]}| ¡r|dqSr¬r)r®Úpr¯r r!r°\s
z2Controller._complete_processes.<locals>.<listcomp>r³)r3r¨Z	processesr¶r r¯r!r§RszController._complete_processescCs|jdkr| ¡ ¡|_|jS)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)rQrÚgetAllProcessInfor9r r r!r´^s
zController._get_complete_infocCs2| ¡dkr| ¡n|jjD]}| |¡qdS)NrL)r¡Ú	help_helpr.rOÚdo_help)r3rDr_r r r!r»fs
zController.do_helpcCs| d¡| d¡dS)Nz'help		Print a list of available actionsz%help <action>	Print help for <action>©rbr9r r r!rºms
zController.help_helpcCs| d¡dS)Nrerr¼©r3rDr r r!Údo_EOFqs
zController.do_EOFcCs| d¡dS)Nz(To quit, type ^D or use the quit commandr¼r9r r r!Úhelp_EOFuszController.help_EOF)rKNN)N)N)N)rrrr'rarcrvryr}rzrbrrrr«r¢r¦r§r´r»rºr¾r¿r r r r!rJws,ÿ
 
-

%
!rJcCs@g}|jg}|r<| d¡}|jr.|t|j}|t|}q|S)Nr)Ú	__class__ÚpopÚ	__bases__ÚlistrU)ÚinstÚnamesÚclassesZaclassr r r!Ú	get_namesxs
rÇc@s0eZdZdZddZddZeeZddZdS)	ÚControllerPluginBaseZunnamedcCs
||_dSr4)r*)r3Z
controllerr r r!r'szControllerPluginBase.__init__cCs
d|jS)Nz %s commands (type help <topic>):)rZr9r r r!Ú_doc_headersz ControllerPluginBase._doc_headercCsr|rzt|d|}Wnntk
rz,t|d|j}|rP|j |¡WYdSWntk
rfYnX|j |jj|f¡YdSX|nàt|}g}g}i}|D]$}|dddkr¦d||dd<q¦| ¡d}	|D]p}|dddkrÜ||	krüqÜ|}	|dd}
|
|kr(| |
¡||
=qÜt||jrB| |
¡qÜ| |
¡qÜ|j d¡|j 	|j
|dd¡dS)	NZhelp_rMrrrerééP)rXÚAttributeErrorrIr*rbZnohelprÇÚsortrYZprint_topicsÚ
doc_header)r3rDrÚdocrÅZcmds_docZ
cmds_undocrLrZZprevnamerSr r r!r»sJ


zControllerPluginBase.do_helpN)	rrrrZr'rÉÚpropertyrÎr»r r r r!rÈs
rÈcCs(ttjdd ¡}| d¡r dStjjS)NÚencodingreÚutf)rXr>r\ÚlowerrVrÑ)Úencr r r!Ú
not_all_langs·srÕcCst}|r| d|¡dS)NzWarning: sys.stdout.encoding is set to %s, so Unicode output may fail. Check your LANG and PYTHONIOENCODING environment settings.)rÕrb)r*Zproblematic_encr r r!Úcheck_encoding»s
þrÖc@s¤eZdZdZdZddZddZddZd	d
ZddZ	d
dZ
ddZe
ZddZ
ddZddZddZddZddZddZdd Zd!d"Zdfd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5Zd6d7Zd8d9Z d:d;Z!d<d=Z"d>d?Z#d@dAZ$dBdCZ%dDdEZ&dFdGZ'dHdIZ(dJdKZ)dLdMZ*dNdOZ+dPdQZ,dRdSZ-dTdUZ.dVdWZ/dXdYZ0dZd[Z1d\d]Z2d^d_Z3d`daZ4dbdcZ5dgdddeZ6dS)hÚDefaultControllerPluginrcNcCs¨t|j|j d¡|jjj}|jjj}d}zF|jdkrDt ¡}n|j}t 	|||¡}| 
|jjj|¡t 
¡Wn.tk
r¢|r| ¡|j d¡YdSXdS)Nú==> Press Ctrl-C to exit <==re)rÖr*rbr.r/r0r,rr+r-r:r;r<r=rtrG)r3Úpathr/r0Zhandlerr,r r r!Ú_tailfÅs"




zDefaultControllerPlugin._tailfc
Cs||j ¡sdS| ¡}t|dkrD|j d¡tj|j_| ¡dSt|dkrr|j d¡tj|j_| ¡dSd}|d 	d¡r| 
d¡}t|dkr¨|d}d}nZ|rè|d}|d ¡}|d	kræ|j d
|¡tj|j_dSn|j d¡tj|j_dSd}|dk	rb|dd}|d
kr,d}n6zt|}Wn(|j d|¡tj|j_YdSX|j 
¡}|dkr| d||f¡St|jz0|dkr°| ||d¡}	n| ||d¡}	Wn¨tjk
rj}
ztj|j_d}|
jtjjkr|j ||df¡nN|
jtjjkr2|j ||df¡n(|
jtjjkrX|j ||df¡nW5d}
~
XYnX|j |	¡dS)NrzError: too few argumentsrúError: too many argumentsrrgéÿÿÿÿr\)Ústderrr\zError: bad channel %rz!Error: tail requires process nameé@ÚfúError: bad argument %sz/logtail/%s/%sú%s: ERROR (%s)úno log fileúunknown error reading logzno such process name)r*rr£r¤rbrrrRÚ	help_tailrVrÁrÓÚintrrÚrÖZreadProcessStdoutLogZreadProcessStderrLogrrrrrwÚNO_FILEÚFAILEDÚBAD_NAME)r3rDruZmodifierrZZchannelÚbytesÚwhatrrbrÚtemplater r r!Údo_tailàs












ÿÿ

ÿ

ÿ
zDefaultControllerPlugin.do_tailcCs|j d¡dS)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*rbr9r r r!rä3sÿz!DefaultControllerPlugin.help_tailc

Cs|j ¡sdS| ¡}t|dkrD|j d¡tj|j_| ¡dSt|dkrè|d 	d¡rÄ|ddd}|dkrd}| 
|¡Szt|}Wn,|j d|d¡tj|j_YdSX|}qì|j d|d¡tj|j_dSnd}|j ¡}z| 
|d¡}Wnztjk
r}zXtj|j_d	}	|jtjjkrN|j |	d
¡n$|jtjjkrp|j |	d¡nW5d}~XYnX|j |¡dS)NrrÛrrgrßz/mainlogtailràrÞrá)Úsupervisordrâ)rîrã)r*rr£r¤rbrrrRÚ
help_maintailrVrÚrårZreadLogrrrrrwrærç)
r3rDrurêrÙrérrbrrër r r!Údo_maintail=sJ






z#DefaultControllerPlugin.do_maintailcCs|j d¡dS)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ír9r r r!rïpsÿz%DefaultControllerPlugin.help_maintailcCs|j |¡Sr4)r*r¾r½r r r!Údo_quitxszDefaultControllerPlugin.do_quitcCs|j d¡dS)Nzquit	Exit the supervisor shell.rír9r r r!Ú	help_quit{sz!DefaultControllerPlugin.help_quitcCs|j d¡dS)Nzexit	Exit the supervisor shell.rír9r r r!Ú	help_exitsz!DefaultControllerPlugin.help_exitcCs¢gd}}t|D]<\}}| t|d|d¡t|||krt||}qdt|dd}t|D]0\}}||||d|dd	}|j |¡qldS)
Nér±rZz%(namespec)-rzs%(state)-10s%(desc)sZ	statenameÚdescription)Znamespecr©Zdesc)Ú	enumeraterYr
r¤Ústrr*rb)r3Z
process_infosZ	namespecsÚmaxlenÚir¶rërEr r r!Ú_show_statusess
þz&DefaultControllerPlugin._show_statusesc
Cs
|j ¡stj|j_dS|j ¡}| ¡}t| ¡}|rBd|krH|}ng}|D]}d}t	|\}}	|D]:}
|
d|k}|	dk	r|o|
d|	k}|rhd}| 
|
¡qh|rP|	dkrºd|}nd|}|j |¡tj|j_qP| |¡|D]}
|
dt
jkrètj|j_qèdS)	NÚallTr±rZFú%s: ERROR (no such group)z%s: ERROR (no such process)r©)r*rr"r#rRrr¹rr£rrYrbrúr
ZSTOPPED_STATESr)
r3rDrZ	all_infosrÅZmatching_infosrZZbad_nameÚ
group_nameÚprocess_namer¶ZmatchedÚmsgr r r!Ú	do_statuss:




z!DefaultControllerPlugin.do_statuscCs4|j d¡|j d¡|j d¡|j d¡dS)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 inforír9r r r!Úhelp_status¼sz#DefaultControllerPlugin.help_statuscCs|j ¡}|j ¡sdS| ¡}|s>| ¡}|j t|¡nÀd|krj| ¡D]}|j t|d¡qNn|D]}z| |¡}WnPt	j
k
rÐ}z0tj|j_
|jtjjkr¾|j d|¡nW5d}~XYqnX|d}|j t|¡|dkrntj|j_
qndS)NrûrzNo such process %sr)r*rrr£ZgetPIDrbr÷r¹ÚgetProcessInforrrrrRrrrwrèr)r3rDrrÅrr¶rZrr r r!Údo_pidÄs,


zDefaultControllerPlugin.do_pidcCs(|j d¡|j d¡|j d¡dS)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ír9r r r!Úhelp_pidßsz DefaultControllerPlugin.help_pidcCsÖt|d|d}|d}d}|tjjkr6||dfS|tjjkrN||dfS|tjjkrf||dfS|tjjkr~||dfS|tjjkr||d	fS|tjjkr®||d
fS|tjj	krÂd|St
d||fdS)
Nr±rZrnráúno such processzno such filezfile is not executablezalready startedzspawn errorzabnormal terminationú%s: startedúUnknown result code %s for %s)r
rrwrèræZNOT_EXECUTABLEÚALREADY_STARTEDÚSPAWN_ERRORÚABNORMAL_TERMINATIONrÚ
ValueError©r3ÚresultrZÚcoderër r r!Ú_startresultæs$z$DefaultControllerPlugin._startresultcCsâ|j ¡sdS| ¡}|j ¡}|sF|j d¡tj|j_| ¡dSd|kr| 	¡}|D],}|j | 
|¡¡|j |dtj
j¡qZnR|D]J}t|\}}|dkrRz@| |¡}|D],}|j | 
|¡¡|j |dtj
j¡q¼Wnbtjk
rN}	z@|	jtj
jkr2d|}
|j |
¡tj|j_ntj|j_W5d}	~	XYnXqz| |¡}Wn`tjk
rÀ}	z>|	j|||	jd}
|j | 
|
¡¡|j |
dtj
j¡W5d}	~	XYqXt||}|j d|¡qdS)Nz$Error: start requires a process namerûrnrü©rnrZr±rõr)r*rr£rrbrrrRÚ
help_startZstartAllProcessesrryrrwrrZstartProcessGrouprrrrèrZstartProcessÚfaultStringr
©r3rDrÅrÚresultsr
rZrýrþrrr r r!Údo_startûsR






ý(
z DefaultControllerPlugin.do_startcCs4|j d¡|j d¡|j d¡|j d¡dS)Nzstart <name>		Start a processz/start <gname>:*		Start all processes in a groupz6start <name> <name>	Start multiple processes or groupszstart all		Start all processesrír9r r r!r,sÿz"DefaultControllerPlugin.help_startÚ	signalledcCsªt|d|d}|d}|d}d}|tjjkr>||dfS|tjjkrV||dfS|tjjkrn||dfS|tjjkrd	||fS|tjjkr|Std
||fdS)Nr±rZrnrõrárzbad signal nameznot runningú%s: %sr)	r
rrwrèZ
BAD_SIGNALrrrçr)r3r
ÚsuccessrZrZfault_stringrër r r!Ú
_signalresult3sz%DefaultControllerPlugin._signalresultcCs|j|ddS)NÚstopped)r)r)r3r
r r r!Ú_stopresultEsz#DefaultControllerPlugin._stopresultcCsØ|j ¡sdS| ¡}|j ¡}|sF|j d¡tj|j_| ¡dSd|kr| 	¡}|D],}|j | 
|¡¡|j |dtj
j¡qZnH|D]@}t|\}}|dkrHz@| |¡}|D],}|j | 
|¡¡|j |dtj
j¡q¼WnXtjk
rD}	z6tj|j_|	jtj
jkr2d|}
|j |
¡nW5d}	~	XYnXqz| |¡Wn`tjk
r¶}	z>|	j|||	jd}
|j | 
|
¡¡|j |
dtj
j¡W5d}	~	XYqXt||}|j d|¡qdS)Nz#Error: stop requires a process namerûrnrürz%s: stopped)r*rr£rrbrrrRÚ	help_stopZstopAllProcessesrryrrwrrÚstopProcessGrouprrrrèZstopProcessrr
rr r r!Údo_stopHsP






ý(
zDefaultControllerPlugin.do_stopcCs4|j d¡|j d¡|j d¡|j d¡dS)Nzstop <name>		Stop a processz-stop <gname>:*		Stop all processes in a groupz4stop <name> <name>	Stop multiple processes or groupszstop all		Stop all processesrír9r r r!rysz!DefaultControllerPlugin.help_stopc
Csè|j ¡sdS| ¡}t|dkrD|j d¡| ¡tj|j_dS|d}|dd}|j 	¡}d|kr¤| 
|¡}|D]&}|j | |¡¡|j |d¡qxn@|D]8}t
|\}	}
|
dkr\z<| |	|¡}|D]&}|j | |¡¡|j |d¡qÖWnXtjk
rX}z6|jtjjkrFd|	}|j |¡tj|j_nW5d}~XYnXq¨z| ||¡WnZtjk
rÆ}z8|j|
|	|jd}|j | |¡¡|j |d¡W5d}~XYq¨Xt|	|
}|j d	|¡q¨dS)
Nrz7Error: signal requires a signal name and a process namerrrûrnrürz
%s: signalled)r*rr£r¤rbÚhelp_signalrrrRrZsignalAllProcessesrryrZsignalProcessGrouprrrrrwrèZ
signalProcessrr
)
r3rDruZsigrÅrrr
rZrýrþrrr r r!Ú	do_signals^
ÿ




ÿý"
z!DefaultControllerPlugin.do_signalcCs4|j d¡|j d¡|j d¡|j d¡dS)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 processesrír9r r r!rµsz#DefaultControllerPlugin.help_signalcCsT|j ¡sdS| ¡}|s<|j d¡tj|j_| ¡dS| |¡| 	|¡dS)Nz&Error: restart requires a process name)
r*rr£rbrrrRÚhelp_restartrr)r3rDrÅr r r!Ú
do_restart»s


z"DefaultControllerPlugin.do_restartcCs@|j d¡|j d¡|j d¡|j d¡|j d¡dS)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ír9r r r!r!Ês
z$DefaultControllerPlugin.help_restartc
Cs*|jjjr"td}| ¡ d¡}nd}|r&|j ¡}z| ¡WnÖtj	k
r}z,|j
tjj
krr|j d¡ntj|j_W5d}~XYntjk
r}zjtj|j_|jdtjkrØd}|j ||jjj¡n0|jdtjkrd}|j ||jjj¡nW5d}~XYnX|j d¡dS)	Nz5Really shut the remote supervisord process down y/N? ÚyrúERROR: already shutting downrz1ERROR: %s refused connection (already shut down?)z+ERROR: %s no such file (already shut down?)z	Shut down)r*r.r{rrÓrVrZshutdownrrrrrwÚSHUTDOWN_STATErbrrrRrrrurrr;r)r3rDÚyesnoÚreallyrrrÿr r r!Údo_shutdownÓs.



z#DefaultControllerPlugin.do_shutdowncCs|j d¡dS)Nz+shutdown 	Shut the remote supervisord down.rír9r r r!Ú
help_shutdownòsz%DefaultControllerPlugin.help_shutdownc
CsÄ|r&|j d¡tj|j_| ¡dS|jjjrHtd}| 	¡ 
d¡}nd}|rÀ|j ¡}z| ¡WnLt
jk
r²}z,tj|j_|jtjjkr |j d¡nW5d}~XYnX|j d¡dS)Nz"Error: reload accepts no argumentsz3Really restart the remote supervisord process y/N? r#rr$zRestarted supervisord)r*rbrrrRÚhelp_reloadr.r{rrÓrVrrrrrrrwr%)r3rDr&r'rrr r r!Ú	do_reloadõs&



z!DefaultControllerPlugin.do_reloadcCs|j d¡dS)Nz(reload 		Restart the remote supervisord.rír9r r r!r*sz#DefaultControllerPlugin.help_reloadc
	Cs|\}}}i}|df|df|dffD]&\}}| tt||gt|¡q$|rt| ¡}| ¡|D]}	|j d|	||	f¡qhn|j d¡dS)NZ	availableÚchangedZdisappearedrzNo config updates to processes)	rÚdictÚzipr¤rÃÚkeysrÍr*rb)
r3Zadded_changed_dropped_tupleÚaddedr,ZdroppedZ
changedictÚnrrÅrZr r r!Ú_formatChangess
þ z&DefaultControllerPlugin._formatChangescCsrt|d|d}d|i}|dr,d|d<nd|d<|drFd|d<nd|d<d	|d
|df|d<d
}||S)Nr±rZZinusezin useZavailZ	autostartÚautoZmanualr·Z
group_prioZprocess_prioZpriorityz4%(name)-32s %(inuse)-9s %(autostart)-9s %(priority)sr	)r3Ú
configinforZZ	formattedrër r r!Ú_formatConfigInfo"s

ÿ
z)DefaultControllerPlugin._formatConfigInfoc
Csª|r&|j d¡tj|j_| ¡dS|j ¡}z| ¡}WnLtj	k
r}z,tj|j_|j
tjj
krv|j d¡nW5d}~XYnX|D]}|j | |¡¡qdS)Nz!Error: avail accepts no argumentsúERROR: supervisor shutting down)r*rbrrrRÚ
help_availrZgetAllConfigInforrrrrwr%r5)r3rDrr4rZpinfor r r!Údo_avail3s


z DefaultControllerPlugin.do_availcCs|j d¡dS)Nz(avail			Display all configured processesrír9r r r!r7Gsz"DefaultControllerPlugin.help_availc
Cs¾|r&|j d¡tj|j_| ¡dS|j ¡}z| ¡}Wnntj	k
rª}zNtj|j_|j
tjj
krv|j d¡n$|j
tjjkr|j d|j¡nW5d}~XYnX| |d¡dS)Nz"Error: reread accepts no argumentsr6z	ERROR: %sr)r*rbrrrRÚhelp_rereadrÚreloadConfigrrrrrwr%ZCANT_REREADrr2)r3rDrr
rr r r!Ú	do_rereadJs 


z!DefaultControllerPlugin.do_rereadcCs|j d¡dS)NzDreread 			Reload the daemon's configuration files without add/removerír9r r r!r9_sz#DefaultControllerPlugin.help_rereadcCsÜ| ¡}|j ¡}|D]À}z| |¡Wntjk
rÄ}z||jtjj	krb|j 
d¡tj|j_
nR|jtjjkr~|j 
d¡n6|jtjjkr¨|j 
d|¡tj|j_
ntj|j_
W5d}~XYqX|j 
d|¡qdS)NzERROR: shutting downz#ERROR: process group already activeú ERROR: no such process/group: %sz%s: added process group)r£r*rÚaddProcessGrouprrrrrwr%rbrrrRZ
ALREADY_ADDEDrè©r3rDrÅrrZrr r r!Údo_addbs"

zDefaultControllerPlugin.do_addcCs|j d¡dS)NzBadd <name> [...]	Activates any updates in config for process/grouprír9r r r!Úhelp_addxsz DefaultControllerPlugin.help_addcCs°| ¡}|j ¡}|D]}z| |¡Wnptjk
r}zPtj|j_|j	t
jjkrf|j 
d|¡n"|j	t
jjkr|j 
d|¡nW5d}~XYqX|j 
d|¡qdS)Nz&ERROR: process/group still running: %sr<z%s: removed process group)r£r*rÚremoveProcessGrouprrrrrRrrrwZ
STILL_RUNNINGrbrèr>r r r!Ú	do_remove|s

ÿz!DefaultControllerPlugin.do_removecCs|j d¡dS)Nz<remove <name> [...]	Removes process/group from active configrír9r r r!Úhelp_removesz#DefaultControllerPlugin.help_removec
sfdd}j ¡}z| ¡}WnTtjk
rv}z4tjj_|jt	j
jkrdj d¡WY¢
dSW5d}~XYnX|d\}}}t
| ¡}	d|	kr t
}	|	rüt
}
| ¡D]}|
 |d¡q²|
 |¡|	D]&}||
krԈj d|¡tjj_qÔ|D]x}|	r||	krq| |¡}
||dd	d
|
D}|rbj d|df¡tjj_q| |¡||d
q|D]L}|	r||	krq~| |¡||d| |¡| |¡||dq~|D].}|	rè||	krèqÐ| |¡||dqÐdS)Ncsj d||f¡dS)Nrrí)rZrr9r r!Úlogsz.DefaultControllerPlugin.do_update.<locals>.logr$rrûr±zERROR: no such group: %srcSs g|]}|dtjjkr|qS)rn)rrwrç)r®Úresr r r!r°¾sÿz5DefaultControllerPlugin.do_update.<locals>.<listcomp>rzhas problems; not removingzremoved process groupzupdated process groupzadded process group)r*rr:rrrrrRrrrwr%rbÚsetr£r¹rrrrAr=)r3rDrDrr
rr0r,ZremovedZvalid_gnamesrµr¶ZgnamerZfailsr r9r!Ú	do_updates`












z!DefaultControllerPlugin.do_updatecCs(|j d¡|j d¡|j d¡dS)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 groupsrír9r r r!Úhelp_update×sz#DefaultControllerPlugin.help_updatecCsvt|d|d}|d}d}|tjjkr6||dfS|tjjkrN||dfS|tjjkrbd|Std||fdS)	Nr±rZrnrárZfailedú%s: clearedr)r
rrwrèrçrrrr r r!Ú_clearresultÜsz$DefaultControllerPlugin._clearresultcCs |j ¡sdS| ¡}|s<|j d¡tj|j_| ¡dS|j ¡}d|kr| 	¡}|D]&}|j | 
|¡¡|j |d¡qZn|D]}t|\}}z| 
|¡WnXtjk
rþ}	z8|	j|||	jd}
|j | 
|
¡¡|j |
d¡W5d}	~	XYqXt||}|j d|¡qdS)Nz$Error: clear requires a process namerûrnrrI)r*rr£rbrrrRÚ
help_clearrZclearAllProcessLogsrJryrZclearProcessLogsrrrrr
rr r r!Údo_clearès8


ý"
z DefaultControllerPlugin.do_clearcCs(|j d¡|j d¡|j d¡dS)Nz)clear <name>		Clear a process' log files.z5clear <name> <name>	Clear multiple process' log filesz'clear all		Clear all process' log filesrír9r r r!rKs
ÿz"DefaultControllerPlugin.help_clearcCs`| ¡}t |¡}|ddkr8|j d¡tj|j_dS||jj_|jj}| 	d¡||j_dS)Nr)ZunixZhttpz%ERROR: url must be http:// or unix://re)
r¡rr*rbrrrRr.r;r)r3rDZurlÚpartsZold_exitstatusr r r!Údo_opens



zDefaultControllerPlugin.do_opencCs|j d¡|j d¡dS)Nz3open <url>	Connect to a remote supervisord process.z3		(for UNIX domain socket, use unix:///socket/path)rír9r r r!Ú	help_opensz!DefaultControllerPlugin.help_opencCsR|r&|j d¡tj|j_| ¡dS|j ¡s4dS|j ¡}|j | ¡¡dS)Nz#Error: version accepts no arguments)	r*rbrrrRÚhelp_versionrrZgetSupervisorVersion)r3rDrr r r!Ú
do_version"s


z"DefaultControllerPlugin.do_versioncCs|j d¡dS)Nz<version			Show the version of the remote supervisord processrír9r r r!rP.sÿz$DefaultControllerPlugin.help_versionc	
CsL|j ¡sdS| ¡}|s<|j d¡tj|j_| ¡dSt|dkrb|j d¡tj|j_dS|d}|j 	¡}z| 
|¡}Wndtjk
ræ}zD|j
tjjkr¼|j d¡tj|j_n|j dt|¡WY¢dSd}~XYnX|dtjjkr|j d¡tj|j_dS|j d	¡d}zît||j}| ¡td
}z| ||¡Wnttjk
rÈ}zR|j
tjjkr|j d¡n|j dt|¡|j d¡| ¡WY¢WdSd}~XYnX| 
|¡}|dtjjkr:|j d¡|j d¡| ¡WdSq:Wn4ttfk
rF|j d¡|rB| ¡YnXdS)
NzERROR: no process name suppliedrz&ERROR: too many process names suppliedrz ERROR: bad process name suppliedzERROR: r©zERROR: process not runningrØrzProcess got killedzExiting foreground)r*rr£rbrrrRÚhelp_fgr¤rrrrrrrwrèr÷r
Z
ProcessStatesZRUNNINGr$r8rZsendProcessStdinrrHrtÚEOFError)	r3rDrÅrZrr¶rr`Zinpr r r!Údo_fg3sf






zDefaultControllerPlugin.do_fgcCs|j d¡|j d¡dS)Nz4fg <process>	Connect to a process in foreground modez		Ctrl-C to exitrí)r3rur r r!rRuszDefaultControllerPlugin.help_fg)r)N)7rrrrZr,rÚrìrärðrïrñròZdo_exitrórúrrrrrrrrrrrr rr"r!r(r)r+r*r2r5r8r7r;r9r?r@rBrCrGrHrJrLrKrNrOrQrPrTrRr r r r!r×ÂshS
3+1
16	D#
Br×cCsh|dkrt}|j|tdt|}|jrH| d |j¡¡t |j	¡|j
rd| ||¡t d¡dS)N)rÏrr)rZrealizerIrJrur}Újoinr>ÚexitrRr{rv)rur.Úcr r r!ÚmainzsrXÚ__main__)NN)*rIrSrr|rr>r%Zsupervisor.compatrrrrrZsupervisor.medusarr<Zsupervisor.optionsrr
rrrr
rrr"rwr	r
rrxr&r$rTrJrÇrÈrÕrÖr×rXrr r r r!Ú<module>sV	þ7
5?
doctorondemand / supervisor python

Products

About

Resources

Contact Gemfury
