Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
doctorondemand
doctorondemand / supervisor python
Repository URL to install this package:
|
Version:
4.2.1 ▾
|
U
B]¿T ã @ s¢ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlmZ d dlmZ d dlmZmZ d dlmZ d dlmZ d dlmZ d dlmZ d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m!Z! d dl m"Z" d dl m#Z# d dl m$Z$ d dl m%Z% d dl m&Z& d dl m'Z' d dl m(Z( d dl m)Z) d dl m*Z* d dl m+Z+ d dl m,Z, d dl m-Z- d dl m.Z. d dl m/Z/ d d l m0Z0 d d l m1Z1 d d l m2Z2 d d l m3Z3 d d l4m5Z5 d d!l4m6Z6 d d"l4m7Z7 d d#l4m8Z8 d$d% Z9e9 Z:d&d' Z;G d(d) d)Z<G d*d+ d+Z=G d,d- d-e=Z>G d.d/ d/e=Z?g Z@G d0d1 d1ejAZBG d2d3 d3eCZDG d4d5 d5eDZEG d6d7 d7eEZFG d8d9 d9eEZGG d:d; d;eDZHG d<d= d=eDZIG d>d? d?eHZJd@dA ZKdBdC ZLdDdE ZMdaNdFdG ZOdHdI ZPG dJdK dKZQdLdM ZRdNdO ZSdPdQ ZTG dRdS dSeUZVG dTdU dUeVZWG dVdW dWeVZXG dXdY dYeVZYG dZd[ d[eVZZdS )\é N)ÚPY2)Ú ConfigParser)Úas_bytesÚ as_string)Ú xmlrpclib)ÚStringIO)Ú
basestring)Ú asyncore_25)Úprocess_or_group_name)Úboolean)Úinteger)Ú name_to_uid)Ú gid_for_uid)Úexisting_dirpath)Ú byte_size)Ú
signal_number)Úlist_of_exitcodes)Údict_of_key_value_pairs)Ú logfile_name)Úlist_of_strings)Ú
octal_type)Úexisting_directory)Ú
logging_level)Úcolon_separated_user_group)Ú inet_address)ÚInetStreamSocketConfig)ÚUnixStreamSocketConfig)Úurl)Ú Automatic)Ú auto_restart)Úprofile_options)Úloggers)Ústates)Úxmlrpc)Úpollerc
C sP t j t j t¡¡} t j | d¡}t|d}| ¡ ¡ W 5 Q R £ S Q R X d S )Nz version.txtÚr) ÚosÚpathÚabspathÚdirnameÚ__file__ÚjoinÚopenÚreadÚstrip)ZmydirZ version_txtÚf© r0 ú!./build/lib/supervisor/options.pyÚ_read_version_txt9 s r2 c C s t j t j t j | ¡¡¡S ©N)r& r' Únormpathr( Ú
expanduser)Úvr0 r0 r1 Únormalize_path@ s r7 c @ s e Zd ZdS )ÚDummyN)Ú__name__Ú
__module__Ú __qualname__r0 r0 r0 r1 r8 C s r8 c @ sº e Zd ZejZejZejZeZd ZZ ej
d Z dZ dZ
dZdZdZd ddZdd Zdd Zd
d Zd d d
Zdd Zd!ddZd"ddZdd Zdd Zd#ddZdd Z d d Z dS )$ÚOptionsNr Tc C sÌ g | _ g | _g | _i | _i | _i | _i | _i | _|| _| dddd| j
¡ | dddd¡ t j
t j
tjd ¡¡}t j |dd ¡t j |d ¡d d
d d g}|| _i | _t j ¡ D ]\}}|| jd
| < q°dS )znConstructor.
Params:
require_configfile -- whether we should fail on no config file.
NÚhÚhelpÚ
configfilezc:zconfiguration=r Úetczsupervisord.confzetc/supervisord.confz/etc/supervisord.confz /etc/supervisor/supervisord.confzENV_%s)Ú
names_listÚ
short_optionsÚ long_optionsÚ options_mapÚ default_mapÚ required_mapÚ environ_mapÚattr_prioritiesÚrequire_configfileÚaddr> r& r' r) ÚsysÚargvr+ Ú searchpathsÚenviron_expansionsÚenvironÚitems)ÚselfrI ÚhererM Úkr6 r0 r0 r1 Ú__init__X s. ûzOptions.__init__c C sL d}| j D ]}tj |¡r
|} q$q
|dkrH| jrH| dd | j ¡ ¡ |S )z=Return the name of the found config file or print usage/exit.NzjNo config file found at default paths (%s); use the -c option to specify a config file at a different pathú, )rM r& r' ÚexistsrI Úusager+ )rQ Úconfigr' r0 r0 r1 Údefault_configfilex s
þzOptions.default_configfilec C s@ | j d }| d¡dkr&| d| j¡}| j |¡ | d¡ dS )zxPrint a long help message to stdout and exit(0).
Occurrences of "%s" in are replaced by self.progname.
Ú
z%sr N)ÚdocÚfindÚreplaceÚprognameÚstdoutÚwriteÚexit)rQ Údummyr> r0 r0 r1 r>
s
z Options.helpc C s4 | j dt| ¡ | j d| j ¡ | d¡ dS )z2Print a brief error message to stderr and exit(2).z
Error: %s
zFor help, use %s -h
é N)Ústderrr` Ústrr^ ra ©rQ Úmsgr0 r0 r1 rW s z
Options.usagec
C sæ |dk r`|dk rt d|s(|s(t d|r>| d¡r>t d|rT| d¡rTt d|fdd}|r|r| d¡| d¡krt d||f |r|d d
kr¦t d |dd
|d d
}
} | d
krÐt dd
|
}
|
| jkrît d|
||f| j|
< | j |¡ |r||d d
kr$t d|}
|
d dkrB|
dd
}
d|
}
|
| jkrbt d|
||f| j|
< | j |¡ | r||f| j| < |rât| |s®t| |d | j ||f¡ |dk rÒ|| j
|< |râ|| j |< dS )a Add information about a configuration option.
This can take several forms:
add(name, confname)
Configuration option 'confname' maps to attribute 'name'
add(name, None, short, long)
Command line option '-short' or '--long' maps to 'name'
add(None, None, short, long, handler)
Command line option calls handler
add(name, None, short, long, handler)
Assign handler return value to attribute 'name'
In addition, one of the following keyword arguments may be given:
default=... -- if not None, the default value
required=... -- if nonempty, an error message if no value provided
flag=... -- if not None, flag value for command line option
env=... -- if not None, name of environment variable that
overrides the configuration file or default
Nz%use at most one of flag= and handler=z"flag= requires a command line flagú:ú=c S s |S r3 r0 )ÚargÚflagr0 r0 r1 Ú<lambda>¿ ó z Options.add.<locals>.<lambda>z&inconsistent short/long options: %r %rr ú-z&short option should not start with '-'é )Ú rh z"short option should be 'x' or 'x:'z duplicate short option key '%s'z%long option should not start with '-'éÿÿÿÿz--z duplicate long option key '%s') Ú
ValueErrorÚendswithrD rB ÚappendrC rG ÚhasattrÚsetattrrA rE rF ) rQ ÚnameÚconfnameZshortZlongÚhandlerÚdefaultZrequiredrk ÚenvÚkeyÚrestr0 r0 r1 rJ s` ÿ
z Options.addc C s0 | j |d¡}||kr,t| || || j |< d S )Nrq )rH Úgetrv )rQ ÚattrÚvalueZprioZcurrentr0 r0 r1 Ú_setê s z Options._setc
C sT |dkrt jdd
}|dkr(t jd }|dkrXzddl}|j}W n tk
rV Y nX || _|| _g | _g | _z$t |d
| j ¡| j ¡\| _| _W n2 t j
k
rÆ } z| t|¡ W 5 d}~X Y nX | jrè| jsè| dt| j ¡ | jD ]\}}| j| \}} | dk rTz | |}W n8 tk
rR }
z| d|||
f ¡ W 5 d}
~
X Y nX |rî|dk rît| |dk r~| d| ¡ | ||d¡ qî| j ¡ D ]} | j| \}} | tjkrtj| } | dk rz | | } W n8 tk
r }
z| d | | |
f ¡ W 5 d}
~
X Y nX |r| dk r| || d¡ q| jdkrH| ¡ | _| ¡ dS )
zôRealize a configuration.
Optional arguments:
args -- the command line arguments, less the program name
(default is sys.argv[1:])
doc -- usage message (default is __main__.__doc__)
Nro r rp z*positional arguments are not supported: %szinvalid value for %s %r: %sz"conflicting command line option %rrc z'invalid environment value for %s %r: %s) rK rL Ú__main__Ú__doc__Ú Exceptionr^ r[ ÚoptionsÚargsÚgetoptr+ rB rC ÚerrorrW re Úpositional_args_allowedrD rr Úgetattrr rG Úkeysr& rO r? rY Úprocess_config)
rQ r r[ r^ r ÚexcÚoptrj rw ry rg Zenvvarr r0 r0 r1 Úrealizeð sf
ÿ
&
ÿ
zOptions.realizec C sÀ | j r| |¡ | jD ]J\}}|r| d¡}| j}|D ]}|dkrF qRt||}q6| ||d¡ q| j ¡ D ]"\}}t| |dkrlt | || ql| j
¡ D ] \}}t| |dkr| |¡ qdS )z}Process configuration data structure.
This includes reading config file if necessary, setting defaults etc.
Ú.Nr ) r? Úprocess_config_filerA ÚsplitÚ
configrootr r rE rP rv rF rW ) rQ Údo_usagerw rx ÚpartsÚobjÚpartr Úmessager0 r0 r1 r 6 s"
zOptions.process_configc
C sx t | jds$tj tj | j¡¡| _z| | j¡ W n> tk
rr } z |rZ| t
|¡ nt|W 5 d }~X Y nX d S )Nr- ) ru r? r& r' r( r) rR Ú read_configrr rW re )rQ r rg r0 r0 r1 r U s zOptions.process_config_filec C s t j |¡S r3 )r& r' rV ©rQ r' r0 r0 r1 rV c s zOptions.existsr% c C s
t ||S r3 )r, )rQ ÚfnÚmoder0 r0 r1 r, f s z Options.openc C sÈ g }| ¡ D ]¶}| |¡s q | dd¡d }| ||d ¡}|d krRtd||f z| |¡}W n$ tk
r td||f Y nX i } | |¡D ] }
|
|kr| ||
¡| |
< q| ||| f¡ q |S )Nrh ro z"section [%s] does not specify a %sú!%s cannot be resolved within [%s]) ÚsectionsÚ
startswithr Úsanegetrr Ú import_specÚ ImportErrorr
rt ) rQ ÚparserZ factory_keyZsection_prefixZ factoriesÚsectionrw Z factory_specÚfactoryZextrasrS r0 r0 r1 Ú get_pluginsi s.
ÿ ÿzOptions.get_pluginsc C s0 t j d| ¡}t|dr"| ¡ S | d¡S d S )Nzx=ÚresolveF)Ú
pkg_resourcesZ
EntryPointÚparseru r§ Úload)rQ ÚspecZepr0 r0 r1 r¡ s
zOptions.import_spec)T) NNNNNNNNN)NNN)T)r% ) r9 r: r; rK rd r_ ra ÚwarningsÚuidÚgidrL r^ r? Z schemadirr rR r rT rY r> rW rJ r r r r rV r, r¦ r¡ r0 r0 r0 r1 r< F sB
÷
T
F
r< c @ s e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZejjZdd Zdd Zdd Zd
d Zd d
ZduddZdd Zdd Zdd ZdvddZ dwddZ dd Z d d Z d d Z d!d" Z!d#d$ Z"d%d& Z#d'd( Z$d)d* Z%d+d, Z&d-d. Z'd/d0 Z(d1d2 Z)d3d4 Z*d5d6 Z+d7d8 Z,d9d: Z-d;d< Z.d=d> Z/d?d@ Z0dAdB Z1dCdD Z2dEdF Z3dGdH Z4dIdJ Z5dKdL Z6dMdN Z7dOdP Z8dQdR Z9dSdT Z:dUdV Z;dWdX Z<dYdZ Z=d[d\ Z>d]d^ Z?d_d` Z@dadb ZAdcdd ZBdedf ZCdgdh ZDdidj ZEdkdl ZFdmdn ZGdxdodpZHdqdr ZIdsdt ZJdS )yÚ
ServerOptionsNr0 Fc C sÀ t | ¡ t | _t | j_| d d dd| j¡ | jddddddd | d d
d d ¡ | jd
dddtdd | ddddt¡ | jddddt dd | jd d d d t
d d | jd!d"d#d$t d%d | jd&d'd(d)t d*d | jd+d,d-d.t d/d | jd0d1d2d3t
d4d | jd5d6d7d8tt ¡ d | jd9d:d;d<td=d | jd>d?d@dAtdBd | jdCdDdEdCddd | jdFdGdHdFddd | jdIdJd@dKtd d i | _g | _g | _g | _g | _t | _t | ¡| _d S )LNr6 ÚversionÚnodaemonzsupervisord.nodaemonÚnro r ©rk rz Úuserzsupervisord.userúu:zuser=Úumaskzsupervisord.umaskzm:zumask=Ú022©rz Ú directoryzsupervisord.directoryzd:z
directory=Úlogfilezsupervisord.logfilezl:zlogfile=úsupervisord.logÚlogfile_maxbytesz supervisord.logfile_maxbyteszy:zlogfile_maxbytes=i Úlogfile_backupszsupervisord.logfile_backupszz:zlogfile_backups=é
Úloglevelzsupervisord.loglevelze:z loglevel=ÚinfoÚpidfilezsupervisord.pidfilezj:zpidfile=úsupervisord.pidÚ
identifierzsupervisord.identifierzi:z identifier=Ú
supervisorÚ childlogdirzsupervisord.childlogdirzq:z childlogdir=Úminfdszsupervisord.minfdsza:zminfds=é Úminprocszsupervisord.minprocsrp z minprocs=éÈ Ú nocleanupzsupervisord.nocleanuprS Ú
strip_ansizsupervisord.strip_ansiÚtr zsupervisord.profile_optionszprofile_options=)r< rT r8 r Ú supervisordrJ r° r r r r r r re ÚtempfileÚ
gettempdirÚintr Z
pidhistoryÚprocess_group_configsÚparse_criticalsÚparse_warningsÚ parse_infosÚSignalReceiverÚsignal_receiverr$ ZPoller©rQ r0 r0 r1 rT s¨
ÿ ÿ ÿ ÿ þ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿ ÿzServerOptions.__init__c C s | j dt ¡ | d¡ dS )z-Print version to stdout and exit(0).
ú%s
r N)r_ r` ÚVERSIONra )rQ rb r0 r0 r1 r° Ê s zServerOptions.versionc O s t j||S r3 )r! Ú getLogger©rQ r Úkwargsr0 r0 r1 rÚ Ñ s zServerOptions.getLoggerc C s" t ¡ dkr| j d¡ t | ¡S )Nr a Supervisord is running as root and it is searching for its configuration file in default locations (including its current working directory); you probably want to specify a "-c" argument specifying an absolute path to a configuration file for improved security.)r& Úgetuidr¬ Úwarnr< rY r× r0 r0 r1 rY Ô s
ÿz ServerOptions.default_configfilec
O sT t j| f|| | jj}| jd k rpzt| j}W n, tk
r^ } z| |¡ W 5 d }~X Y nX || _t || _
| j s~|j | _ | j r| j }n|j }t
|| _ | jrª| j}n|j}t
|| _|j| _d | _|j | _}dd |D D ]} | d }
d|
| _ qþqâ| jd krHdd |D D ].} | d } | d } | s6d} d | | f | _q|j| _d S )
Nc S s g | ]}|d t jkr|qS ©Úfamily)ÚsocketÚAF_UNIX©Ú.0rX r0 r0 r1 Ú
<listcomp> s ÿz)ServerOptions.realize.<locals>.<listcomp>Úfileú unix://%sc S s g | ]}|d t jkr|qS rß )rá ÚAF_INETrã r0 r0 r1 rå s ÿÚhostÚportZ localhostz http://%s:%s)r< r r rÍ r´ r
rr rW r r r® r¿ rº r7 rÁ Úrpcinterface_factoriesÚ serverurlÚserver_configsrà )
rQ rj Úkwr¤ r rg rº rÁ ZsconfigsrX r' ré rê r0 r0 r1 r à sD
zServerOptions.realizeTc C s" t j| |d | jjj}|| _d S )N)r )r< r r rÍ rÑ )rQ r Únewr0 r0 r1 r s
z ServerOptions.process_configc s g | _ g | _g | _| jj}d}t|dsx| |¡s>td| z| |d¡}d}W n$ t t
fk
rv td| Y nX t | j _
zhz2z |¡ W n tk
r¶ |¡ Y nX W n0 tjk
rê } ztt|W 5 d }~X Y nX W 5 |rü| ¡ X t ¡ }| j|d}| | j ¡ d¡rN | j¡ dd ¡sLtd
dd ¡}t ||d }| ¡ }t|d rt j !t j "|j#¡¡}nd
}|D ]´} t j $|| ¡} t% %| ¡}
|
sÎ| j &d| ¡ qt'|
D ]r} | j &d| ¡ z (| ¡ W n2 tjk
r* } ztt|W 5 d }~X Y n X t j "t j !| ¡¡¡ qq )¡ } d| krhtdd| ji fdd}
t*|
dd|_+t*|
dd|_,|
dd }|d kr¼d |_-n
t.||_-|
dd |_/t0|
dd |_1t2|
d d |_3t4|
d d |_5t*|
d!d"|_6t7|
d#d$|_8t2|
d%d&|_9|
d'd(|_:t;|
d)d*|_<t= >¡ }t.|
d+||_?t;|
d,d*|_@t;|
d-d*|_A|
d.d/}t ||d.}tB||_C| Dd0d1¡|_E| F¡|_G|jGD ]0}|jHD ]"}|jC I¡ }| |jC¡ ||_CqҐqÈ| J¡|_Kd |_L|S )2NFr- ú could not find config file %sr% Tú could not read config file %s)rR Úhost_node_nameZincludeÚfilesz5.ini file has [include] section, but no files settingz
include.filesrw r z No file matches via include "%s"z'Included extra file "%s" during parsingrÍ z..ini file does not include supervisord sectionrR c s. | di ¡}| ¡ ||d< j| |f|S ©NÚ
expansions)r~ ÚupdateÚ
getdefault)r rz rÜ rõ ©Zcommon_expansionsr£ r0 r1 r~ i s
z&ServerOptions.read_config.<locals>.getrÆ rÇ rÈ rÉ r¹ r´ r¶ r· rº r» r¼ Ú50MBr½ r¾ r¿ rÀ rÁ r rà rÄ r± ÚfalserÅ rÊ rË Ú environmentrp z supervisor.rpcinterface_factoryz
rpcinterface:)MrÒ rÓ rÔ r rÍ ru rV rr r, ÚIOErrorÚOSErrorÚUnhosedConfigParserrN rõ ÚcloseÚ read_fileÚAttributeErrorÚreadfpr Z ParsingErrorre ÚplatformÚnoderR rö Z has_sectionÚ expand_hereZ
has_optionr~ Úexpandr r& r' r) r( rw r+ Úglobrt Úsortedr- 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ë Úprocess_groups_from_parserrÑ Úprocess_configsÚcopyÚserver_configs_from_parserrí r )rQ Úfpr¤ Ú
need_closeÚwhyrò rõ ró ÚbaseÚpatternÚ filenamesÚfilenamer r~ r¹ ZtempdirZ environ_strÚgroupÚprocr{ r0 rø r1 r " sÆ
"
ÿ
ÿ ÿ ÿ
ý
zServerOptions.read_configc " sæ g } ¡ }g }d| ji fdd}|D ]ê}| d¡s<q,t| dd¡d }t||dd }t||dd } g }
|D ]} d
| } d | }
| |kr¬|
|kr¬td || f | |krÌ|
|krÌtd
|| f | |krØ| n|
}| |¡ | ||t
¡}|
|¡ qx| t | || |
¡ q,|D ]h}| d¡r ||kr:q t| dd¡d }t||dd } | ||t
¡}| t | || |¡ q |D ]n}| d¡s q| dd¡d }t||dd} t||dd}|dk rêtd||f ||dd}z|
|¡}W n& tk
r* td||f Y nX dd t||ddD }t|}|s`td| d d lm} g }|D ]6}t||d }|d krtd ||f | |¡ qtt||d d }|rÎtd!| | ||t¡}| t| || ||||¡ q|D ]Ö}| d"¡r ||kr q t| dd¡d }t||dd } d#|i}||d$d }|d krhd }nt|}||d%d } | d k r®t| } | dk s¢| d&kr®td'| ||d(d } | d k rôz t| } W n" tk
rò td)| Y nX ||d*d } | d k r>z t| } W n& ttfk
r< td+| Y nX ||d,d |d-} | s`td.| z| | || | | ¡} W n8 tk
r® }! ztd/t|!|f W 5 d }!~!X Y nX | ||t ¡}| t | || || ¡ q | ¡ |S )0NrR c s0 | di ¡}| ¡ ||d< j| ||f|S rô ©r~ rö r )r¤ r rz rÜ rõ rø r0 r1 r~ ¡ s
z5ServerOptions.process_groups_from_parser.<locals>.getzgroup:rh ro ÚprogramsÚpriorityéç z
program:%szfcgi-program:%sz-[%s] names unknown program or fcgi-program %sz>[%s] name %s is ambiguous (exists as program and fcgi-program)zprogram:zeventlistener:rq Ú buffer_sizer¾ z*[%s] section sets invalid buffer_size (%d)Úresult_handlerz&supervisor.dispatchers:default_handlerr c S s g | ] }| ¡ qS r0 )Úupper)rä Úxr0 r0 r1 rå ç s z<ServerOptions.process_groups_from_parser.<locals>.<listcomp>Úeventsrp z&[%s] section requires an "events" liner )Ú
EventTypesz$Unknown event type %s in [%s] eventsÚredirect_stderrrú zx[%s] section sets redirect_stderr=true but this is not allowed because it will interfere with the eventlistener protocolz
fcgi-program:Ú program_namer´ Úsocket_backlogéÿÿ z Invalid socket_backlog value %sÚ socket_ownerz Invalid socket_owner value %sÚ socket_modez Invalid socket_mode value %srá ©rõ z%[%s] section requires a "socket" linez%s in [%s] socket) r rR r r
r r r rr rt Úprocesses_from_sectionÚ
ProcessConfigÚextendÚProcessGroupConfigr¡ r¢ ÚsetZsupervisor.eventsr r r ÚEventListenerConfigÚEventListenerPoolConfigr
r r Ú TypeErrorÚparse_fcgi_socketre ÚFastCGIProcessConfigÚFastCGIGroupConfigÚsort)"rQ r£ ÚgroupsZ all_sectionsZhomogeneous_excluder~ r¤ Ú
group_namer r Zgroup_processesZprogramZprogram_sectionZ fcgi_sectionZ processesr! Z pool_namer r Zpool_event_namesr Ú pool_eventsZpool_event_nameZ
pool_eventr Zfcgi_expansionsZ proc_userÚproc_uidr" r$ r% rá Ú
socket_configÚer0 rø r1 r s<
ÿÿÿ
ÿ ÿ ÿ
ÿ ÿ
ÿÿ ÿÿÿ
ÿþ
ÿ
þÿ
ÿ
ÿ
ÿ
ÿ ÿ þ&
ÿ
ÿÿz(ServerOptions.process_groups_from_parserc C sØ | d¡r||dd
}tj |¡s,td|t|}|d kr`t ¡ }|d k r`||kr`|t|f}|d krld}t||||dS |d k s|d k rtdt
d|¡}|rÊ| d¡} t | d ¡}
t
| |
|d
S td |d S ) Núunix://é z+Unix socket path %s is not an absolute pathéÀ )Úownerr ÚbacklogzQsocket_owner and socket_mode params should only be used with a Unix domain socketztcp://([^\s:]+):(\d+)$ro rc )r= zBad socket format %s)r r& r' Úisabsrr r7 rÝ r r ÚreÚmatchr rÐ r ) rQ Zsockr6 r$ r% r" r' r Úmré rê r0 r0 r1 r/ D s6
ÿ þ
ÿz ServerOptions.parse_fcgi_socketc
C s\ z| ||||¡W S tk
rV } z&|j || j¡}td|||f W 5 d }~X Y nX d S )Nz%s in section %r (file: %r))Ú_processes_from_sectionrr Úsection_to_filer~ r? )rQ r£ r¤ r4 Úklassr8 r r0 r0 r1 r' g s ÿÿz$ServerOptions.processes_from_sectionc 0 " s |d kr t }g }t| dd¡d }t ¡ }| j|||d fdd}t||dd} t||dd }
t||d
d } t||d d} t||d
d}
t ||dd}t||dd}t||dd}t||d|}t
||dd}t||dd}t||dd}t||dd}||d d d d }t ||d d}t||d!d}t ||d"d}t||d#d}||d$d }|r| ¡
¡ d%krd }||d&d } | d kr®d } nt| } ||d'd } | d k rÔt| } t||d(d)d d } |dkrd*| krtd+|r|std,t||| D ]Þ} }!|! d-| i¡ |! | j¡ tt||!d }"||d.d }#i }$d/D ]Æ}%d0|% }&|||&t}'t|'trt|'|!|&}'t|'}'|'|$|&< d1|% }(t|||(d})|)|$|(< d2|% }*t |||*d3}+|+|$|*< d4|% },t|||,d }-|-|$|,< |'tkrn|+sn| j d5||&f ¡ qn|rf|$d6 td fkr^| j d7| ¡ d |$d6< ||d8d |!d9}.|.d krtd:| || t| |!d(|.|#| | |
| | |
| |$d; |||$d< |$d= |$d> |$d6 |||$d? |$d@ |$dA |||||||"|dB }/| |/¡ q&| ¡ |S )CNrh ro )rR r! rò r4 c s2 | di ¡}| ¡ ||d< j| |f||S rô r )r¤ r r rÜ rõ rø r0 r1 r~ } s
z2ServerOptions._processes_from_section.<locals>.getr r Ú autostartÚtrueÚ autorestartZ
unexpectedÚ startsecsÚ startretriesé Ú
stopsignalZTERMÚ stopwaitsecsr¾ Ú stopasgrouprú Ú killasgroupÚ exitcodesÚ0r ÚnumprocsÚnumprocs_startr rû rp F)Ú do_expandÚstdout_capture_maxbytesÚstdout_events_enabledÚstderr_capture_maxbytesÚstderr_events_enabledrì ZAUTOr´ r¶ Ú process_namez%(program_name)sz%(process_num)zD%(process_num) must be present within process_name when numprocs > 1z1Cannot set stopasgroup=true and killasgroup=falseÚ process_numr¹ )r_ rd z
%s_logfilez%s_logfile_backupsz%s_logfile_maxbytesrù z %s_syslogztFor [%s], AUTO logging used for %s without rollover, set maxbytes > 0 to avoid filling up filesystem unintentionallyÚstderr_logfilezpFor [%s], redirect_stderr=true but stderr_logfile has also been set to a filename, the filename has been ignoredÚcommandr& z-program section %s does not specify a commandÚstdout_logfileÚstdout_logfile_backupsÚstdout_logfile_maxbytesÚ
stdout_syslogÚstderr_logfile_backupsÚstderr_logfile_maxbytesÚ
stderr_syslog) rw r[ r¹ r¶ r rE rG rH rI r r\ rT rU r] r^ r_ rZ rV rW r` ra rb rK rL rM rN rO r rû rì ) r( r
r r r rR r r r r r r r. r r
r rr Úrangerö rN r r r Ú
isinstancer r rÓ rt r2 )0rQ r£ r¤ r4 rD r r! rò r~ r rE rG rH rI rK rL rM rN rO r rQ rR Zenvironment_strZstdout_cmaxbytesZ
stdout_eventsZstderr_cmaxbytesZ
stderr_eventsrì r´ r r¶ rX rY rõ rû r¹ ZlogfilesrS r² Zlf_valZbu_keyÚbackupsZmb_keyÚmaxbytesZsy_keyZsyslogr[ Zpconfigr0 rø r1 rB q s ý
ÿ
ÿ ÿ
ÿ þÿþÿ
ÿ
á!z%ServerOptions._processes_from_sectionc C sT g }| ¡ D ]B}| |¡r | dd¡}t|dkr<|d }nd }| ||f¡ q |S )Nrh ro )r r r Úlenrt )rQ r£ Ústyper
r¤ r rw r0 r0 r1 Ú_parse_servernames s
z ServerOptions._parse_servernamesc C sT |j }||dd }||dd }|d k s.|d k rJ|d ks>|d krJtd| ||dS )NÚusernameÚpasswordzSection [%s] contains incomplete authentication: If a username or a password is specified, both the username and password must be specified)rj rk )r rr )rQ r£ r¤ r~ rj rk r0 r0 r1 Ú _parse_username_and_password s þÿz*ServerOptions._parse_username_and_passwordc
C sä g }| |d¡}|D ]\}}i }|j}| | ||¡¡ ||d< tj|d< ||dd }|d krjtd| t|\} }| |d< ||d< ||d< | |¡ q| |d¡}
|
D ]2\}}i }|j}||d d d
| j id } | d krètd | |
¡ } ||d< tj |d< t | |d < | | ||¡¡ ||d
d } | d k rhz t
| } W n" tk
rd td| Y nX nd} | |d
< ||dd }
|
d k rÀz t|
}
W n& ttfk
r¼ td|
Y nX nd}
|
|d< ||d< | |¡ qª|S )NZinet_http_serverrw rà rê z section [%s] has no port valueré r¤ Zunix_http_serverræ rR r& z section [%s] has no file valueÚchownzInvalid sockchown value %s)rq rq ÚchmodzInvalid chmod value %sr; )ri r rö rl rá rè rr r rt rR r. râ r7 r r r. )rQ r£ ZconfigsZinet_serverdefsrw r¤ rX r~ rê ré Zunix_serverdefsZsfilerm rn r0 r0 r1 r ' s^
z(ServerOptions.server_configs_from_parserc C s | j ¡ | ¡ | j ¡ d S r3 )r$ Zbefore_daemonizeÚ
_daemonizeZafter_daemonizer× r0 r0 r1 Ú daemonize\ s
zServerOptions.daemonizec
C s t ¡ }|dkr&| j d¡ t d¡ | j d¡ | jrzt | j¡ W n8 tk
r } z| j d| j|f ¡ W 5 d }~X Y nX | j d| j ¡ t
d¡ t d | _ t
_ t
_t
d¡ t dd | _ t
_t
_t
d ¡ t dd | _ t
_t
_t ¡ t | j¡ d S )
Nr z"supervisord forked; parent exitingz#daemonizing the supervisord processzcan't chdir into %r: %szset current directory: %rz /dev/nullro Úwrc )r& ÚforkÚloggerÚblatherÚ_exitrÀ r¹ Úchdirrý Úcriticalrÿ r, ÚstdinrK Ú __stdin__r_ Ú
__stdout__rd Ú
__stderr__Úsetsidr¶ )rQ ÚpidÚerrr0 r0 r1 ro a s.
ÿÿ
zServerOptions._daemonizec C sx t ¡ }z*t| jd}| d| ¡ W 5 Q R X W n* ttfk
r\ | j d| j ¡ Y nX d| _ | j
d| ¡ d S )Nrq rØ zcould not write pidfile %sTz supervisord started with pid %s) r& Úgetpidr, rÁ r` rü rý rs rw Úunlink_pidfilerÀ )rQ r} r/ r0 r0 r1 Ú
write_pidfile s zServerOptions.write_pidfilec C sV | j D ].\}}|d tjkr| jr|d }| |¡ q| jrH| | j¡ | j ¡ d S )Nrà ræ ) Ú httpserversrá râ Úunlink_socketfilesÚ _try_unlinkr rÁ r$ rÿ )rQ rX ÚserverZ
socketnamer0 r0 r1 Úcleanup s zServerOptions.cleanupc C s( zt |¡ W n tk
r" Y nX d S r3 )r& Úunlinkrý r r0 r0 r1 r ª s zServerOptions._try_unlinkc C sb g }| j D ]@\}}| ¡ | ¡ ¡ D ]"}t|dd }||kr&| |¡ q&q
|D ] }| ¡ qPd S )Nr
)r rÿ Úget_socket_mapÚvaluesr rt )rQ Zdispatcher_serversrX r
Ú
dispatcherZdispatcher_serverr0 r0 r1 Úclose_httpservers° s z ServerOptions.close_httpserversc C s | j ¡ d S r3 )rs rÿ r× r0 r0 r1 Ú close_loggerÇ s zServerOptions.close_loggerc C s` | j j}t tj|¡ t tj|¡ t tj|¡ t tj|¡ t tj|¡ t tj|¡ d S r3 ) rÖ ÚreceiveÚsignalÚSIGTERMÚSIGINTÚSIGQUITÚSIGHUPÚSIGCHLDÚSIGUSR2)rQ r r0 r0 r1 Ú
setsignalsÊ s zServerOptions.setsignalsc C s
| j ¡ S r3 )rÖ Ú
get_signalr× r0 r0 r1 r Ó s zServerOptions.get_signalc
C sÞ z| |¡| _d| _W n tjk
r¨ } zr|jd tjkrF| d¡ nRd}tj
|jd ¡}|d kr~| d||jd f ¡ n| d|||jd f ¡ W 5 d }~X Y n2 t k
rØ } z| |jd ¡ W 5 d }~X Y nX d S )NTr zAnother program is already listening on a port that one of our HTTP servers is configured to use. Shut this program down first before starting supervisord.z1Cannot open an HTTP server: socket.error reportedz%s %sz%s errno.%s (%d)) Úmake_http_serversr r rá r r ÚerrnoZ
EADDRINUSErW Z errorcoder~ rr )rQ rÍ r r> Z errornamer0 r0 r1 ÚopenhttpserversÖ s
ÿz ServerOptions.openhttpserversc C s$ d|||f }| j d|| jd}|S )Nz %s-%s---%s-z.log)ÚsuffixÚprefixÚdir)Ú
mktempfilerÅ )rQ rw rà Zchannelr rº r0 r0 r1 Úget_autochildlog_nameë s ýz#ServerOptions.get_autochildlog_namec
C sª | j }t d| j ¡}zt |¡}W n& ttfk
rJ | j d¡ Y d S X |D ]T}|
|¡rPtj ||¡}z|
|¡ W qP ttfk
r¢ | j d| ¡ Y qPX qPd S )Nz .+?---%s-\S+\.log\.{0,1}\d{0,4}z Could not clear childlog dirzFailed to clean up %r)rÅ r? Úcompilerà r& Úlistdirrü rý rs rÞ r@ r' r+ Úremove)rQ rÅ Zfnrer r Úpathnamer0 r0 r1 Úclear_autochildlogdiró s
z#ServerOptions.clear_autochildlogdirc C s t jS r3 )ÚasyncoreZ
socket_mapr× r0 r0 r1 r s z ServerOptions.get_socket_mapc C s> d}t || jD ](}zt |¡ W q tk
r6 Y qX qd S )Né )rc rÆ r& rÿ rý )rQ Ústartr r0 r0 r1 Ú cleanup_fds s zServerOptions.cleanup_fdsc C s t ||¡ d S r3 )r& Úkill)rQ r} r r0 r0 r1 r¨ s zServerOptions.killc
C s zt dt j¡\}}W nj tk
r } zL|jd }|tjtjfkrR| j d| ¡ |tjkrh| j
d¡ d\}}W 5 d }~X Y nX ||fS )Nrq r z:waitpid error %r; a process may not be cleaned up properlyzEINTR during reap)NN) r& ÚwaitpidÚWNOHANGrý r r ZECHILDÚEINTRrs rw rt )rQ r} Ústsr Úcoder0 r0 r1 r© s
ÿÿ
zServerOptions.waitpidc sN dkr dS z t }W nL tk
rd zt ¡}W n tk
rV d Y Y S X |d }Y n.X zt |¡}W n tk
r d| Y S X t ¡ }||kr¦dS |dkr²dS |d }ttd r|d fd
d t
¡ D }| d|¡ zt |¡ W n t
k
r Y d S X zt |¡ W n t
k
r> Y d
S X t |¡ dS )züDrop privileges to become the specified user, which may be a
username or uid. Called for supervisord startup and when spawning
subprocesses. Returns None on success or a string error message if
privileges could not be dropped.Nz No user specified to setuid to!zCan't find username %rrc zCan't find uid %rr z$Can't drop privilege as nonroot userrJ Ú setgroupsc s g | ]} |d kr|d qS )rJ rc r0 )rä Zgrprec©r´ r0 r1 rå R s
ÿ z1ServerOptions.drop_privileges.<locals>.<listcomp>z&Could not set groups of effective userz(Could not set group id of effective user)rÐ rr ÚpwdÚgetpwnamÚKeyErrorÚgetpwuidr& rÝ ru ÚgrpZgetgrallÚinsertr® rý ÚsetgidÚsetuid)rQ r´ r ZpwrecZ current_uidr® r3 r0 r¯ r1 Údrop_privileges, sB z ServerOptions.drop_privilegesc C sZ | j dkr$t ¡ dkrV| j d¡ n2| | j ¡}|dkrL| j d| j ¡ n
| |¡ dS )zµSet the uid of the supervisord process. Called during supervisord
startup only. No return value. Exits the process via usage() if
privileges could not be dropped.Nr zËSupervisor is running as root. Privileges were not dropped because no user is specified in the config file. If you intend to run as root, you can set user=root in the config file to avoid this message.z Set uid to user %s succeeded)r r& rÝ rÒ rt r¸ rÔ rW rf r0 r0 r1 Úset_uid_or_exite s
ÿz ServerOptions.set_uid_or_exitc
C sþ g }t tdr&| d| jtjdd¡ t tdrH| d| jtjdd¡ |D ]¬}|d }|d }|d }|d }|}t |¡\}}||k rL|d
krL||k r¦|d
kr¦|}z&t |||f¡ | j d t
¡ W qL tj t fk
rö |
|t
¡ Y qLX qLd S )
z¶Set the rlimits of the supervisord process. Called during
supervisord startup only. No return value. Exits the process via
usage() if any rlimits could not be set.Ú
RLIMIT_NOFILEa The minimum number of file descriptors required to run this process is %(min_limit)s as per the "minfds" command-line argument or config file setting. The current environment will only allow you to open %(hard)s file descriptors. Either raise the number of usable file descriptors in your environment (see README.rst) or lower the minfds setting in the config file to allow the process to start.)rg ÚminÚresourcerw Ú RLIMIT_NPROCa
The minimum number of available processes required to run this program is %(min_limit)s as per the "minprocs" command-line argument or config file setting. The current environment will only allow you to open %(hard)s processes. Either raise the number of usable processes in your environment (see README.rst) or lower the minprocs setting in the config file to allow the program to start.r» r¼ rg rw rq z)Increased %(name)s limit to %(min_limit)sN)ru r¼ rt rÆ rº rÈ r½ Z getrlimitZ setrlimitrÔ Úlocalsr rr rW ) rQ ZlimitsÚlimitZ min_limitÚresrg rw ZsoftZhardr0 r0 r1 Úset_rlimits_or_exitx sD
ôÿ
ôÿÿ
z!ServerOptions.set_rlimits_or_exitc C s d}t | j¡| _| jr&t | j|¡ t j| j| j|| j | j| j d | j
D ]}| j |¡ qP| j D ]}| j
|¡ qh| jD ]}| j |¡ qd S )Nz&%(asctime)s %(levelname)s %(message)s
)Zrotatingrf re )r! rÚ r¿ rs r± Z
handle_stdoutZ handle_filerº r¼ r½ rÒ rw rÓ rÞ rÔ rÀ )rQ Úformatrg r0 r0 r1 Ú make_logger´ s$ ú
zServerOptions.make_loggerc C s ddl m} || |S )Nr )r )Zsupervisor.httpr )rQ rÍ r r0 r0 r1 r É s z ServerOptions.make_http_serversc C s( zt |¡ W n tk
r" Y nX d S r3 )r& rÿ rý )rQ Úfdr0 r0 r1 Úclose_fdÍ s zServerOptions.close_fdc C s t ¡ S r3 )r& rr r× r0 r0 r1 rr Ó s zServerOptions.forkc C s t ||¡S r3 )r& Údup2)rQ ZfrmÚtor0 r0 r1 rÆ Ö s zServerOptions.dup2c C s t ¡ S r3 )r& Úsetpgrpr× r0 r0 r1 rÈ Ù s zServerOptions.setpgrpc C s
t |¡S r3 )r& Ústat)rQ r r0 r0 r1 rÉ Ü s zServerOptions.statc C s t |t|¡S r3 )r& r` r )rQ rÄ Údatar0 r0 r1 r` ß s zServerOptions.writec C s t |||¡S r3 )r& Úexecve)rQ r rL r{ r0 r0 r1 rË â s zServerOptions.execvec C s& d t _t |||¡\}}t |¡ |S r3 )r& Z
_urandomfdrÎ Zmkstemprÿ )rQ r r r rÄ r r0 r0 r1 r å s
zServerOptions.mktempfilec C s t |¡ d S r3 )r& r¡ r r0 r0 r1 r¡ î s zServerOptions.removec C s t |¡ d S r3 )r& ru )rQ r r0 r0 r1 ru ñ s zServerOptions._exitc C s t |¡ d S r3 )r& r¶ )rQ Úmaskr0 r0 r1 Úsetumaskô s zServerOptions.setumaskc C s2 dddg}dt jkr.t jd }|r.| t j¡}|S )z3Return a list corresponding to $PATH, or a default.z/binz/usr/binz/usr/local/binÚPATH)r& rO r Úpathsep)rQ r' Úpr0 r0 r1 Úget_path÷ s
zServerOptions.get_pathc C s t ¡ S r3 )r& r r× r0 r0 r1 Úget_pid s zServerOptions.get_pidc C st |d krt d| nZt |tj ¡r4td| n<t |tj ¡d@ sVtd| nt |tj¡spt d| d S )Nzcan't find command %rz command at %r is a directoryéI z command at %r is not executablez no permission to run command %r)
ÚNotFoundrÉ ÚS_ISDIRÚST_MODEÚ
NotExecutableÚS_IMODEr& ÚaccessÚX_OKÚ NoPermission)rQ r rL Ústr0 r0 r1 Úcheck_execv_args s z ServerOptions.check_execv_argsc C s0 | j d¡ | j jD ]}t|dr| ¡ qd S )Nzsupervisord logreopenÚreopen)rs rÀ Zhandlersru rÞ )rQ ry r0 r0 r1 Ú
reopenlogs s
zServerOptions.reopenlogsc
C sX zt |d¡}W nB tk
rR } z$|jd tjtjtjfkr> d}W 5 d }~X Y nX |S )Ni r rm )r& r- rý r r Z EWOULDBLOCKZEBADFr« )rQ rÄ rÊ r r0 r0 r1 Úreadfd s zServerOptions.readfdc C s t j | jpi ¡ d S r3 )r& rO rö rû r× r0 r0 r1 Úprocess_environment s z!ServerOptions.process_environmentc C s t |¡ d S r3 )r& rv )rQ r r0 r0 r1 rv " s zServerOptions.chdirc
C sú ddddddd}z¬t ¡ \}}|| |d< |d< t ¡ \}}|| |d< |d< |rrt ¡ \}}|| |d< |d< |d |d |d fD ]0}|dk rt |tj¡t jB } t |tj| ¡ q|W S tk
rô | ¡ D ]}|dk rÖ| |¡ qւ Y nX dS ) zç Create pipes for parent to child stdin/stdout/stderr
communications. Open fd in non-blocking mode so we can read them
in the mainloop without blocking. If stderr is False, don't
create a pipe for stderr. N)Ú child_stdinrx r_ Ú child_stdoutrd Ú child_stderrrâ rx r_ rã rd rä ) r& ÚpipeÚfcntlZF_GETFLÚO_NDELAYZF_SETFLrý r rÅ )
rQ rd Úpipesrx râ r_ rã rä rÄ Úflagsr0 r0 r1 Ú
make_pipes% s2 û zServerOptions.make_pipesc C s* dD ] }| |¡}|d k r| |¡ qd S )N)rx r_ rd ©r~ rÅ ©rQ rè ZfdnamerÄ r0 r0 r1 Úclose_parent_pipesD s
z ServerOptions.close_parent_pipesc C s* dD ] }| |¡}|d k r| |¡ qd S )N)râ rã rä rë rì r0 r0 r1 Úclose_child_pipesJ s
z ServerOptions.close_child_pipes)T)N)N)T)Kr9 r: r; r´ Z sockchownZ sockchmodrº r¿ rÁ Z
passwdfiler± rû r r r r" ZSupervisorStatesZRUNNINGZmoodrT r° rÚ rY r r r r r/ r' rB ri rl r rp ro r r r r r r r r r r£ r r§ r¨ r© r¸ r¹ rÁ rà r rÅ rr rÆ rÈ rÉ r` rË r r¡ ru rÍ rÑ rÒ rÝ rß rà rá rv rê rí rî r0 r0 r0 r1 r¯ s . <
y *$ ÿ
ÿ
54
9<
r¯ c @ sH e Zd ZdZdZdZdZdZdZdZ dd Z
dd Z dd Z d d
Z
dS ) Ú
ClientOptionsro Nc C sê t j| dd t | _t | j_d | jj_d| jj_d | jj_d | jj_d | jj_ d | jj_
ddl m } d|i f}|g| _
| jddd dd
dd | jd d
dd | jddddtdd | dddd¡ | dddd¡ | d d d d ¡ d S ) NF)rI rÄ r )ÚDefaultControllerPluginrz Ú interactivezsupervisorctl.interactiveÚiro r³ Úpromptzsupervisorctl.promptr¸ rì zsupervisorctl.serverurlzs:z
serverurl=úhttp://localhost:9001rj zsupervisorctl.usernamerµ z username=rk zsupervisorctl.passwordzp:z password=Úhistoryzsupervisorctl.history_filezr:z
history_file=)r< rT r8 r Ú
supervisorctlrñ ró rì rj rk Ú history_fileZsupervisor.supervisorctlrð Úplugin_factoriesrJ r )rQ rð Údefault_factoryr0 r0 r1 rT Z s2
ÿ ÿzClientOptions.__init__c O s" t j| f|| | js d| _d S )Nro )r< r r rñ )rQ rj rî r0 r0 r1 r t s zClientOptions.realizec C sª | j j}d}t|dsxtj t|¡| _| |¡s>t d| z|
|d¡}d}W n$ t t fk
rv t d| Y nX t
}| j|_d|_z| |¡ W n tk
r¸ | |¡ Y nX |rÆ| ¡ | ¡ }d|krÞt d|jd d
d | jid }| d
¡rt|dd
}d| }||_| d|j¡|_| d|j¡|_| d|j¡|_|jd|j d | jid }|rt|}||_ || _ n d |_ d | _ | j | |dd¡7 _ |S )NFr- rð r% Trñ rö z0.ini file does not include supervisorctl sectionrì rô rR r& r9 r: rç ró rj rk r÷ zsupervisor.ctl_factoryz
ctlplugin:) r rö ru r& r' r) r7 rR rV rr r, rü rý rþ rN rõ Ú mysectionr r r rÿ r r÷ r rì ró rj rk r÷ rø r¦ ) rQ r
r¤ r r£ r rì r' r÷ r0 r0 r1 r y s`
ÿ
ÿ
ýzClientOptions.read_configc C s t jdt | j| j| j¡dS )Nzhttp://127.0.0.1)Z transport)r Z ServerProxyr# ZSupervisorTransportrj rk rì r× r0 r0 r1 ÚgetServerProxy² s þûz ClientOptions.getServerProxy)r9 r: r; r rñ ró rì rj rk r÷ rT r r rû r0 r0 r0 r1 rï P s 9rï c @ sP e Zd ZdZdd ZdddZdd Zed i fd
d Zei fd d
Z dd Z
dS )rþ rÍ c O sH t s$d|krd|d< d|kr$d|d< tjj| f|| i | _i | _d S )NZinline_comment_prefixes)ú;ú#ÚstrictF)r r ÚRawConfigParserrT rC rõ rÛ r0 r0 r1 rT Â s z UnhosedConfigParser.__init__ú<string>c C s: zt j | ||¡W S tk
r4 | t|¡ Y S X dS )zParse configuration data from a string. This is intended
to be used in tests only. We add this method for Py 2/3 compat.N)r rÿ Ú read_stringr r r )rQ ÚstringÚsourcer0 r0 r1 r Ò s ÿz UnhosedConfigParser.read_stringc K sl t |tr|g}g }|D ]N}| j ¡ }| tjj| |gf|¡ t| jt| }|D ]}|| j |< qVq|S )a% Attempt to read and parse a list of filenames, returning a list
of filenames which were successfully parsed. This is a method of
RawConfigParser that is overridden to build self.section_to_file,
which is a mapping of section names to the files they came from.
)
rd r Z _sectionsr r) r rÿ r- Ú frozensetrC )rQ r rÜ Z ok_filenamesr Z
sections_origZdiffr¤ r0 r0 r1 r- Û s
ÿzUnhosedConfigParser.readTc C s| z| ||¡}W n& tjk
r6 |tkr. n|}Y nX |rxt|trxtt| j ¡ t| ¡ }t
||d||f }|S )Nz%s.%s) r~ r Z
NoOptionErrorÚ_markerrd r ÚdictÚlistrõ rP r )rQ r¤ Úoptionrz rS rõ ZoptvalZcombined_expansionsr0 r0 r1 r ð s
ÿ
ÿzUnhosedConfigParser.sanegetc K s | j | j|f||d|S )N)rz rõ )r rú )rQ r rz rõ rÜ r0 r0 r1 r÷ s
ÿÿz UnhosedConfigParser.getdefaultc C s\ d}| ¡ D ]J}| |¡D ]:\}}||kr|d k s:td| ||¡}| |||¡ qq d S )Nz%(here)sz here has not been set to a path)r rP ÚAssertionErrorr] r+ )rQ rR Z HERE_FORMATr¤ r| r r0 r0 r1 r s z UnhosedConfigParser.expand_hereN)r ) r9 r: r; rú rT r r- r r r÷ r r0 r0 r0 r1 rþ ¿ s
ÿ
rþ c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
S )ÚConfigc C s | |¡ S r3 )Ú__eq__©rQ Úotherr0 r0 r1 Ú__ne__ s z
Config.__ne__c C s$ | j |j kr| j|jk S | j |j k S r3 ©r rw r r0 r0 r1 Ú__lt__ s z
Config.__lt__c C s$ | j |j kr| j|jkS | j |j kS r3 r r r0 r0 r1 Ú__le__ s z
Config.__le__c C s$ | j |j kr| j|jkS | j |j kS r3 r r r0 r0 r1 Ú__gt__! s z
Config.__gt__c C s$ | j |j kr| j|jkS | j |j kS r3 r r r0 r0 r1 Ú__ge__' s z
Config.__ge__c C s d| j t| | jf S )Nz <%s instance at %s named %s>)Ú __class__Úidrw r× r0 r0 r1 Ú__repr__- s ÿzConfig.__repr__N) r9 r: r; r r r r r r r0 r0 r0 r1 r
s r
c @ s e Zd Zddddddddd d
d d d
ddddddddddddddd g Zd d gZd d Zd!d" Zd#d$ Zd%d& Zd,d(d)Z d*d+ Z
d'S )-r( rw r r[ r¹ r¶ r rE rG rH rI r\ rT rU r_ r] r^ rZ rV r` ra rW rb rK rL rM rN rO r rû rì c K sF || _ | jD ]}t| ||| q | jD ]}t| || |d ¡ q(d S r3 )r
Úreq_param_namesrv Úoptional_param_namesr~ )rQ r
Zparamsrw r0 r0 r1 rT ? s
zProcessConfig.__init__c C sX t |tsdS | j| j D ]8}tt| |t||fkr8qt| |t||kr dS qdS ©NFT)rd r( r r r r )rQ r
rw r0 r0 r1 r F s
zProcessConfig.__eq__c C s4 | j dk r*| j d¡}|dk r*| tj¡S | j ¡ S )z|Return a list corresponding to $PATH that is configured to be set
in the process environment, or the system default.NrÎ )rû r~ r r& rÏ r
rÑ r r0 r0 r1 rÑ R s
zProcessConfig.get_pathc C sJ | j j}| j j}| j}| jtkr.|||d| _| jtkrF|||d| _d S )Nr_ rd )r
r rà rw r\ r rZ )rQ Z get_autonameZsidrw r0 r0 r1 Úcreate_autochildlogs[ s
z"ProcessConfig.create_autochildlogsNc C s ddl m} || }||_|S )Nr )Ú
Subprocess)Úsupervisor.processr r )rQ r r Úprocessr0 r0 r1 Ú make_processe s zProcessConfig.make_processc C s´ | j }| j |¡}|d |d |d }}}i }ddlm} ddlm} ddlm}
|d k rv|
j} ||| |||< |d k r|
j } ||| |||< |d k r¬| |d|||< ||fS )Nr_ rd rx r ©ÚPOutputDispatcher©ÚPInputDispatcher©r )
r r
rê Úsupervisor.dispatchersr r" rÄ r Z ProcessCommunicationStdoutEventÚ ProcessCommunicationStderrEvent) rQ r Ú
use_stderrrÐ Ú stdout_fdÚ stderr_fdÚstdin_fdÚ dispatchersr r" r Úetyper0 r0 r1 Úmake_dispatchersk s z ProcessConfig.make_dispatchers)N) r9 r: r; r r rT r rÑ r r r, r0 r0 r0 r1 r( 1 sH ö
r( c @ s e Zd Zdd ZdS )r, c
C s¶ d}| j |¡}|d |d |d }}}i }ddlm} ddlm} ddlm}
dd lm} |d k rx||d|||< |d k r| j} |
|| |||< |d k r®| |d|||< ||fS )
NTr_ rd rx r )ÚPEventListenerDispatcherr! r r# ) r
rê r$ r- r" r rÄ r r% )
rQ r r& rÐ r' r( r) r* r- r" r r r+ r0 r0 r1 r, ~ s$ ÿz$EventListenerConfig.make_dispatchersN)r9 r: r; r, r0 r0 r0 r1 r, } s r, c @ s e Zd ZdddZdd ZdS )r0 Nc C s. |d krt dddlm} || }||_|S )Nz FastCGI programs require a groupr )ÚFastCGISubprocess)ÚNotImplementedErrorr r. r )rQ r r. r r0 r0 r1 r s z!FastCGIProcessConfig.make_processc C s4 t | |¡\}}|d }|d k r,|| ¡ ||fS )Nrx )r( r, rÿ )rQ r r* rÐ r) r0 r0 r1 r, s
z%FastCGIProcessConfig.make_dispatchers)N)r9 r: r; r r, r0 r0 r0 r1 r0 s
r0 c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r* c C s || _ || _|| _|| _d S r3 )r
rw r r
)rQ r
rw r r
r0 r0 r1 rT ¨ s zProcessGroupConfig.__init__c C sB t |tsdS | j|jkr dS | j|jkr.dS | j|jkr>dS dS r )rd r* rw r r
r r0 r0 r1 r ® s
zProcessGroupConfig.__eq__c C s | j D ] }| ¡ qd S r3 ©r
r ©rQ rX r0 r0 r1 Ú after_setuid» s
z ProcessGroupConfig.after_setuidc C s ddl m} || S )Nr )Ú ProcessGroup)r r3 )rQ r3 r0 r0 r1 Ú
make_group¿ s z ProcessGroupConfig.make_groupN©r9 r: r; rT r r2 r4 r0 r0 r0 r1 r* § s
r* c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r- c C s. || _ || _|| _|| _|| _|| _|| _d S r3 )r
rw r r
r r5 r )rQ r
rw r r
r r5 r r0 r0 r1 rT Ä s z EventListenerPoolConfig.__init__c C s^ t |tsdS | j|jkrZ| j|jkrZ| j|jkrZ| j|jkrZ| j|jkrZ| j|jkrZdS dS r )rd r- rw r r
r r5 r r r0 r0 r1 r Î s
ÿ
þ
ý
ü
ûz EventListenerPoolConfig.__eq__c C s | j D ] }| ¡ qd S r3 r0 r1 r0 r0 r1 r2 Ü s
z$EventListenerPoolConfig.after_setuidc C s ddl m} || S )Nr )ÚEventListenerPool)r r6 )rQ r6 r0 r0 r1 r4 à s z"EventListenerPoolConfig.make_groupNr5 r0 r0 r0 r1 r- Ã s
r- c @ s$ e Zd Zdd Zdd Zdd ZdS )r1 c C s t | ||||¡ || _d S r3 )r* rT r7 )rQ r
rw r r
r7 r0 r0 r1 rT å s ûzFastCGIGroupConfig.__init__c C s* t |tsdS | j|jkr dS t | |¡S )NF)rd r1 r7 r* r r r0 r0 r1 r ï s
zFastCGIGroupConfig.__eq__c C s ddl m} || S )Nr )ÚFastCGIProcessGroup)r r7 )rQ r7 r0 r0 r1 r4 ø s z FastCGIGroupConfig.make_groupN)r9 r: r; rT r r4 r0 r0 r0 r1 r1 ä s
r1 c C sæ t |}t |}z°t| d}||krt|r2td| dd¡ | ¡ }t|| }|dk r^d}| |¡ | |¡}n@||krtd|dkr | |¡ | ¡ }n| |¡ | |¡}W 5 Q R X W n ttfk
rà tdY nX |S )zJ Read length bytes from the file named by filename starting at
offset ÚrbZ
BAD_ARGUMENTSr rc ZFAILED) Úabsr, rr ÚseekÚtellrÐ r- rý rü ) r ÚoffsetÚlengthZ absoffsetZ abslengthr/ ÚszÚposrÊ r0 r0 r1 ÚreadFileü s0
r@ c
C sì zÄt | d°}d}| dd¡ | ¡ }||| kr>d}|d }|| |krb||d krZd}|| }|dk rnd}|dk rzd}|dkrd}n| |¡ | |¡}|}t|||gW 5 Q R £ W S Q R X W n" ttfk
ræ d|dg Y S X d S )
a
Read length bytes from the file named by filename starting at
offset, automatically increasing offset and setting overflow
flag if log size has grown beyond (offset + length). If length
bytes are not available, as many bytes as are available are returned.
r8 Fr rc Tro rm rp N)r, r: r; r- r rý rü )r r< r= r/ Zoverflowr> rÊ r0 r0 r1 ÚtailFile s0
&rA c C s t | ¡r(t | ¡d@ }d| }||fS t | ¡rzt | ¡}dt| }tt dr^t | ¡}n| d@ }|rr|d7 }d|fS d| }d|fS d S )
a* Decode the status returned by wait() or waitpid().
Return a tuple (exitstatus, message) where exitstatus is the exit
status, or -1 if the process was killed by a signal; and message
is a message telling what happened. It is the caller's
responsibility to display the message.
r# zexit status %szterminated by %sÚ WCOREDUMPé z (core dumped)rq z unknown termination cause 0x%04xN)r& Ú WIFEXITEDÚ WEXITSTATUSÚ WIFSIGNALEDÚWTERMSIGÚsignameru rB )r¬ Zesrg ÚsigZiscorer0 r0 r1 Údecode_wait_statusG s
rJ c C s t dkrt t | ¡p d| S )zReturn a symbolic name for a signal.
Return "signal NNN" if there is no corresponding SIG name in the
signal module.
Nz signal %d)Ú _signamesÚ_init_signamesr~ )rI r0 r0 r1 rH c s rH c C sN i } t j ¡ D ]6\}}t|dd }|d kr,q|dr|ds|| |< q| ad S )Nr ZSIGZSIG_)r Ú__dict__rP r rK )ÚdrS r6 Z k_startswithr0 r0 r1 rL n s
rL c @ s$ e Zd Zdd Zdd Zdd ZdS )rÕ c C s
g | _ d S r3 )Ú_signals_recvdr× r0 r0 r1 rT z s zSignalReceiver.__init__c C s || j kr| j |¡ d S r3 )rO rt )rQ rI Úframer0 r0 r1 r } s
zSignalReceiver.receivec C s | j r| j d¡}nd }|S )Nr )rO Úpop)rQ rI r0 r0 r1 r s zSignalReceiver.get_signalN)r9 r: r; rT r r r0 r0 r0 r1 rÕ y s rÕ c C s z
| | W S t k
r^ } z6t| ¡ }| ¡ td| |t|d |¡f W 5 d }~X Y n8 tk
r } ztd| |t|f W 5 d }~X Y nX d S )NzYFormat string %r for %r contains names (%s) which cannot be expanded. Available names: %srU z.Format string %r for %r is badly formatted: %s)r² r r r2 rr re r+ r )Úsrõ rw ÚexZ availabler0 r0 r1 r s
þÿ ÿÿr c C s | |kr|}n d| |f }|S )Nz%s:%sr0 )r4 rX rw r0 r0 r1 Ú
make_namespec s rT c C sD | dd¡}t|dkr2|\}}|r,|dkr<d }n
| | }}||fS )Nrh ro rc Ú*)r rg )ZnamespecÚnamesr4 rX r0 r0 r1 Úsplit_namespec¤ s
rW c @ s e Zd ZdZdS )ÚProcessExceptionz@ Specialized exceptions used when attempting to start a process N©r9 r: r; r r0 r0 r0 r1 rX ² s rX c @ s e Zd ZdZdS )Ú
BadCommandz5 Indicates the command could not be parsed properly. NrY r0 r0 r0 r1 rZ µ s rZ c @ s e Zd ZdZdS )r× z Indicates that the filespec cannot be executed because its path
resolves to a file which is not executable, or which is a directory. NrY r0 r0 r0 r1 r× ¸ s r× c @ s e Zd ZdZdS )rÔ zR Indicates that the filespec cannot be executed because it could not
be found NrY r0 r0 r0 r1 rÔ ¼ s rÔ c @ s e Zd ZdZdS )rÛ z¤ Indicates that the file cannot be executed because the supervisor
process does not possess the appropriate UNIX filesystem permission
to execute the file. NrY r0 r0 r0 r1 rÛ À s rÛ )[rá r r& rK rÎ r r r? r° r´ r¼ rÉ r¨ r r r¬ ræ Zsupervisor.compatr r r r r r r Zsupervisor.medusar r¤ Zsupervisor.datatypesr
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 rÙ r7 r8 r< r¯ rï r rÿ rþ Úobjectr
r( r, r0 r* r- r1 r@ rA rJ rK rH rL rÕ r rT rW r rX rZ r× rÔ rÛ r0 r0 r0 r1 Ú<module> s¸ I LmR L !")