File: //lib/python3.6/site-packages/supervisor/tests/__pycache__/test_options.cpython-36.opt-1.pyc
3
�k�`�3 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z ddl
mZmZmZ ddlmZ ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd l
mZ dd
l
mZ ddl
mZ G dd� dej�Z G dd� dej�Z G dd� dej�Z G dd� dej�Z G dd� dej�Z G dd� dej�Z!G dd � d ej�Z"G d d � d ej�Z#G d d � d ej�Z$G d!d"� d"ej�Z%G d#d$� d$ej�Z&G d%d&� d&ej�Z'd'd(� Z(e)d)k�r�ej*d(d*� dS )+z!Test suite for supervisor.options� N)�StringIO)�as_bytes)�Mock�sentinel�patch)� LevelsByName)�DummySupervisor)� DummyLogger)� DummyOptions)� DummyPoller)� DummyPConfig)� DummyProcess)�DummySocketConfig)�lstripc @ s� e Zd Zdd� Zd-dd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,S ).� OptionTestsc C s ddl m} |S )Nr )�Options)�supervisor.optionsr )�selfr � r �"/usr/lib/python3.6/test_options.py�_getTargetClass s zOptionTests._getTargetClassFc sf | j � � ddlm} G � �fdd�d� �}|� }t� |_|jdddddd � |jd
d
d d d
|d� |S )Nr )�integerc s, e Zd ZddiZ�f� fdd� Zdd� ZdS )z+OptionTests._makeOptions.<locals>.MyOptions�other�) c s, || _ � j| � G dd� dt�}|� | _d S )Nc @ s e Zd ZdS )zAOptionTests._makeOptions.<locals>.MyOptions.__init__.<locals>.FooN)�__name__�
__module__� __qualname__r r r r �Foo- s r )�
read_error�__init__�object�
configroot)r r r )r r r r * s
z4OptionTests._makeOptions.<locals>.MyOptions.__init__c S s4 | j rt| j ��| jjj| j� | jjj| j� d S )N)r �
ValueErrorr! �__dict__�updateZ default_map�master)r �fpr r r � read_config0 s
z7OptionTests._makeOptions.<locals>.MyOptions.read_configN)r r r r% r r' r )r r r r � MyOptions' s r( �anoption�oZoption�default)�name�confname�short�longr+ r �OTHERzp:zother=)r, r- �envr. r/ �handler)r �supervisor.datatypesr r �
configfile�add)r r r r( �optionsr )r r r � _makeOptions# s
zOptionTests._makeOptionsc C s& | j � }|� }| jt|jddd� d S )NT)�flagr2 )r � assertRaisesr" r5 )r �cls�instr r r �'test_add_flag_not_None_handler_not_None? s z3OptionTests.test_add_flag_not_None_handler_not_Nonec C s( | j � }|� }| jt|jdddd� d S )NTF)r8 r/ r. )r r9 r" r5 )r r: r; r r r �-test_add_flag_not_None_long_false_short_falseD s z9OptionTests.test_add_flag_not_None_long_false_short_falsec C s( | j � }|� }| jt|jdddd� d S )NTF�:)r8 r/ r. )r r9 r" r5 )r r: r; r r r �+test_add_flag_not_None_short_endswith_colonO s z7OptionTests.test_add_flag_not_None_short_endswith_colonc C s( | j � }|� }| jt|jdddd� d S )NT�=F)r8 r/ r. )r r9 r" r5 )r r: r; r r r �*test_add_flag_not_None_long_endswith_equalZ s z6OptionTests.test_add_flag_not_None_long_endswith_equalc C s& | j � }|� }| jt|jddd� d S )Nr@ �abc)r/ r. )r r9 r" r5 )r r: r; r r r �(test_add_inconsistent_short_long_optionse s z4OptionTests.test_add_inconsistent_short_long_optionsc C s& | j � }|� }| jt|jddd� d S )NFz-abc)r/ r. )r r9 r" r5 )r r: r; r r r �%test_add_short_option_startswith_dasho s z1OptionTests.test_add_short_option_startswith_dashc C s& | j � }|� }| jt|jddd� d S )NFrB )r/ r. )r r9 r" r5 )r r: r; r r r � test_add_short_option_too_longy s z*OptionTests.test_add_short_option_too_longc C s0 | j � }|� }ddi|_| jt|jddd� d S )Nz-aTF�a)r/ r. )r � options_mapr9 r" r5 )r r: r; r r r �#test_add_duplicate_short_option_key� s
z/OptionTests.test_add_duplicate_short_option_keyc C s& | j � }|� }| jt|jddd� d S )Nz-abcF)r/ r. )r r9 r" r5 )r r: r; r r r �$test_add_long_option_startswith_dash� s z0OptionTests.test_add_long_option_startswith_dashc C s0 | j � }|� }ddi|_| jt|jddd� d S )Nz--abcTrB F)r/ r. )r rG r9 r" r5 )r r: r; r r r �"test_add_duplicate_long_option_key� s
z.OptionTests.test_add_duplicate_long_option_keyc C s< | j � }| jt|j�d� | j|jdd � ddddg� d S )N� � zsupervisord.confzetc/supervisord.confz/etc/supervisord.confz /etc/supervisor/supervisord.conf���)r7 � assertEqual�len� searchpaths)r r6 r r r �test_searchpaths� s z OptionTests.test_searchpathsc C s� | j � }|jg � | j|jd� | j|jd� | j � }dtjd< |jg � | j|jd� | j � }|jddg� | j|jd� tjd= d S ) Nr+ r Z42r0 �* z-pZ43�+ )r7 �realizerN r) r �os�environ)r r6 r r r �test_options_and_args_order� s
z'OptionTests.test_options_and_args_orderc C sD | j � }|jg � | j|jd� d|jd< |j� | j|jd� d S )Nr rR r )r7 rT rN r r% �process_config)r r6 r r r �test_config_reload� s
z OptionTests.test_config_reloadc C s | j dd�}| jt|jd� d S )N�error)r F)r7 r9 r" rX )r r6 r r r �!test_config_reload_do_usage_false� s
z-OptionTests.test_config_reload_do_usage_falsec sZ | j dd�}g � � fdd�|_t� |_|_d|j_d|j_|jdd� | j � dg� d S ) NrZ )r c s
� j | �S )N)�append)�x)� exitcodesr r �<lambda>� s z>OptionTests.test_config_reload_do_usage_true.<locals>.<lambda>� T)�do_usage� )
r7 �exitr �stderr�stdoutr! r) r rX rN )r r6 r )r^ r � test_config_reload_do_usage_true� s z,OptionTests.test_config_reload_do_usage_truec C s� ddl m} |� }|jddd� | j|jd� | j|jd d� |jddd� | j|jd� | j|jd d� |jddd� | j|jd� | j|jd d� |jddd� | j|jd� d S )Nr )r �foo�bar�bazr` Zgazonk)r r Z_setrN rg Zattr_priorities)r r r6 r r r � test__set� s zOptionTests.test__setc s\ | j � }g |_g � � fdd�|_t� |_|j� | j� dg� d}| j|jj� j |�� d S )Nc s
� j | �S )N)r\ )r] )r^ r r r_ � s z9OptionTests.test_missing_default_config.<locals>.<lambda>rb z,Error: No config file found at default paths)
r7 rP rc r rd �default_configfilerN �
assertTrue�getvalue�
startswith)r r6 �msgr )r^ r �test_missing_default_config� s z'OptionTests.test_missing_default_configc
C s@ | j � }tj� �&}|jg|_|j� }| j||j� W d Q R X d S )N)r7 �tempfile�NamedTemporaryFiler, rP rk rN )r r6 �f�configr r r �test_default_config� s
z OptionTests.test_default_configc s` | j � }g � � fdd�|_t� |_d|_d|_|jd� | j� dg� d}| j|jj� |� d S )Nc s
� j | �S )N)r\ )r] )r^ r r r_ � s z'OptionTests.test_help.<locals>.<lambda>� test_helpzA sample docstring for %s� r z!A sample docstring for test_help
) r7 rc r re Zprogname�doc�helprN rm )r r6 ro r )r^ r rv � s
zOptionTests.test_helpN)F)r r r r r7 r< r= r? rA rC rD rE rH rI rJ rQ rW rY r[ rf rj rp ru rv r r r r r s*
r c @ s| e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd S ) �ClientOptionsTestsc C s ddl m} |S )Nr )�
ClientOptions)r r{ )r r{ r r r r s z"ClientOptionsTests._getTargetClassc C s
| j � � S )N)r )r r r r �_makeOne s zClientOptionsTests._makeOnec s� | j � }g |_g � � fdd�|_|jddddddgd � | j� g � | j|jd
� | j|jd� | j|jd� | j|jd� d S ) z(Making sure config file is not required.c s
� j | �S )N)r\ )r] )r^ r r r_ s z8ClientOptionsTests.test_no_config_file.<locals>.<lambda>z-szhttp://localhost:9001z-u�chrisz-p�123)�argsr` N) r| rP rc rT rN � interactive� serverurl�username�password)r �instancer )r^ r �test_no_config_file s z&ClientOptionsTests.test_no_config_filec C s� t j� }td| �}t|�}| j� }||_|jg d� | j|jd� t j
j |d�}| j|j |� |j
j}| j|jd� | j|jd� | j|jd� | j|jd� | j|j |� d S ) Nz�[supervisorctl]
serverurl=http://localhost:9001
username=chris
password=123
prompt=mysupervisor
history_file=%s/sc_history
)r T�
sc_historyZ mysupervisorzhttp://localhost:9001r} r~ )rq �
gettempdirr r r| r4 rT rN r� rU �path�join� history_filer! �
supervisorctl�promptr� r� r� )r �tempdir�sr& r� r� r6 r r r � test_options s
z ClientOptionsTests.test_optionsc C s@ t d�}| j� }t|�|_|jg d� |jj}| j|jd� d S )Nzx
[supervisorctl]
serverurl=http://127.0.0.1:9001 ; use an http:// url to specify an inet socket
)r zhttp://127.0.0.1:9001) r r| r r4 rT r! r� rN r� )r �textr� r6 r r r �3test_options_ignores_space_prefixed_inline_comments4 s
zFClientOptionsTests.test_options_ignores_space_prefixed_inline_commentsc C s@ t d�}| j� }t|�|_|jg d� |jj}| j|jd� d S )Nzw
[supervisorctl]
serverurl=http://127.0.0.1:9001 ;use an http:// url to specify an inet socket
)r zhttp://127.0.0.1:9001) r r| r r4 rT r! r� rN r� )r r� r� r6 r r r �1test_options_ignores_tab_prefixed_inline_comments? s
zDClientOptionsTests.test_options_ignores_tab_prefixed_inline_commentsc C s* t d�}| j� }t|�|_|jg d� d S )Nz�
[supervisorctl]
serverurl=http://localhost:9001 ;duplicate
[supervisorctl]
serverurl=http://localhost:9001 ;duplicate
)r )r r| r r4 rT )r r� r� r r r �3test_options_parses_as_nonstrict_for_py2_py3_compatJ s
zFClientOptionsTests.test_options_parses_as_nonstrict_for_py2_py3_compatc C s� t d�}t|�}| j� }tj� ddddddd�|_||_|jg d � | j|j d
� |j
j }| j|j d� | j|j
d � | j|jd� | j|jd� | j|jd � d S )
Na
[supervisorctl]
serverurl=http://localhost:%(ENV_SERVER_PORT)s
username=%(ENV_CLIENT_USER)s
password=%(ENV_CLIENT_PASS)s
prompt=%(ENV_CLIENT_PROMPT)s
history_file=/path/to/histdir/.supervisorctl%(ENV_CLIENT_HIST_EXT)s
�johndoe�9210�someuser� passwordhereZ xsupervisorz.hist)�ENV_HOME�ENV_USER�ENV_SERVER_PORTZENV_CLIENT_USERZENV_CLIENT_PASSZENV_CLIENT_PROMPTZENV_CLIENT_HIST_EXT)r Tzhttp://localhost:9210z$/path/to/histdir/.supervisorctl.hist)r r r| rq r� �environ_expansionsr4 rT rN r� r! r� r� r� r� r� r� )r r� r& r� r6 r r r �(test_options_with_environment_expansionsW s(
z;ClientOptionsTests.test_options_with_environment_expansionsc C s� | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}| j|jtjj|d�� | j|jdtjj|d � � d S )
Nz}
[supervisorctl]
history_file=%(here)s/sc_history
serverurl=unix://%(here)s/supervisord.sock
zsupervisord.conf�w)r T)�
ignore_errorsr� zunix://zsupervisord.sock)r| r rq �mkdtemprU r� r� �open�writer4 rT �shutil�rmtreer! r� rN r� r� )r r� r� �here�supervisord_confrs r6 r r r �/test_options_supervisorctl_section_expands_hereu s zBClientOptionsTests.test_options_supervisorctl_section_expands_herec C sr t jjt jjt�d�}| j� }y|j|� | jd� W n6 tk
rl } z| j d|j
d k� W Y d d }~X nX d S )N� nonexistentznothing raisedzcould not find config filer ) rU r� r� �dirname�__file__r| r' �failr" rl r )r r� r� �excr r r �test_read_config_not_found� s
z-ClientOptionsTests.test_read_config_not_foundc C sj | j � }dd� }||_y|jt� | jd� W n6 tk
rd } z| jd|jd k� W Y d d }~X nX d S )Nc S s t tjd| ��d S )NzPermission denied: %s)�IOError�errno�EACCES)�fn�moder r r �
dummy_open� s zBClientOptionsTests.test_read_config_unreadable.<locals>.dummy_openzexpected exceptionzcould not read config filer )r| r� r' r� r� r" rl r )r r� r� r� r r r �test_read_config_unreadable� s
z.ClientOptionsTests.test_read_config_unreadablec C s\ | j � }y|jt� � | jd� W n4 tk
rV } z| j|jd d� W Y d d }~X nX d S )Nznothing raisedr z0.ini file does not include supervisorctl section)r| r' r r� r" rN r )r r� r� r r r �9test_read_config_no_supervisord_section_raises_valueerror� s zLClientOptionsTests.test_read_config_no_supervisord_section_raises_valueerrorc C s8 t d�}| j� }||_|jddgd� | j|jd� d S )Nz[supervisorctl]z --serverurlzunix:///dev/null)r )r r| r4 rT rN r� )r r& r� r r r �test_options_unixsocket_cli� s
z.ClientOptionsTests.test_options_unixsocket_clic C s< t d�}t|�}| j� }||_|jg d� | j|jd� d S )Nz;[supervisorctl]
serverurl=unix:///dev/null
)r zunix:///dev/null)r r r| r4 rT rN r� )r r� r& r� r r r �"test_options_unixsocket_configfile� s z5ClientOptionsTests.test_options_unixsocket_configfileN)r r r r r| r� r� r� r� r� r� r� r� r� r� r� r� r r r r rz s
rz c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z d=d>� Z!d?d@� Z"dAdB� Z#dCdD� Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)dOdP� Z*dQdR� Z+dSdT� Z,dUdV� Z-dWdX� Z.dYdZ� Z/d[d\� Z0d]d^� Z1d_d`� Z2dadb� Z3dcdd� Z4dedf� Z5dgdh� Z6didj� Z7dkdl� Z8dmdn� Z9dodp� Z:dqdr� Z;dsdt� Z<dudv� Z=e>dwe?e@dx��dydz� �ZAd{d|� ZBd}d~� ZCdd�� ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d�� Zcd�d�� Zdd�d Zed�dĄ Zfd�dƄ Zgd�dȄ Zhd�dʄ Zid�d̄ Zjd�d΄ Zkd�dЄ Zld�d҄ Zmd�dԄ Znd�dք Zod�d Zpd�dڄ Zqd�d܄ Zrd�dބ Zsd�d� Ztd�d� Zud�d� Zvd�d� Zwd�d� Zxd�d� Zyd�d� Zzd�d� Z{d�d� Z|d�d� Z}d�d� Z~d�d�� Zd�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 �d
� Z�e>�d e?�d �d
�d�dg�d��e>�de?�d�d���d�d� ��Z�e>�d e?�d �d
�d�dg�d��e>�de?�d�d���d�d� ��Z��d�d� Z��d
S ( �ServerOptionsTestsc C s ddl m} |S )Nr )�
ServerOptions)r r� )r r� r r r r � s z"ServerOptionsTests._getTargetClassc C s
| j � � S )N)r )r r r r r| � s zServerOptionsTests._makeOnec C sF ddl m} | j� }t� |_| jt|jd � | j|jj � |d � d S )Nr )�VERSION�
)
r r� r| r re r9 �
SystemExit�versionrN rm )r r� r6 r r r � test_version� s
z ServerOptionsTests.test_versionc C sR t ddtj� i �}ddlm} t|�}| j� }||_|jg d� |j j
}| j |j tj� � | j |j
d� | j |jd� | j |jd5� | j |jd
� | j |jd � | j |jd � | j |jd
� | j |jd
� | j |jd� | j |jtj� � | j t|j�d� | j |jd d tj� | j |jd d d� | j |jd d d� | j |jd d d� | j |jd d d� | j |jd
� | j |j d� | j |j d� | j |jd
� | j t|j �d
� | j |j t dd �� |j d }| j |j!d � | j |j"d� | j t|j#�d� |j#d }| j |j!d � | j |j$d � | j |j"d� | j |j%d
� | j |j&|j'� | j |j(d
� | j |j)d � | j |j*d� | j |j+d � | j |j,t-j.� | j |j/d
� | j |j0d!� | j |j1d!� | j |j2|j3d"�� | j |j4d � | j |j5dg� | j |j d#� | j |j
d$� | j |j t dd �� |j d }| j |j!d%� | j |j"d$� | j t|j#�d� |j#d } | j | j!d%� | j | j$d � | j | j"d$� | j | j%d
� | j | j&d!� | j | j*d � | j | j+d&� | j | j,t-j6� | j | j0d!� | j | j1d!� | j | j2d � | j | j4d$� | j | j5dg� | j | j d � |j d$ }
| j |
j!d'� | j |
j"d(� | j t|
j#�d� |
j#d } | j | j!d)� | j | j$d � | j | j"d(� | j | j%d
� | j | j&|j7� | j | j*d � | j | j+|j8� | j | j2|j3d"�� | j | j4d � | j | j5ddd*g� | j | j,t-j6� | j | j0d
� | j | j1d
� |j d( } | j | j!d+� | j | j"d,� | j t| j#�d$� | j#d }
| j |
j!d-� | j |
j$d � | j |
j"d,� | j |
j%d
� | j |
j&|j'� | j |
j*d � | j |
j+|j8� | j |
j2|j3d"�� | j |
j4d � | j |
j5dg� | j |
j,t-j6� | j |
j0d!� | j |
j1d!� | j |
j d � | j#d }| j |j!d.� | j |j$d � | j |j"d,� | j |j%d
� | j |j&|j'� | j |j*d � | j |j+|j8� | j |j2|j3d"�� | j |j4d � | j |j5dg� | j |j,t-j6� | j |j0d!� | j |j1d!� | j |j d � |j d, }| j |j!d/� | j |j"d
� | j t|j#�d$� |j#d }| j |j!d0� | j |j d1� |j#d }| j |j!d2� | j |j d3� t9j:j;t9j<� �}| j |j*d� | j |j=d� | j |j tj� � | j |j
d� | j |jt9j:j>|d�� | j |jd7� | j |jd
� | j |jd � | j |jt9j:j>|d �� | j |jd
� | j |jd
� | j |j?d � | j |jd� | j |jtj� � | j t|j�d� | j |jd d tj� | j |jd d d� | j |jd d d� | j |jd d d� | j |jd d d� | j |jd
� | j |j d� | j |j d� d S )8Na�
[supervisord]
directory=%(tempdir)s
backofflimit=10
user=root
umask=022
logfile=supervisord.log
logfile_maxbytes=1000MB
logfile_backups=5
loglevel=error
pidfile=supervisord.pid
nodaemon=true
silent=true
identifier=fleeb
childlogdir=%(tempdir)s
nocleanup=true
minfds=2048
minprocs=300
environment=FAKE_ENV_VAR=/some/path
[inet_http_server]
port=127.0.0.1:8999
username=chrism
password=foo
[program:cat1]
command=/bin/cat
priority=1
autostart=true
user=root
stdout_logfile=/tmp/cat.log
stopsignal=KILL
stopwaitsecs=5
startsecs=5
startretries=10
directory=/tmp
umask=002
[program:cat2]
priority=2
command=/bin/cat
autostart=true
autorestart=false
stdout_logfile_maxbytes = 1024
stdout_logfile_backups = 2
stdout_logfile = /tmp/cat2.log
[program:cat3]
priority=3
process_name = replaced
command=/bin/cat
autorestart=true
exitcodes=0,1,127
stopasgroup=true
killasgroup=true
[program:cat4]
priority=4
process_name = fleeb_%%(process_num)s
numprocs = 2
command = /bin/cat
autorestart=unexpected
[program:cat5]
priority=5
process_name = foo_%%(process_num)02d
numprocs = 2
numprocs_start = 1
command = /bin/cat
directory = /some/path/foo_%%(process_num)02d
r� r )� datatypes)r � zsupervisord.logi� i � �( zsupervisord.pidTZfleebr` �family�hostz 127.0.0.1�porti'# r� Zchrismr� rg i i, z
/some/path)� FAKE_ENV_VAR�cat1z/bin/cat�
z /tmp/cat.logFZ50MBz/tmprb �cat2z
/tmp/cat2.log�cat3� Zreplaced� �cat4rL Zfleeb_0Zfleeb_1�cat5Zfoo_01z/some/path/foo_01Zfoo_02z/some/path/foo_02i � i �>i � i �>)@r rq r� �
supervisorr� r r| r4 rT r! � supervisordrN � directory�umask�logfile�logfile_maxbytes�logfile_backups�loglevel�pidfile�nodaemon�silent�
identifier� childlogdirrO �server_configs�socket�AF_INET� nocleanup�minfds�minprocs�process_group_configs� environment�dictr, �priority�process_configs�command� autostart� autorestart�RestartWhenExitUnexpected� startsecs� startretries�uid�stdout_logfile�
stopsignal�signal�SIGKILL� stopwaitsecs� stopasgroup� killasgroup�stdout_logfile_maxbytes� byte_size�stdout_logfile_backupsr^ �SIGTERMZRestartUnconditionally� AutomaticrU r� �abspath�getcwd�gidr� Z
passwdfile)r r� r� r& r� r6 r� �proc1r� Zproc2r� Zproc3r� Zproc4_aZproc4_br� Zproc5_aZproc5_br� r r r r� � sL F
z ServerOptionsTests.test_optionsc C sN t d�}| j� }t|�|_|jg d� |jj}| j|jd� | j|j d� d S )Nz�
[supervisord]
logfile=/tmp/supervisord.log ;(main log file;default $CWD/supervisord.log)
minfds=123 ; (min. avail startup file descriptors;default 1024)
)r z/tmp/supervisord.log�{ )
r r| r r4 rT r! r� rN r� r� )r r� r� r6 r r r r� � s
zFServerOptionsTests.test_options_ignores_space_prefixed_inline_commentsc C s@ t d�}| j� }t|�|_|jg d� |jj}| j|jd� d S )Nz�
[supervisord]
logfile=/tmp/supervisord.log ;(main log file;default $CWD/supervisord.log)
minfds=123 ; (min. avail startup file descriptors;default 1024)
)r r� ) r r| r r4 rT r! r� rN r� )r r� r� r6 r r r r� � s
zDServerOptionsTests.test_options_ignores_tab_prefixed_inline_commentsc C s* t d�}| j� }t|�|_|jg d� d S )Nz�
[supervisord]
[program:duplicate]
command=/bin/cat
[program:duplicate]
command=/bin/cat
)r )r r| r r4 rT )r r� r� r r r r� � s
zFServerOptionsTests.test_options_parses_as_nonstrict_for_py2_py3_compatc C s\ t d�}| j� }t|�|_|jg d� |jj}| jt|j �d� |j d }| jt|j
�d� |j d }| jt|j
�d� | j |j |j k� t d�}t|�|_|j dd� |jj}| jt|j �d� |j d }| jt|j
�d� |j
d }| j|j
d � | j|jd
� | j |j |j k� |j d }| jt|j
�d� |j
d }| j|j
d � | j|jd � d S )
Nz� [supervisord]
user=root
[program:one]
command = /bin/cat
[program:two]
command = /bin/dog
[program:four]
command = /bin/sheep
[group:thegroup]
programs = one,two
)r rb r r` z� [supervisord]
user=root
[program:one]
command = /bin/cat
[program:three]
command = /bin/pig
[group:thegroup]
programs = three
F)ra Zonez/bin/catZthreez/bin/pig)r r| r r4 rT r! r� rN rO r� r� rl rX r, r� )r r� r� �section�cat�procr r r � test_reload� s>
z ServerOptionsTests.test_reloadc C sv | j � }d}|g|_|g|_|g|_td�}t|�|_|jg d� | j||jk� | j||jk� | j||jk� d S )Nz Message from a prior config readzb [supervisord]
user=root
[program:cat]
command = /bin/cat
)r ) r| Zparse_criticals�parse_warnings� parse_infosr r r4 rT � assertFalse)r r� Zold_msgr� r r r �!test_reload_clears_parse_messages3 s
z4ServerOptionsTests.test_reload_clears_parse_messagesc C sF | j � }d}|g|_td�}t|�|_|jg d� | j||jk� d S )Nz Info from a prior config readzb [supervisord]
user=root
[program:cat]
command = /bin/cat
)r )r| Zinfosr r r4 rT r r )r r� Zold_infor� r r r � test_reload_clears_parse_infosG s
z1ServerOptionsTests.test_reload_clears_parse_infosc C sr t jjt jjt�d�}| j� }y|j|� | jd� W n6 tk
rl } z| j d|j
d k� W Y d d }~X nX d S )Nr� znothing raisedzcould not find config filer ) rU r� r� r� r� r| r' r� r" rl r )r r� r� r� r r r r� W s
z-ServerOptionsTests.test_read_config_not_foundc C sj | j � }dd� }||_y|jt� | jd� W n6 tk
rd } z| jd|jd k� W Y d d }~X nX d S )Nc S s t tjd| ��d S )NzPermission denied: %s)r� r� r� )r� r� r r r r� b s zBServerOptionsTests.test_read_config_unreadable.<locals>.dummy_openznothing raisedzcould not read config filer )r| r� r' r� r� r" rl r )r r� r� r� r r r r� ` s
z.ServerOptionsTests.test_read_config_unreadablec C s� | j � }tjdd���}y,|jd� |j� |j|j� | jd� W nL tk
r� } z0| j d|j
d k� | j |j|j
d k� W Y d d }~X nX W d Q R X d S )Nzw+)r� z[supervisord]
junkznothing raisedzcontains parsing errors:r ) r| rq rr r� �flushr' r, r� r" rl r )r r� rs r� r r r �8test_read_config_malformed_config_file_raises_valueerrorl s
zKServerOptionsTests.test_read_config_malformed_config_file_raises_valueerrorc C s� | j � }tjjtjjt�dd�}td| �}y |jt|�� | j d� W n8 t
k
r� } z | j |j d d| � W Y d d }~X nX d S )Nr� zsupervisord.logz1 [supervisord]
logfile=%s
znothing raisedr z9The directory named as part of the path %s does not exist)
r| rU r� r� r� r� r r' r r� r" rN r )r r� Z logfile_with_nonexistent_dirr� r� r r r �1test_read_config_logfile_with_nonexistent_dirpathy s
zDServerOptionsTests.test_read_config_logfile_with_nonexistent_dirpathc C s\ | j � }y|jt� � | jd� W n4 tk
rV } z| j|jd d� W Y d d }~X nX d S )Nznothing raisedr z..ini file does not include supervisord section)r| r' r r� r" rN r )r r� r� r r r r� � s zLServerOptionsTests.test_read_config_no_supervisord_section_raises_valueerrorc C sf | j � }td�}y |jt|�� | jd� W n4 tk
r` } z| j|jd d� W Y d d }~X nX d S )NzD [supervisord]
[include]
;no files=
znothing raisedr z5.ini file has [include] section, but no files setting)r| r r' r r� r" rN r )r r� r� r� r r r �8test_read_config_include_with_no_files_raises_valueerror� s zKServerOptionsTests.test_read_config_include_with_no_files_raises_valueerrorc C s2 | j � }td�}|jt|�� | j|jdg� d S )NzM [supervisord]
[include]
files=nonexistent/*
z-No file matches via include "./nonexistent/*")r| r r' r rN r )r r� r� r r r �<test_read_config_include_with_no_matching_files_logs_warning� s zOServerOptionsTests.test_read_config_include_with_no_matching_files_logs_warningc " C s0 t j� }tjj|d�}tj|� tjj|d�}td||f �}t|d��}|j|� W d Q R X tjj|d�}t|d��}|jd� W d Q R X tjj|d�}t|d��}|jd� W d Q R X | j � }z|j
|� W d t j |d d
� X |j
j} | jt| j�d � d | }
| j|
|jk� d | }
| j|
|jk� d S )
Nzconf.dzsupervisord.confz` [supervisord]
[include]
files=%s/conf.d/*.conf %s/conf.d/*.ini
r� za.confz [inet_http_server]
port=8000
za.iniz"[unix_http_server]
file=/tmp/file
T)r� rb z'Included extra file "%s" during parsing)rq r� rU r� r� �mkdirr r� r� r| r' r� r� r! r� rN rO r� rl r ) r r� �conf_dr� r� rs � conf_fileZini_filer� r6 ro r r r �*test_read_config_include_reads_extra_files� s0
z=ServerOptionsTests.test_read_config_include_reads_extra_filesc C s. t j� }tjj|d�}tj|� tjj|d�}td| �}t|d��}|j|� W d Q R X ddl m
} |d d� }xJt |�D ]>}tjj|d| �} t| d��}|jd ||f � W d Q R X q|W | j � }
z|
j
|� W d tj|d
d � X g } x0t|�D ]$}tjj|d| �} | jd | � q�W | j|
j| � d S )
Nzconf.dzsupervisord.confzP [supervisord]
[include]
files=%s/conf.d/*.conf
r� r )�letters� z%s.confz [program:%s]
command=/bin/%s
T)r� z'Included extra file "%s" during parsing)rq r� rU r� r� r r r� r� �supervisor.compatr �reversedr| r' r� r� �sortedr\ rN r ) r r� r
r� r� rs r Za_zZletter�filenamer� Z
expected_msgsr r r �4test_read_config_include_reads_files_in_sorted_order� s2
zGServerOptionsTests.test_read_config_include_reads_files_in_sorted_orderc
' C s( t j� }tjj|d�}tj|� tjj|d�}td| �}t|d��}|j|� W d Q R X tjj|d�}t|d��}|jd� W d Q R X | j � }z�y|j
|� | j d� W nd t k
�r } zF| j
d|jd k� | j
||jd k� d
| } | j
| |jk� W Y d d }~X nX W d tj|d d � X d S )
Nzconf.dzsupervisord.confzP [supervisord]
[include]
files=%s/conf.d/*.conf
r� za.confz[inet_http_server]
junk
znothing raisedzcontains parsing errors:r z'Included extra file "%s" during parsingT)r� )rq r� rU r� r� r r r� r� r| r' r� r" rl r r r� r� )
r r� r
r� r� rs Zmalformed_filer� r� ro r r r �-test_read_config_include_extra_file_malformed� s*
&[email protected]_read_config_include_extra_file_malformedc
C s� t j� }tjj|d�}tj|� tjj|d�}td|df �}t|d��}|j|� W d Q R X tjj|dt j
� �}t|d��}|jd� W d Q R X | j � }z|j |� W d t
j|dd � X |jj}| jt|j�d
� d | } | j| |jk� d S ) Nzconf.dzsupervisord.confzQ [supervisord]
[include]
files=%s/conf.d/%s.conf
z%(host_node_name)sr� z%s.confz [inet_http_server]
port=8000
T)r� r` z'Included extra file "%s" during parsing)rq r� rU r� r� r r r� r� �platform�noder| r' r� r� r! r� rN rO r� rl r )
r r� r
r� r� rs r r� r6 ro r r r �/test_read_config_include_expands_host_node_name s&
zBServerOptionsTests.test_read_config_include_expands_host_node_namec C sz t jjt jjt jjt��dd�}t jj|�}t jj|d�}| j� }||_|jd� |j j
}| j |j |� | j |j
|� d S )NZfixturesz include.confZexampleT)rU r� r� r� r� r� r| r4 Zprocess_config_filer! r� rN r� r� )r ZconfZ root_hereZ include_here�parserr� r r r �%test_read_config_include_expands_here2 s
z8ServerOptionsTests.test_read_config_include_expands_herec C s^ ddl m} y|ddd� W n4 tk
rP } z| j|jd d� W Y d d }~X n
X td��d S )Nr )�readFilez /nottherer� ZFAILEDz Didn't raise)r r r" rN r �AssertionError)r r r; r r r �test_readFile_failed? s $z'ServerOptionsTests.test_readFile_failedc C s | j � }| jtj� |j� � d S )N)r| rN rU �getpidZget_pid)r r� r r r � test_get_pidH s z ServerOptionsTests.test_get_pidc C s` | j � }|jjtjd � |jjtjd � | j|j� tj� | j|j� tj� | j|j� d � d S )N)r| Zsignal_receiver�receiver� r� �SIGCHLDrN �
get_signal)r r� r r r �,test_get_signal_delegates_to_signal_receiverL s z?ServerOptionsTests.test_get_signal_delegates_to_signal_receiverc C s, | j � }ddlm} | j||jdd d � d S )Nr )�NotFoundz
/not/there)r| r r& r9 �check_execv_args)r r� r& r r r �'test_check_execv_args_cant_find_commandT s
z:ServerOptionsTests.test_check_execv_args_cant_find_commandc C s4 | j � }ddlm} | j||jddgtjd�� d S )Nr )�
NotExecutablez /etc/passwdz
etc/passwd)r| r r) r9 r' rU �stat)r r� r) r r r �#test_check_execv_args_notexecutableZ s
z6ServerOptionsTests.test_check_execv_args_notexecutablec C s4 | j � }ddlm} | j||jddgtjd�� d S )Nr )r) �/)r| r r) r9 r' rU r* )r r� r) r r r �test_check_execv_args_isdira s
z.ServerOptionsTests.test_check_execv_args_isdirc sd | j � }g � � fdd�}||_td�|_ddg}|j|d� | jt� �d� | j� d d | � d S )
Nc s � j | � d S )N)r\ )�message)�recorderr r � record_usagel s zSServerOptionsTests.test_realize_positional_args_not_supported.<locals>.record_usagez
[supervisord]rg rh )r r` r z*positional arguments are not supported: %s)r| �usager r4 rT rN rO )r r� r0 r r )r/ r �*test_realize_positional_args_not_supportedh s
z=ServerOptionsTests.test_realize_positional_args_not_supportedc sZ | j � }g � � fdd�}||_td�|_|jdgd� | jt� �d� | j� d d� d S ) Nc s � j | � d S )N)r\ )r. )r/ r r r0 { s zBServerOptionsTests.test_realize_getopt_error.<locals>.record_usagez
[supervisord]z--bad=1)r r` r zoption --bad not recognized)r| r1 r r4 rT rN rO )r r� r0 r )r/ r �test_realize_getopt_errorw s
z,ServerOptionsTests.test_realize_getopt_errorc C s� | j � }td�}ddlm} |� }|j|� t|�|_|jt|�� |jg d� |j j
}| j |j d d t
j� | j |j d d d� | j |j d d d � | j |j d d
d� d S )Nz� [unix_http_server]
file=/tmp/supvtest.sock
username=johndoe
password=passwordhere
[supervisord]
; ...
r )�UnhosedConfigParser)r r� �filez/tmp/supvtest.sock�chmodi� �chownr` ���r8 )r8 r8 )r| r r r4 � read_stringr r4 r' rT r! r� rN r� r� �AF_UNIX)r r� r� r4 rt r6 r r r �test_options_afunix� s
z&ServerOptionsTests.test_options_afunixc C s� | j � }td�}ddlm} |� }|j|� t|�|_|jt|�� |jg d� |j j
}| j |j d d t
j� | j |j d d d� | j |j d d d � d S )
Nz� [unix_http_server]
file=/tmp/supvtest.sock
username=johndoe
password=passwordhere
chmod=0755
[supervisord]
; ...
r )r4 )r r� r5 z/tmp/supvtest.sockr6 i� )r| r r r4 r9 r r4 r' rT r! r� rN r� r� r: )r r� r� r4 rt r6 r r r �&test_options_afunix_chxxx_values_valid� s
z9ServerOptionsTests.test_options_afunix_chxxx_values_validc C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nzc [supervisord]
[unix_http_server]
file=/tmp/file
chmod=NaN
znothing raisedr zInvalid chmod value NaN) r| r r r4 r' r� r" rN r )r r� r� r� r r r � test_options_afunix_chmod_bad� s
z0ServerOptionsTests.test_options_afunix_chmod_badc C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nzs [supervisord]
[unix_http_server]
file=/tmp/file
chown=thisisnotavaliduser
znothing raisedr z+Invalid sockchown value thisisnotavaliduser) r| r r r4 r' r� r" rN r )r r� r� r� r r r � test_options_afunix_chown_bad� s
z0ServerOptionsTests.test_options_afunix_chown_badc C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )NzL [supervisord]
[unix_http_server]
;no file=
znothing raisedr z,section [unix_http_server] has no file value) r| r r r4 r' r� r" rN r )r r� r� r� r r r �test_options_afunix_no_file� s
z.ServerOptionsTests.test_options_afunix_no_filec C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nz� [supervisord]
[unix_http_server]
file=/tmp/supvtest.sock
username=usernamehere
;no password=
chmod=0755
znothing raisedr z�Section [unix_http_server] contains incomplete authentication: If a username or a password is specified, both the username and password must be specified) r| r r r4 r' r� r" rN r )r r� r� r� r r r �-test_options_afunix_username_without_password� s
[email protected]_options_afunix_username_without_passwordc C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nz� [supervisord]
[unix_http_server]
file=/tmp/supvtest.sock
;no username=
password=passwordhere
chmod=0755
znothing raisedr z�Section [unix_http_server] contains incomplete authentication: If a username or a password is specified, both the username and password must be specified) r| r r r4 r' r� r" rN r )r r� r� r� r r r �-test_options_afunix_password_without_username� s
[email protected]_options_afunix_password_without_usernamec C s� | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}|jd }| j|d tj� | j|d tjj|d
�� d S ) Nza [supervisord]
[unix_http_server]
file=%(here)s/supervisord.sock
zsupervisord.confr� )r T)r� r r� r5 zsupervisord.sock)r| r rq r� rU r� r� r� r� r4 rT r� r� r! r� r� rN r� r: )r r� r� r� r� rs r6 Z
serverconfr r r �%test_options_afunix_file_expands_here s
z8ServerOptionsTests.test_options_afunix_file_expands_herec C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nz� [supervisord]
[inet_http_server]
file=/tmp/supvtest.sock
username=usernamehere
;no password=
chmod=0755
znothing raisedr z�Section [inet_http_server] contains incomplete authentication: If a username or a password is specified, both the username and password must be specified) r| r r r4 r' r� r" rN r )r r� r� r� r r r �-test_options_afinet_username_without_password* s
[email protected]_options_afinet_username_without_passwordc C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )Nzn [supervisord]
[inet_http_server]
password=passwordhere
;no username=
znothing raisedr z�Section [inet_http_server] contains incomplete authentication: If a username or a password is specified, both the username and password must be specified) r| r r r4 r' r� r" rN r )r r� r� r� r r r �-test_options_afinet_password_without_username@ s
[email protected]_options_afinet_password_without_usernamec C sp | j � }td�}t|�|_y |jt|�� | jd� W n4 tk
rj } z| j|jd d� W Y d d }~X nX d S )NzL [supervisord]
[inet_http_server]
;no port=
znothing raisedr z,section [inet_http_server] has no port value) r| r r r4 r' r� r" rN r )r r� r� r� r r r �test_options_afinet_no_portT s
z.ServerOptionsTests.test_options_afinet_no_portc
C s~ t j� }t|d��}|jd� W d Q R X | j� }d|_G dd� d�}tj|d�|� fg|_d|_ |j
� | j t j
j|�� d S )Nr� rg Tc @ s e Zd ZdS )z=ServerOptionsTests.test_cleanup_afunix_unlink.<locals>.ServerN)r r r r r r r �Serverj s rF )r� r5 rw )rq �mktempr� r� r| �unlink_socketfilesr� r: � httpserversr� �cleanupr rU r� �exists)r r� rs r� rF r r r �test_cleanup_afunix_unlinkd s
z-ServerOptionsTests.test_cleanup_afunix_unlinkc C s� t j� }zvt|d��}|jd� W d Q R X | j� }G dd� d�}tj|d�|� fg|_d|_d|_ |j
� | j t j
j|�� W d yt j|� W n tk
r� Y nX X d S )Nr� rg c @ s e Zd ZdS )z?ServerOptionsTests.test_cleanup_afunix_nounlink.<locals>.ServerN)r r r r r r r rF x s rF )r� r5 rw F)rq rG r� r� r| r� r: rI r� rH rJ rl rU r� rK �unlink�OSError)r r� rs r� rF r r r � test_cleanup_afunix_nounlinkr s
z/ServerOptionsTests.test_cleanup_afunix_nounlinkc C s� t jjt jjt�d�}tj� }z�t|d��}|jd� W d Q R X | j � }d|_
G dd� d�}t j |d�|� ft j |d�|� fg|_
d|_|j� | jt jj|�� W d yt j|� W n tk
r� Y nX X d S ) N�notfoundr� rg Tc @ s e Zd ZdS )zMServerOptionsTests.test_cleanup_afunix_ignores_oserror_enoent.<locals>.ServerN)r r r r r r r rF � s rF )r� r5 rw )rU r� r� r� r� rq rG r� r� r| rH r� r: rI r� rJ r rK rM rN )r rP Z
socketnamers r� rF r r r �*test_cleanup_afunix_ignores_oserror_enoent� s" z=ServerOptionsTests.test_cleanup_afunix_ignores_oserror_enoentc C s� t j� }zht|d��}|jd� W d Q R X | j� }||_t� |_|j� | j |j
� |j � | j t
jj|�� W d yt
j|� W n tk
r� Y nX X d S )Nr� �2)rq rG r� r� r| r� r �logger�
write_pidfilerl �unlink_pidfilerJ r rU r� rK rM rN )r r� rs r� r r r � test_cleanup_removes_pidfile� s z/ServerOptionsTests.test_cleanup_removes_pidfilec C s0 t jjt jjt�d�}| j� }||_|j� d S )NrP )rU r� r� r� r� r| r� rJ )r rP r� r r r �+test_cleanup_pidfile_ignores_oserror_enoent� s z>ServerOptionsTests.test_cleanup_pidfile_ignores_oserror_enoentc C s� t j� }t|d��}|jd� W d Q R X z8| j� }||_| j|j� |j� | j t
j j |�� W d yt
j
|� W n tk
r� Y nX X d S )Nr� Z1234)rq rG r� r� r| r� r rU rJ rl rU r� rK rM rN )r r� rs r� r r r �=test_cleanup_does_not_remove_pidfile_from_another_supervisord� s zPServerOptionsTests.test_cleanup_does_not_remove_pidfile_from_another_supervisordc C s� t j� }z`t|d��}|jd� W d Q R X | j� }||_ti �}||_| j|j � |j
� | j |j � W d yt j
|� W n tk
r� Y nX X d S )Nr� rR )rq rG r� r� r| r� r �pollerr �closedrJ rl rU rM rN )r r� rs r� rY r r r �test_cleanup_closes_poller� s z-ServerOptionsTests.test_cleanup_closes_pollerc sR | j � �d�_g � � fdd�}td|��fdd��}|� | j� ddd d
g� d S ) Nr� c s | dkr t �� j| � d S )N� )rN r\ )�fd)rZ r r �close� s zWServerOptionsTests.test_cleanup_fds_closes_5_upto_minfds_ignores_oserror.<locals>.closezos.closec s � j � d S )N)Z cleanup_fdsr )r� r r rs � s zSServerOptionsTests.test_cleanup_fds_closes_5_upto_minfds_ignores_oserror.<locals>.fr� rK � � )r| r� r rN )r r^ rs r )rZ r� r �5test_cleanup_fds_closes_5_upto_minfds_ignores_oserror� s zHServerOptionsTests.test_cleanup_fds_closes_5_upto_minfds_ignores_oserrorc C sB | j � }G dd� d�}|� }i |fg|_|j� | j|jd� d S )Nc @ s e Zd ZdZdd� ZdS )z9ServerOptionsTests.test_close_httpservers.<locals>.ServerFc S s
d| _ d S )NT)rZ )r r r r r^ � s z?ServerOptionsTests.test_close_httpservers.<locals>.Server.closeN)r r r rZ r^ r r r r rF � s rF T)r| rI Zclose_httpserversrN rZ )r r� rF Zserverr r r �test_close_httpservers� s z)ServerOptionsTests.test_close_httpserversc C s. | j � }t� }||_|j� | j|jd� d S )NT)r| r rS Z close_loggerrN rZ )r r� rS r r r �test_close_logger� s
z$ServerOptionsTests.test_close_loggerc sT | j � }g � � fdd�}||_ddddddd �}|j|� | jt� �dddg� d S )
Nc s � j | � d S )N)r\ )r] )rZ r r �close_fd s z<ServerOptionsTests.test_close_parent_pipes.<locals>.close_fdr r` rb r� rL r� )�stdinre rd � child_stdin� child_stdout� child_stderr)r| rd �close_parent_pipesrN r )r r� rd �pipesr )rZ r �test_close_parent_pipes� s
z*ServerOptionsTests.test_close_parent_pipesc s@ | j � }g � � fdd�}||_dd i}|j|� | j� g � d S )Nc s � j | � d S )N)r\ )r] )rZ r r rd
s zOServerOptionsTests.test_close_parent_pipes_ignores_fd_of_none.<locals>.close_fdre )r| rd ri rN )r r� rd rj r )rZ r �*test_close_parent_pipes_ignores_fd_of_none
s
z=ServerOptionsTests.test_close_parent_pipes_ignores_fd_of_nonec sT | j � }g � � fdd�}||_ddddddd �}|j|� | jt� �dddg� d S )
Nc s � j | � d S )N)r\ )r] )rZ r r rd s z;ServerOptionsTests.test_close_child_pipes.<locals>.close_fdr r` rb r� rL r� )re re rd rf rg rh )r| rd Zclose_child_pipesrN r )r r� rd rj r )rZ r �test_close_child_pipes s
z)ServerOptionsTests.test_close_child_pipesc sD | j � }g � � fdd�}||_dd i}|j|� | jt� �g � d S )Nc s � j | � d S )N)r\ )r] )rZ r r rd " s zNServerOptionsTests.test_close_child_pipes_ignores_fd_of_none.<locals>.close_fdrf )r| rd ri rN r )r r� rd rj r )rZ r �)test_close_child_pipes_ignores_fd_of_none s
z<ServerOptionsTests.test_close_child_pipes_ignores_fd_of_nonec C sP | j � }t� }t� g|_||_|j� | j|jd jd� | j|jd d� d S )Nr Tzsupervisord logreopen)r| r ZhandlersrS Z
reopenlogsrN Zreopened�data)r r� rS r r r �test_reopenlogs) s
z"ServerOptionsTests.test_reopenlogsc C s� t j� }z�| j� }t� |_||_|j� | jtj j
|�� t |d��}t |j
� j� �}W d Q R X | j|tj� � |jjd }| j|jd�� | j|j� W d ytj|� W n tk
r� Y nX X d S )N�rr z supervisord started with pid)rq rG r| r rS r� rT rl rU r� rK r� �int�read�striprN r ro rn rU rM rN )r r� r� rs �pidro r r r �test_write_pidfile_ok2 s" z(ServerOptionsTests.test_write_pidfile_okc C sN d}| j � }t� |_||_|j� |jjd }| j|jd�� | j|j � d S )Nz/cannot/possibly/existr zcould not write pidfile)
r| r rS r� rT ro rl rn r rU )r r� r� ro r r r �test_write_pidfile_failF s z*ServerOptionsTests.test_write_pidfile_failc C sp | j � }tj� \}}tj|d� tj|td�� |j|� | jttj|d� |j|� | jttj|td�� d S )Nr rg ) r| rU �pipers r� r rd r9 rN )r r� ZinnieZoutier r r �
test_close_fdP s
z ServerOptionsTests.test_close_fdzos.close)Z side_effectc C s | j � }|jd� d S )Nr )r| rd )r r� r r r � test_close_fd_ignores_oserrorZ s z0ServerOptionsTests.test_close_fd_ignores_oserrorc C s` | j � }td�}ddlm} |� }|j|� |j|dd�}| jt|�d� |d }| j|jd� | j|j d� | j|j
d � | j|j d � | j|j d
� | j|j
d
� | j|jd� | j|jd � | j|jd� | j|jd � | j|jd � | j|jtj� | j|jd � | j|jd � | j|jd
� | j|jd
dg� | j|jd � | j|jdddd�� d S )Na~ [program:foo]
command = /bin/cat
priority = 1
autostart = false
autorestart = false
startsecs = 100
startretries = 100
user = root
stdout_logfile = NONE
stdout_logfile_backups = 1
stdout_logfile_maxbytes = 100MB
stdout_events_enabled = true
stopsignal = KILL
stopwaitsecs = 100
killasgroup = true
exitcodes = 1,4
redirect_stderr = false
environment = KEY1=val1,KEY2=val2,KEY3=%(process_num)s
numprocs = 2
process_name = %(group_name)s_%(program_name)s_%(process_num)02d
r )r4 z program:foorh rb Z
bar_foo_00z/bin/catF�d i @Tr` rL Zval1Zval2�0)ZKEY1ZKEY2ZKEY3) r| r r r4 r9 �processes_from_sectionrN rO r, r� r� r� r� r� r� r� �stdout_capture_maxbytesr� �stdout_events_enabledr� r� r� r� r� r� r^ �redirect_stderrr� )r r� r� r4 rt �pconfigs�pconfigr r r �test_processes_from_section_ s8
z.ServerOptionsTests.test_processes_from_sectionc C s\ | j � }td�}ddlm} |� }|j|� |j|dd�}dtj� }| j|d j |� d S )NzS [program:foo]
command = /bin/foo --host=%(host_node_name)s
r )r4 z program:foorh z/bin/foo --host=)
r| r r r4 r9 r} r r rN r� )r r� r� r4 rt r� �expectedr r r �4test_processes_from_section_host_node_name_expansion� s
zGServerOptionsTests.test_processes_from_section_host_node_name_expansionc C s� | j � }td�}ddlm} |� }|j|� |j|dd�}| jt|�d� x�dD ]�}| j|| jd| � | j|| j d | � | j|| j
d
| � | j|| j d | � | j|| j d | � | j|| j
d
d| i� qPW d S )NaX [program:foo]
process_name = foo_%(process_num)d
command = /bin/foo --num=%(process_num)d
directory = /tmp/foo_%(process_num)d
stderr_logfile = /tmp/foo_%(process_num)d_stderr
stdout_logfile = /tmp/foo_%(process_num)d_stdout
environment = NUM=%(process_num)d
numprocs = 2
r )r4 z program:foorh rb r` zfoo_%dz/bin/foo --num=%dz /tmp/foo_%dz/tmp/foo_%d_stderrz/tmp/foo_%d_stdoutZNUMz%d)r r` )r| r r r4 r9 r} rN rO r, r� r� �stderr_logfiler� r� )r r� r� r4 rt r� �numr r r �1test_processes_from_section_process_num_expansion� s"
zDServerOptionsTests.test_processes_from_section_process_num_expansionc C s� | j � }td�}ddlm} |� }|j|� |j|dd�}| jt|�d� x8d
D ]0}| j|| jd| � | j|| j d d � qPW d S ) Nz� [program:foo]
process_name = foo_%(process_num)d
command = /bin/foo --numprocs=%(numprocs)d
numprocs = 2
r )r4 z program:foorh rb r` zfoo_%dz/bin/foo --numprocs=%d)r r` )
r| r r r4 r9 r} rN rO r, r� )r r� r� r4 rt r� r� r r r �.test_processes_from_section_numprocs_expansion� s
zAServerOptionsTests.test_processes_from_section_numprocs_expansionc C sZ | j � }td�}ddlm} |� }ddi|_|j|� |j|dd�}| j|d jd� d S )Nz^ [program:foo]
command = /bin/cat
directory = /tmp/%(ENV_FOO)s
r )r4 �ENV_FOOrh z program:fooz/tmp/bar) r| r r r4 �
expansionsr9 r} rN r� )r r� r� r4 rt r� r r r �-test_processes_from_section_expands_directory� s
[email protected]_processes_from_section_expands_directoryc C s^ | j � }td�}ddlm} |� }|j|� |j|dd�}dtjd }| j|d j |� d S )NzO [program:foo]
command = /bin/foo --path='%(ENV_PATH)s'
r )r4 z program:foorh z/bin/foo --path='%s'�PATH)
r| r r r4 r9 r} rU rV rN r� )r r� r� r4 rt r� r� r r r �;test_processes_from_section_environment_variables_expansion� s
zNServerOptionsTests.test_processes_from_section_environment_variables_expansionc C sb | j � }td�}ddlm} |� }|j|� |j|dd�}dtjd }| j|d j d |� d S )Nzl [program:foo]
command = /bin/foo
environment = PATH='/foo/bar:%(ENV_PATH)s'
r )r4 z program:foorh z /foo/bar:%sr� )
r| r r r4 r9 r} rU rV rN r� )r r� r� r4 rt r� r� r r r �6test_processes_from_section_expands_env_in_environment� s
zIServerOptionsTests.test_processes_from_section_expands_env_in_environmentc C sb | j � }td�}ddlm} |� }|j|� |j|dd�}| j|jd d� | j|d jd � d S )Nz~ [program:foo]
command = /bin/foo
redirect_stderr = true
stderr_logfile = /tmp/logfile
r )r4 z program:foorh zyFor [program:foo], redirect_stderr=true but stderr_logfile has also been set to a filename, the filename has been ignored) r| r r r4 r9 r} rN r r� )r r� r� r4 rt r� r r r �9test_processes_from_section_redirect_stderr_with_filename� s
zLServerOptionsTests.test_processes_from_section_redirect_stderr_with_filenamec C st | j � }td�}ddlm} |� }|j|� |j|dd�}| j|jd d� | j|d jd � | j|d j d� d S )NzY [program:foo]
command = /bin/foo
stdout_logfile = syslog
r )r4 z program:foorh z�For [program:foo], stdout_logfile=syslog but this is deprecated and will be removed. Use stdout_syslog=true to enable syslog instead.T)
r| r r r4 r9 r} rN r r� �
stdout_syslog)r r� r� r4 rt r� r r r �=test_processes_from_section_rewrites_stdout_logfile_of_syslog s
zPServerOptionsTests.test_processes_from_section_rewrites_stdout_logfile_of_syslogc C st | j � }td�}ddlm} |� }|j|� |j|dd�}| j|jd d� | j|d jd � | j|d j d� d S )NzY [program:foo]
command = /bin/foo
stderr_logfile = syslog
r )r4 z program:foorh z�For [program:foo], stderr_logfile=syslog but this is deprecated and will be removed. Use stderr_syslog=true to enable syslog instead.T)
r| r r r4 r9 r} rN r r� �
stderr_syslog)r r� r� r4 rt r� r r r �=test_processes_from_section_rewrites_stderr_logfile_of_syslog s
zPServerOptionsTests.test_processes_from_section_rewrites_stderr_logfile_of_syslogc C s^ | j � }td�}ddlm} |� }|j|� |j|dd�}| j|jg � | j|d jd � d S )Nzv [program:foo]
command = /bin/foo
redirect_stderr = true
stderr_logfile = auto
r )r4 z program:foorh ) r| r r r4 r9 r} rN r r� )r r� r� r4 rt r� r r r �5test_processes_from_section_redirect_stderr_with_auto( s
zHServerOptionsTests.test_processes_from_section_redirect_stderr_with_autoc C s@ t d�}ddlm} ddlm} | j� }tj� ddddd d
d d d d
dddd dddddddddddd
ddd� |_|� }|j|_ |j
|� t |�|_ |j
t |�� |jg d � | j|jd |j � | j|jd |j � | j|jd � | j|jd � | j|jtj� | j|jd!� | j|jd!� | j|jd"� | j|jd#� | j|jd$� | j|j |j d% � | j|j d!� |j j }| j|j d d& t!j"� | j|j d d' d(� | j|j d d) d*� | j|j d d+ d� | j|j d d, d� |j#d }| j|j$d-� | j|j%d.� | jt&|j'�d/� |j'd }| j|j$d-� | j|j(d0� | j|j%d.� | j|j)d$� | j|j*|j+� | j|j,d1� | j|j-d � | j|j.d� | j|j/d� | j|j0t1j2� | j|j3d1� | j|j4d!� | j|j5d!� | j|j6|j7d�� | j|j8d2� | j|j9dg� | j|j:d� | j|j;d2� | j|j<t=d3d4�� d S )5Na^ [supervisord]
logfile = %(ENV_HOME)s/supervisord.log
logfile_maxbytes = %(ENV_SUPD_LOGFILE_MAXBYTES)s
logfile_backups = %(ENV_SUPD_LOGFILE_BACKUPS)s
loglevel = %(ENV_SUPD_LOGLEVEL)s
nodaemon = %(ENV_SUPD_NODAEMON)s
minfds = %(ENV_SUPD_MINFDS)s
minprocs = %(ENV_SUPD_MINPROCS)s
umask = %(ENV_SUPD_UMASK)s
identifier = supervisor_%(ENV_USER)s
nocleanup = %(ENV_SUPD_NOCLEANUP)s
childlogdir = %(ENV_HOME)s
strip_ansi = %(ENV_SUPD_STRIP_ANSI)s
environment = FAKE_ENV_VAR=/some/path
[inet_http_server]
port=*:%(ENV_HTSRV_PORT)s
username=%(ENV_HTSRV_USER)s
password=%(ENV_HTSRV_PASS)s
[program:cat1]
command=%(ENV_CAT1_COMMAND)s --logdir=%(ENV_CAT1_COMMAND_LOGDIR)s
priority=%(ENV_CAT1_PRIORITY)s
autostart=%(ENV_CAT1_AUTOSTART)s
user=%(ENV_CAT1_USER)s
stdout_logfile=%(ENV_CAT1_STDOUT_LOGFILE)s
stdout_logfile_maxbytes = %(ENV_CAT1_STDOUT_LOGFILE_MAXBYTES)s
stdout_logfile_backups = %(ENV_CAT1_STDOUT_LOGFILE_BACKUPS)s
stopsignal=%(ENV_CAT1_STOPSIGNAL)s
stopwaitsecs=%(ENV_CAT1_STOPWAIT)s
startsecs=%(ENV_CAT1_STARTWAIT)s
startretries=%(ENV_CAT1_STARTRETRIES)s
directory=%(ENV_CAT1_DIR)s
umask=%(ENV_CAT1_UMASK)s
r )r� )r4 r� r� r� r� Z51MBZ10�infoZfalseZ1024Z200Z002�truez/bin/customcatz
/path/to/logs�3�rootz /tmp/cat.logZ78KBrR ZKILL�5z/tmp) r� r� ZENV_HTSRV_PORTZENV_HTSRV_USERZENV_HTSRV_PASSZENV_SUPD_LOGFILE_MAXBYTESZENV_SUPD_LOGFILE_BACKUPSZENV_SUPD_LOGLEVELZENV_SUPD_NODAEMONZENV_SUPD_SILENTZENV_SUPD_MINFDSZENV_SUPD_MINPROCSZENV_SUPD_UMASKZENV_SUPD_NOCLEANUPZENV_SUPD_STRIP_ANSIZENV_CAT1_COMMANDZENV_CAT1_COMMAND_LOGDIRZENV_CAT1_PRIORITYZENV_CAT1_AUTOSTARTZ
ENV_CAT1_USERZENV_CAT1_STDOUT_LOGFILEZ ENV_CAT1_STDOUT_LOGFILE_MAXBYTESZ ENV_CAT1_STDOUT_LOGFILE_BACKUPSZENV_CAT1_STOPSIGNALZENV_CAT1_STOPWAITZENV_CAT1_STARTWAITZENV_CAT1_STARTRETRIESZ ENV_CAT1_DIRZENV_CAT1_UMASK)r z %(ENV_HOME)s/supervisord.logzsupervisor_%(ENV_USER)si 0r� Fi �� Tr� r� r� rw r� i�# r� r� r� r� r` z%/bin/customcat --logdir=/path/to/logsr� rb z
/some/path)r� )>r r� r� r r4 r| rq r� r� r� r9 r r4 r' rT rN r� r� r� r� r� r �INFOr� r� r� r� r� r� Z
strip_ansir! r� r� r� r� r� r, r� rO 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� r4 r� rt r6 r� r� r r r r� 7 s� #
z;ServerOptionsTests.test_options_with_environment_expansionsc C s� | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X | j
|jtjj|�� | j
|jtjj|�� | j
|jtjj|d�� | j
|jtjj|d�� d S ) Nz� [supervisord]
childlogdir=%(here)s
directory=%(here)s
logfile=%(here)s/supervisord.log
pidfile=%(here)s/supervisord.pid
zsupervisord.confr� )r T)r� zsupervisord.logzsupervisord.pid)r| r rq r� rU r� r� r� r� r4 rT r� r� rN r� r� r� r� )r r� r� r� r� rs r r r �-test_options_supervisord_section_expands_here� s& [email protected]_options_supervisord_section_expands_herec C s� | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}|jd }| j|jd� |jd }| j|jtjj|d �� d S )
Nz�
[supervisord]
environment=CMD=/bin/from/supervisord/section
[program:cmd]
command=%(ENV_CMD)s
zsupervisord.confr� )r T)r� r �cmdz /bin/from/supervisord/section)r| r rq r� rU r� r� r� r� r4 rT r� r� r! r� r� rN r, r� r� ) r r� r� r� r� rs r6 �groupr r r r �>test_options_program_section_expands_env_from_supervisord_sect� s"
zQServerOptionsTests.test_options_program_section_expands_env_from_supervisord_sectc C s� | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}|jd }| j|jd� |jd }| j|jtjj|d �� d S )
Nz�
[supervisord]
environment=CMD=/bin/from/supervisord/section
[program:cmd]
command=%(ENV_CMD)s
environment=CMD=/bin/from/program/section
zsupervisord.confr� )r T)r� r r� z/bin/from/program/section)r| r rq r� rU r� r� r� r� r4 rT r� r� r! r� r� rN r, r� r� ) r r� r� r� r� rs r6 r� r r r r �:test_options_program_section_expands_env_from_program_sect� s"
zMServerOptionsTests.test_options_program_section_expands_env_from_program_sectc C s4 | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}|jd }| j|jd� |jd }| j|jtjj|d �� | j|jtjj|d
�� | j|jd tjj|d �i� | j|jd
tjj|d� � | j|jtjj|d�� | j|jtjj|d�� d S )Na-
[supervisord]
[program:cat]
command=%(here)s/bin/cat
directory=%(here)s/thedirectory
environment=FOO=%(here)s/foo
serverurl=unix://%(here)s/supervisord.sock
stdout_logfile=%(here)s/stdout.log
stderr_logfile=%(here)s/stderr.log
zsupervisord.confr� )r T)r� r r� � thedirectoryzbin/cat�FOOrg zunix://zsupervisord.sockz
stdout.logz
stderr.log)r| r rq r� rU r� r� r� r� r4 rT r� r� r! r� r� rN r, r� r� r� r� r� r� r� ) r r� r� r� r� rs r6 r� r r r r �)test_options_program_section_expands_here s6
z<ServerOptionsTests.test_options_program_section_expands_herec C s4 | j � }td�}tj� }tjj|d�}t|d��}|j|� W d Q R X z||_ |j
g d� W d t j |dd� X |j
j}|jd }| j|jd� |jd }| j|jtjj|d �� | j|jtjj|d
�� | j|jd tjj|d �i� | j|jd
tjj|d� � | j|jtjj|d�� | j|jtjj|d�� d S )NaP
[supervisord]
[eventlistener:memmon]
events=TICK_60
command=%(here)s/bin/memmon
directory=%(here)s/thedirectory
environment=FOO=%(here)s/foo
serverurl=unix://%(here)s/supervisord.sock
stdout_logfile=%(here)s/stdout.log
stderr_logfile=%(here)s/stderr.log
zsupervisord.confr� )r T)r� r Zmemmonr� z
bin/memmonr� rg zunix://zsupervisord.sockz
stdout.logz
stderr.log)r| r rq r� rU r� r� r� r� r4 rT r� r� r! r� r� rN r, r� r� r� r� r� r� r� ) r r� r� r� r� rs r6 r� r r r r �/test_options_eventlistener_section_expands_here+ s6
zBServerOptionsTests.test_options_eventlistener_section_expands_herec
C s� | j � }td�}|d7 }tj� }tjj|d�}t|d��}|j|� W d Q R X z"ddd�|_ ||_
|j g d� W d t j
|d d
� X |jj}| j|jtjj|d �� |jd }|jd }d
tjj|d�tj� f } | j|j| � d S )Nze
[supervisord]
logfile = %(here)s/%(ENV_LOGNAME)s.log
[program:cat]
z\command = %(here)s/bin/cat --foo=%(ENV_FOO)s --num=%(process_num)d --node=%(host_node_name)szsupervisord.confr� Zmainlogrh )Z ENV_LOGNAMEr� )r T)r� z mainlog.logr z %s --foo=bar --num=0 --node=%szbin/cat)r| r rq r� rU r� r� r� r� r� r4 rT r� r� r! r� rN r� r� r� r r r� )
r r� r� r� r� rs r� Z cat_groupZcat_0r� r r r �(test_options_expands_combined_expansionsS s.
z;ServerOptionsTests.test_options_expands_combined_expansionsc C s� t j� }tjj|d�}td�}t|d��}|j|� W d Q R X | j� }zb||_ y|j
dd� | j d� W n< t k
r� } z | j
t|jd �d| � W Y d d }~X nX W d tj|d d
� X d S ) Nzsupervisord.confzq
[supervisord]
[program:cat]
command = /bin/cat
stopsignal = NOTASIGNAL
r� F)ra znothing raisedr zQvalue 'NOTASIGNAL' is not a valid signal name in section 'program:cat' (file: %r)T)r� )rq r� rU r� r� r r� r� r| r4 rX r� r" rN �strr r� r� )r r� r� r� rs r� �er r r �.test_options_error_handler_shows_main_filenamex s" zAServerOptionsTests.test_options_error_handler_shows_main_filenamec ' C s t j� }tjj|d�}td| �}t|d��}|j|� W d Q R X tjj|d�}tj|� tjj|d�}td�}t|d��}|j|� W d Q R X | j � }zb||_
y|j dd� | j d � W n< t
k
r� } z | jt|jd
�d | � W Y d d }~X nX W d tj|d d
� X d S )Nzsupervisord.confzP [supervisord]
[include]
files=%s/conf.d/*.conf
r� zconf.dz
included.confzY [program:cat]
command = /bin/cat
stopsignal = NOTASIGNAL
F)ra znothing raisedr zQvalue 'NOTASIGNAL' is not a valid signal name in section 'program:cat' (file: %r)T)r� )rq r� rU r� r� r r� r� r r| r4 rX r� r" rN r� r r� r� ) r r� r� r� rs r
Z
included_confr� r� r r r �2test_options_error_handler_shows_included_filename� s0
zEServerOptionsTests.test_options_error_handler_shows_included_filenamec C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz) [program:spaces are bad]
r )r4 zprogram:spaces are bad)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �3test_processes_from_section_bad_program_name_spaces� s
zFServerOptionsTests.test_processes_from_section_bad_program_name_spacesc C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz) [program:colons:are:bad]
r )r4 zprogram:colons:are:bad)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �3test_processes_from_section_bad_program_name_colons� s
zFServerOptionsTests.test_processes_from_section_bad_program_name_colonsc C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )NzN [program:foo]
command = /bin/cat
numprocs = 2
r )r4 z program:foo)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �5test_processes_from_section_no_procnum_in_processname� s
zHServerOptionsTests.test_processes_from_section_no_procnum_in_processnamec C s� | j � }td�}ddlm} |� }|j|� y |j|dd � | jd� W n8 tk
r� } z | j|j d j
d�� W Y d d }~X nX d S )Nz [program:foo]
r )r4 z program:fooznothing raisedz6program section program:foo does not specify a command) r| r r r4 r9 r} r� r" rl r rn )r r� r� r4 rt r� r r r �&test_processes_from_section_no_command� s
z9ServerOptionsTests.test_processes_from_section_no_commandc C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz^ [program:foo]
command = /bin/cat
process_name = %(not_there)s
r )r4 z program:foo)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �?test_processes_from_section_missing_replacement_in_process_name� s
zRServerOptionsTests.test_processes_from_section_missing_replacement_in_process_namec C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz` [program:foo]
command = /bin/cat
process_name = %(program_name)
r )r4 z program:foo)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �:test_processes_from_section_bad_expression_in_process_name� s
zMServerOptionsTests.test_processes_from_section_bad_expression_in_process_namec C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz_ [program:foo]
command = /bin/cat
process_name = colons:are:bad
r )r4 z program:foo)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �5test_processes_from_section_bad_chars_in_process_name s
zHServerOptionsTests.test_processes_from_section_bad_chars_in_process_namec C sr | j � }td�}ddlm} |� }|j|� |j|dd�}| jt|�d� |d }| j|jd� | j|j d� d S )Nz| [program:foo]
command = /bin/cat
process_name = %(program_name)s
stopasgroup = true
r )r4 z program:foorh r` T)
r| r r r4 r9 r} rN rO r� r� )r r� r� r4 rt r� r� r r r �;test_processes_from_section_stopasgroup_implies_killasgroup s
zNServerOptionsTests.test_processes_from_section_stopasgroup_implies_killasgroupc C sD | j � }td�}ddlm} |� }|j|� | jt|j|dd � d S )Nz� [program:foo]
command = /bin/cat
process_name = %(program_name)s
stopasgroup = true
killasgroup = false
r )r4 z program:foo)r| r r r4 r9 r9 r" r} )r r� r� r4 rt r r r �>test_processes_from_section_killasgroup_mismatch_w_stopasgroup s
zQServerOptionsTests.test_processes_from_section_killasgroup_mismatch_w_stopasgroupc C s� | j � }td�}ddlm} |� }|j|� y|j|dd � W n4 tk
rr } z| jdt|�k� W Y d d }~X n X | j d� d S )Nzh [program:foo]
command = /bin/cat
environment = KEY1=val1,KEY2=val2,KEY3
r )r4 z program:fooz^Unexpected end of key/value pairs in value 'KEY1=val1,KEY2=val2,KEY3' in section 'program:foo'z9instance.processes_from_section should raise a ValueError)
r| r r r4 r9 r} r" rl r� r� )r r� r� r4 rt r� r r r �=test_processes_from_section_unexpected_end_of_key_value_pairs/ s
zPServerOptionsTests.test_processes_from_section_unexpected_end_of_key_value_pairsc C s� | j � }td�}tjdd���}yB|j|� |j� ddlm} |� }|j|j � |j
|dd � W n: t k
r� } z | j |j
d d|j � W Y d d }~X n X | jd� W d Q R X d S ) Nz2 [program:foo]
;no command
zw+)r� r )r4 z program:foozZprogram section program:foo does not specify a command in section 'program:foo' (file: %r)znothing raised)r| r rq rr r� r r r4 rs r, r} r" rN r r� )r r� r� rs r4 rt r� r r r �=test_processes_from_section_shows_conf_filename_on_valueerrorD s
zPServerOptionsTests.test_processes_from_section_shows_conf_filename_on_valueerrorc C sj | j � }td�}ddlm} |� }t� |_|j|� |j|dd � | j|j d d� | j|j d d� d S )Nz� [program:foo]
command = /bin/foo
stdout_logfile = AUTO
stdout_logfile_maxbytes = 0
stderr_logfile = AUTO
stderr_logfile_maxbytes = 0
r )r4 z program:fooz�For [program:foo], AUTO logging used for stdout_logfile without rollover, set maxbytes > 0 to avoid filling up filesystem unintentionallyr` z�For [program:foo], AUTO logging used for stderr_logfile without rollover, set maxbytes > 0 to avoid filling up filesystem unintentionally)
r| r r r4 r rS r9 r} rN r )r r� r� r4 rt r r r �4test_processes_from_section_autolog_without_rolloverY s
zGServerOptionsTests.test_processes_from_section_autolog_without_rolloverc C s� t d�}ddlm} |� }|j|� | j� }|j|�}| jt|�d� |d }| j|jd� | j|j d� | jt|j
�d� d S )Nz� [program:many]
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 2
priority = 1
r )r4 r` �manyrb ) r r r4 r9 r| �process_groups_from_parserrN rO r, r� r� )r r� r4 rt r� �gconfigs�gconfigr r r �+test_homogeneous_process_groups_from_parserq s
z>ServerOptionsTests.test_homogeneous_process_groups_from_parserc C s t d�}ddlm} ddlm} |� }|j|� | j� }|j|�}| jt |�d� |d }| j|j
d� | j|j |� | jt |j �d� |d }| j|j
d � | j|j
d � | j|j |� | jt |j �d� |d }| j|j
d
� | j|j
d� | j|j |� | jt |j �d� d S ) Na [eventlistener:dog]
events=PROCESS_COMMUNICATION
process_name = %(program_name)s_%(process_num)s
command = /bin/dog
numprocs = 2
priority = 1
[eventlistener:cat]
events=PROCESS_COMMUNICATION
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 3
[eventlistener:biz]
events=PROCESS_COMMUNICATION
process_name = %(program_name)s_%(process_num)s
command = /bin/biz
numprocs = 2
r )r4 )�default_handlerr� Zbizrb r` r� �dogr8 )r r r4 �supervisor.dispatchersr� r9 r| r� rN rO r, �result_handlerr� r� )r r� r4 r� rt r� r� �gconfig1r r r �%test_event_listener_pools_from_parser� s.
z8ServerOptionsTests.test_event_listener_pools_from_parserc C sf t d�}ddlm} ddlm} | j� }tj� ddddd d
�|_|� }|j|_ |j
|� |j |�}| j t
|�d � |d }| j |jd � | j |jd� | j |j|� | j t
|j�d� |d
}| j |jd� | j |jd
� | j |j|� | j t
|j�d � |jd } | j | jd� | j | jd� | j | jd
� |jd
}
| j |
jd� | j |
jd� | j |
jd
� d S )Na� [eventlistener:dog]
events=PROCESS_COMMUNICATION
process_name = %(ENV_EL1_PROCNAME)s_%(program_name)s_%(process_num)s
command = %(ENV_EL1_COMMAND)s
numprocs = %(ENV_EL1_NUMPROCS)s
priority = %(ENV_EL1_PRIORITY)s
[eventlistener:cat]
events=PROCESS_COMMUNICATION
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 3
r )r4 )r� r� Zmyeventlistenerz/bin/dogrR �1)r� r� ZENV_EL1_PROCNAMEZENV_EL1_COMMANDZENV_EL1_NUMPROCSZENV_EL1_PRIORITYrb r� r` r� r� Zmyeventlistener_dog_0Zmyeventlistener_dog_1r8 )r r r4 r� r� r| rq r� r� r� r9 r� rN rO r, r� r� r� r� ) r r� r4 r� r� rt r� Zgconfig0r� Zdog0Zdog1r r r �Atest_event_listener_pools_from_parser_with_environment_expansions� sD
zTServerOptionsTests.test_event_listener_pools_from_parser_with_environment_expansionsc C s~ t d�}ddlm} |� }|j|� | j� }y|j|� | jd� W n4 tk
rx } z| j|j d d� W Y d d }~X nX d S )Nzl [eventlistener:dog]
events=EVENT
command = /bin/dog
buffer_size = 0
r )r4 znothing raisedz8[eventlistener:dog] section sets invalid buffer_size (0))
r r r4 r9 r| r� r� r" rN r )r r� r4 rt r� r� r r r �3test_event_listener_pool_disallows_buffer_size_zero� s
zFServerOptionsTests.test_event_listener_pool_disallows_buffer_size_zeroc C s~ t d�}ddlm} |� }|j|� | j� }y|j|� | jd� W n4 tk
rx } z| j|j d d� W Y d d }~X nX d S )Nz� [eventlistener:dog]
events=PROCESS_COMMUNICATION
command = /bin/dog
redirect_stderr = True
r )r4 znothing raisedz�[eventlistener:dog] section sets redirect_stderr=true but this is not allowed because it will interfere with the eventlistener protocol)
r r r4 r9 r| r� r� r" rN r )r r� r4 rt r� r� r r r �2test_event_listener_pool_disallows_redirect_stderr� s
zEServerOptionsTests.test_event_listener_pool_disallows_redirect_stderrc C sl t d�}ddlm} ddlm} |� }|j|� | j� }|j|�}| jt |�d� |d }| j|j
|� d S )Nz� [eventlistener:dog]
events=PROCESS_COMMUNICATION
command = /bin/dog
result_handler = supervisor.tests.base:dummy_handler
r )r4 )�
dummy_handlerr` ) r r r4 �supervisor.tests.baser� r9 r| r� rN rO r� )r r� r4 r� rt r� r� r� r r r �2test_event_listener_pool_with_event_result_handler
s
zEServerOptionsTests.test_event_listener_pool_with_event_result_handlerc C s~ t d�}ddlm} |� }|j|� | j� }y|j|� | jd� W n4 tk
rx } z| j|j d d� W Y d d }~X nX d S )Nz� [eventlistener:cat]
events=PROCESS_COMMUNICATION
command = /bin/cat
result_handler = supervisor.tests.base:nonexistent
r )r4 znothing raisedzOsupervisor.tests.base:nonexistent cannot be resolved within [eventlistener:cat])
r r r4 r9 r| r� r� r" rN r )r r� r4 rt r� r� r r r �4test_event_listener_pool_result_handler_unimportable
s
zGServerOptionsTests.test_event_listener_pool_result_handler_unimportablec C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [eventlistener:dog]
process_name = %(program_name)s_%(process_num)s
command = /bin/dog
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �%test_event_listener_pool_noeventsline0
s
z8ServerOptionsTests.test_event_listener_pool_noeventslinec C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [eventlistener:dog]
events=PROCESS_COMMUNICATION,THIS_EVENT_TYPE_DOESNT_EXIST
process_name = %(program_name)s_%(process_num)s
command = /bin/dog
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �*test_event_listener_pool_unknown_eventtype>
s
z=ServerOptionsTests.test_event_listener_pool_unknown_eventtypec C s` ddl m} ddl m} td�}ddl m} |� }|j|� | j� }t� }d d tj tj
f|_ t� }d d tj
f|_ t d|�t d|�t d|�d d
� ���} | ||�}
tj tj
f} | j
t|
�d � |
d } | j
| j|� | j
| jd � | j
| jd
� | j
| jjd� | j
| | jj� � | j
d| jj� � | j
d| jj� � | j
t| j�d� | jd }
| j
|
j|� |
d
}| j
|jd� | j
|jd� | j
|jjd� | j
| |jj� � | j
d|jj� � | j
t|j�d� |
d }| j
|jd� | j
|jjd� | j
t|j�d
� |
d }| j
|jd� | j
|jjd� | j
d |jj� � | j
d|jj� � | j
t|j�d
� d S )Nr )�FastCGIGroupConfig)�FastCGIProcessConfiga� [fcgi-program:foo]
socket = unix:///tmp/%(program_name)s.sock
socket_owner = testuser:testgroup
socket_mode = 0666
socket_backlog = 32676
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
[fcgi-program:bar]
socket = unix:///tmp/%(program_name)s.sock
process_name = %(program_name)s_%(process_num)s
command = /bin/bar
user = testuser
numprocs = 3
[fcgi-program:flub]
socket = unix:///tmp/%(program_name)s.sock
command = /bin/flub
[fcgi-program:cub]
socket = tcp://localhost:6000
command = /bin/cub
)r4 z pwd.getpwuidz pwd.getpwnamz grp.getgrnamc S s
| j |�S )N)r� )r� rt r r r �get_process_groupsv
s zMServerOptionsTests.test_fcgi_programs_from_parser.<locals>.get_process_groupsrL rg r` zunix:///tmp/foo.socki� i� rb rh i� zunix:///tmp/bar.socki� r� Zcubztcp://localhost:6000Zflubzunix:///tmp/flub.sock)r r� r� r r4 r9 r| r r r� r� � return_valuer rN rO � __class__r, r� �
socket_config�url� get_owner�get_mode� get_backlogr� )r r� r� r� r4 rt r� �pwd_mock�grp_mockr� r� � exp_owner� gconf_foo� pconfig_fooZ gconf_barZ gconf_cubZ
gconf_flubr r r � test_fcgi_programs_from_parserM
sd
z1ServerOptionsTests.test_fcgi_programs_from_parserc C s� ddl m} ddl m} td�}ddl m} | j� }dddd d
d d d
ddd�
|_|� }|j|_|j|� t � }d d t
j t
j f|_
t � }d d t
j f|_
td|�td|�td|�dd� ���} | ||�}
t
j t
j f} | jt|
�d� |
d } | j| j|� | j| jd� | j| jd� | j| jjd� | j| | jj� � | jd| jj� � | jd| jj� � | jt| j�d� | jd }
| j|
j|� | j|
jd � d S ) Nr )r� )r� a� [fcgi-program:foo]
socket = unix:///tmp/%(program_name)s%(ENV_FOO_SOCKET_EXT)s
socket_owner = %(ENV_FOO_SOCKET_USER)s:testgroup
socket_mode = %(ENV_FOO_SOCKET_MODE)s
socket_backlog = %(ENV_FOO_SOCKET_BACKLOG)s
process_name = %(ENV_FOO_PROCESS_PREFIX)s_%(program_name)s_%(process_num)s
command = /bin/foo --arg1=%(ENV_FOO_COMMAND_ARG1)s
numprocs = %(ENV_FOO_NUMPROCS)s
priority = %(ENV_FOO_PRIORITY)s
)r4 z/tmpr� z.usockZtestuserZ0666Z32676zfcgi-rh rR r� )
r� r� ZENV_FOO_SOCKET_EXTZENV_FOO_SOCKET_USERZENV_FOO_SOCKET_MODEZENV_FOO_SOCKET_BACKLOGZENV_FOO_PROCESS_PREFIXZENV_FOO_COMMAND_ARG1ZENV_FOO_NUMPROCSZENV_FOO_PRIORITYz pwd.getpwuidz pwd.getpwnamz grp.getgrnamc S s
| j |�S )N)r� )r� rt r r r r� �
s ziServerOptionsTests.test_fcgi_programs_from_parser_with_environment_expansions.<locals>.get_process_groupsr` rg zunix:///tmp/foo.usocki� i� rb z/bin/foo --arg1=bar)r r� r� r r4 r| r� r� r9 r r r� r� r� r rN rO r� r, r� r� r� r� r� r� r� r� )r r� r� r� r4 r� rt r� r� r� r� r� r� r� r r r �:test_fcgi_programs_from_parser_with_environment_expansions�
sT
zMServerOptionsTests.test_fcgi_programs_from_parser_with_environment_expansionsc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �test_fcgi_program_no_socket�
s
z.ServerOptionsTests.test_fcgi_program_no_socketc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket=junk://blah
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �)test_fcgi_program_unknown_socket_protocol�
s
z<ServerOptionsTests.test_fcgi_program_unknown_socket_protocolc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket=unix://relative/path
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �$test_fcgi_program_rel_unix_sock_path s
z7ServerOptionsTests.test_fcgi_program_rel_unix_sock_pathc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket=tcp://missingport
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �%test_fcgi_program_bad_tcp_sock_format s
z8ServerOptionsTests.test_fcgi_program_bad_tcp_sock_formatc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket=unix:///tmp/%(process_num)s.sock
process_name = %(program_name)s_%(process_num)s
command = /bin/foo
numprocs = 2
priority = 1
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �(test_fcgi_program_bad_expansion_proc_num! s
z;ServerOptionsTests.test_fcgi_program_bad_expansion_proc_numc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket=tcp://localhost:8000
socket_owner=nobody:nobody
command = /bin/foo
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �*test_fcgi_program_socket_owner_set_for_tcp0 s
z=ServerOptionsTests.test_fcgi_program_socket_owner_set_for_tcpc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz [fcgi-program:foo]
socket = tcp://localhost:8000
socket_mode = 0777
command = /bin/foo
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �)test_fcgi_program_socket_mode_set_for_tcp= s
z<ServerOptionsTests.test_fcgi_program_socket_mode_set_for_tcpc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket = unix:///tmp/foo.sock
socket_owner = sometotaljunkuserthatshouldnobethere
command = /bin/foo
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �"test_fcgi_program_bad_socket_ownerJ s
z5ServerOptionsTests.test_fcgi_program_bad_socket_ownerc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz [fcgi-program:foo]
socket = unix:///tmp/foo.sock
socket_mode = junk
command = /bin/foo
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �!test_fcgi_program_bad_socket_modeW s
z4ServerOptionsTests.test_fcgi_program_bad_socket_modec C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [fcgi-program:foo]
socket = unix:///tmp/foo.sock
socket_backlog = -1
command = /bin/foo
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �$test_fcgi_program_bad_socket_backlogd s
z7ServerOptionsTests.test_fcgi_program_bad_socket_backlogc C s� t d�}ddlm} |� }|j|� | j� }|j|�}| jt|�d� |d }| j|jd� | j|j d� | jt|j
�d� d S )Nz� [program:one]
command = /bin/cat
[program:two]
command = /bin/cat
[group:thegroup]
programs = one,two
priority = 5
r )r4 r` �thegroupr� rb ) r r r4 r9 r| r� rN rO r, r� r� )r r� r4 rt r� r� r� r r r �-test_heterogeneous_process_groups_from_parserq s
[email protected]_heterogeneous_process_groups_from_parserc C s� t d�}ddlm} |� }|j|� | j� }|j|�}| jt|�d� |d }| j|jd� | j|j d� | jt|j
�d� |d }| j|jd� | j|j d� | jt|j
�d� d S ) NaJ [program:one]
command = /bin/cat
[program:two]
command = /bin/cat
[program:many]
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 2
priority = 1
[group:thegroup]
programs = one,two
priority = 5
r )r4 rb r� r` r� r� ) r r r4 r9 r| r� rN rO r, r� r� )r r� r4 rt r� r� Z
manyconfigr� r r r �&test_mixed_process_groups_from_parser1� s
z9ServerOptionsTests.test_mixed_process_groups_from_parser1c C s� t d�}ddlm} |� }|j|� | j� }|j|�}| jt|�d� |d }| j|jd� | j|j d� | jt|j
�d� d S )NaP [program:one]
command = /bin/cat
[program:two]
command = /bin/cat
[program:many]
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 2
priority = 1
[group:thegroup]
programs = one,two, many
priority = 5
r )r4 r` r� r� rL ) r r r4 r9 r| r� rN rO r, r� r� )r r� r4 rt r� r� r� r r r �&test_mixed_process_groups_from_parser2� s
z9ServerOptionsTests.test_mixed_process_groups_from_parser2c C s� t d�}ddlm} |� }|j|� | j� }|j|�}| jt|�d� |d }| j|jd� | j|j d� | jt|j
�d� d S )Na� [program:one]
command = /bin/cat
[fcgi-program:two]
command = /bin/cat
[program:many]
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 2
priority = 1
[fcgi-program:more]
process_name = %(program_name)s_%(process_num)s
command = /bin/cat
numprocs = 2
priority = 1
[group:thegroup]
programs = one,two,many,more
priority = 5
r )r4 r` r� r� rK ) r r r4 r9 r| r� rN rO r, r� r� )r r� r4 rt r� r� r� r r r �&test_mixed_process_groups_from_parser3� s
z9ServerOptionsTests.test_mixed_process_groups_from_parser3c C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nz� [program:one]
command = /bin/cat
[fcgi-program:one]
command = /bin/cat
[group:thegroup]
programs = oner )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �-test_ambiguous_process_in_heterogeneous_group� s
[email protected]_ambiguous_process_in_heterogeneous_groupc C s@ t d�}ddlm} |� }|j|� | j� }| jt|j|� d S )Nzj [program:one]
command = /bin/cat
[group:foo]
programs = notthere
r )r4 )r r r4 r9 r| r9 r" r� )r r� r4 rt r� r r r �+test_unknown_program_in_heterogeneous_group� s
z>ServerOptionsTests.test_unknown_program_in_heterogeneous_groupc C s� t dt �}ddlm} |� }|j|� | j� }|j|dd�}| jt|�d� |d }| j|d d� | j|d t j
t � | j|d d d
d �� d S ) Nzv [rpcinterface:dummy]
supervisor.rpcinterface_factory = %s
foo = bar
baz = qux
r )r4 z supervisor.rpcinterface_factoryz
rpcinterface:r` �dummyrb rh Zqux)rg ri ) r r r r4 r9 r| � get_pluginsrN rO �sys�modules)r r� r4 rt r� � factories�factoryr r r � test_rpcinterfaces_from_parser
s
z1ServerOptionsTests.test_rpcinterfaces_from_parserc C s� t d�}ddlm} | j� }|� }tdd�|_|j|� |j|dd�}| jt |�d� |d }| j|d d � | j|d t
j t � | j|d
d di� d S ) Nzq [rpcinterface:dummy]
supervisor.rpcinterface_factory = %(factory)s
foo = %(pet)s
r )r4 r� )r� �petz supervisor.rpcinterface_factoryz
rpcinterface:r` r� rb rg ) r r r4 r| r r� r9 r� rN rO r� r� )r r� r4 r� rt r� r� r r r �1test_rpcinterfaces_from_parser_factory_expansions! s
zDServerOptionsTests.test_rpcinterfaces_from_parser_factory_expansionsc C s� t d�}ddlm} |� }|j|� | j� }y |j|dd� | jd� W n4 tk
r| } z| j|j d d� W Y d d }~X nX d S )Nz] [rpcinterface:dummy]
# note: no supervisor.rpcinterface_factory here
r )r4 z supervisor.rpcinterface_factoryz
rpcinterface:znothing raisedzOsection [rpcinterface:dummy] does not specify a supervisor.rpcinterface_factory)
r r r4 r9 r| r� r� r" rN r )r r� r4 rt r� r� r r r �.test_rpcinterfaces_from_parser_factory_missing5 s
zAServerOptionsTests.test_rpcinterfaces_from_parser_factory_missingc C s� t d�}ddlm} |� }|j|� | j� }y |j|dd� | jd� W n4 tk
r| } z| j|j d d� W Y d d }~X nX d S )Nz[ [rpcinterface:dummy]
supervisor.rpcinterface_factory = nonexistent
r )r4 z supervisor.rpcinterface_factoryz
rpcinterface:znothing raisedz:nonexistent cannot be resolved within [rpcinterface:dummy])
r r r4 r9 r| r� r� r" rN r )r r� r4 rt r� r� r r r �5test_rpcinterfaces_from_parser_factory_not_importableG s
zHServerOptionsTests.test_rpcinterfaces_from_parser_factory_not_importablec
C s� t j� }z�| j� }||_d}||_|jd|d�}|d }|d }t|d�}t|d�}|j� | jt j
j |�� | jt j
j |�� | jt j
j |�� |j � |j � W d t
j|dd� X d S ) Nr� rg re z.1z.2r� T)r� )rq r� r| r� r� Zget_autochildlog_namer� �clear_autochildlogdirr rU r� rK r^ r� r� ) r Zdnr� ZsidZlogfn�first�second�f1�f2r r r �test_clear_autochildlogdirY s$
z-ServerOptionsTests.test_clear_autochildlogdirc C s4 | j � }d|_t� |_|j� | j|jjdg� d S )Nz!/tmp/this/cant/possibly/existjjjjz Could not clear childlog dir)r| r� r rS r� rN ro )r r� r r r �*test_clear_autochildlogdir_listdir_oserrorn s
z=ServerOptionsTests.test_clear_autochildlogdir_listdir_oserrorc C s� t j� }| j� }||_|j}tjj|d| �}t|d��}|j d� W d Q R X dd� }||_
t � |_ |j
� | j|j jd| g� d S )Nzcat-stdout---%s-ayWAp9.logr� �logc W s t tj��d S )N)rN r� �ENOENT)r r r r �
raise_oserror} s zSServerOptionsTests.test_clear_autochildlogdir_unlink_oserror.<locals>.raise_oserrorzFailed to clean up '%s')rq r� r| r� r� rU r� r� r� r� �remover rS r� rN ro )r r� r� Zidentr rs r r r r �)test_clear_autochildlogdir_unlink_oserroru s
z<ServerOptionsTests.test_clear_autochildlogdir_unlink_oserrorc sh t � }| j� }dd� }||_g � � fdd�}||_|j|� | jt� �d� d}| j� d j|�� d S )Nc S s t jtj��d S )N)r� rZ r� Z
EADDRINUSE)r� r r r �raise_eaddrinuse� s zhServerOptionsTests.test_openhttpservers_reports_friendly_usage_when_eaddrinuse.<locals>.raise_eaddrinusec s � j | � d S )N)r\ )r. )r/ r r r0 � s zdServerOptionsTests.test_openhttpservers_reports_friendly_usage_when_eaddrinuse.<locals>.record_usager` z$Another program is already listeningr ) r r| �make_http_serversr1 �openhttpserversrN rO rl rn )r r� r� r r0 r� r )r/ r �;test_openhttpservers_reports_friendly_usage_when_eaddrinuse� s
zNServerOptionsTests.test_openhttpservers_reports_friendly_usage_when_eaddrinusec sj t � }| j� }dd� }||_g � � fdd�}||_|j|� | jt� �d� dtj }| j� d |� d S )Nc S s t jtj��d S )N)r� rZ r� �EPERM)r� r r r r � s zbServerOptionsTests.test_openhttpservers_reports_socket_error_with_errno.<locals>.make_http_serversc s � j | � d S )N)r\ )r. )r/ r r r0 � s z]ServerOptionsTests.test_openhttpservers_reports_socket_error_with_errno.<locals>.record_usager` zBCannot open an HTTP server: socket.error reported errno.EPERM (%d)r ) r r| r r1 r rN rO r� r )r r� r� r r0 r� r )r/ r �4test_openhttpservers_reports_socket_error_with_errno� s
zGServerOptionsTests.test_openhttpservers_reports_socket_error_with_errnoc sd t � }| j� }dd� }||_g � � fdd�}||_|j|� | jt� �d� d}| j� d |� d S )Nc S s t jd��d S )Nzuh oh)r� rZ )r� r r r r � s z^ServerOptionsTests.test_openhttpservers_reports_other_socket_errors.<locals>.make_http_serversc s � j | � d S )N)r\ )r. )r/ r r r0 � s zYServerOptionsTests.test_openhttpservers_reports_other_socket_errors.<locals>.record_usager` z7Cannot open an HTTP server: socket.error reported uh ohr )r r| r r1 r rN rO )r r� r� r r0 r� r )r/ r �0test_openhttpservers_reports_other_socket_errors� s
zCServerOptionsTests.test_openhttpservers_reports_other_socket_errorsc sd t � }| j� }dd� }||_g � � fdd�}||_|j|� | jt� �d� d}| j� d |� d S )Nc S s t d��d S )Nznot prefixed with help)r" )r� r r r r � s zWServerOptionsTests.test_openhttpservers_reports_value_errors.<locals>.make_http_serversc s � j | � d S )N)r\ )r. )r/ r r r0 � s zRServerOptionsTests.test_openhttpservers_reports_value_errors.<locals>.record_usager` znot prefixed with helpr )r r| r r1 r rN rO )r r� r� r r0 r� r )r/ r �)test_openhttpservers_reports_value_errors� s
z<ServerOptionsTests.test_openhttpservers_reports_value_errorsc C s0 t � }| j� }dd� }||_| jt|j|� d S )Nc S s t �d S )N)�
OverflowError)r� r r r r � s zgServerOptionsTests.test_openhttpservers_does_not_catch_other_exception_types.<locals>.make_http_servers)r r| r r9 r
r )r r� r� r r r r �9test_openhttpservers_does_not_catch_other_exception_types� s zLServerOptionsTests.test_openhttpservers_does_not_catch_other_exception_typesc C s" | j � }|jd �}| j|d� d S )Nz No user specified to setuid to!)r| �drop_privilegesrN )r r� ro r r r � test_drop_privileges_user_none� s
z1ServerOptionsTests.test_drop_privileges_user_nonez pwd.getpwuidrg N� �" )r� z os.getuidc C s& | j � }|jtj� �}| j|d � d S )N)r| r rU �getuidrN )r r� ro r r r �&test_drop_privileges_nonroot_same_user� s z9ServerOptionsTests.test_drop_privileges_nonroot_same_user�7 c C s" | j � }|jd�}| j|d� d S )NrR z$Can't drop privilege as nonroot user)r| r rN )r r� ro r r r �+test_drop_privileges_nonroot_different_user� s
z>ServerOptionsTests.test_drop_privileges_nonroot_different_userc C s> | j � }dd� |_t� |_|j� |jjj� |jjj� d S )Nc S s d S )Nr r r r r r_ � s zYServerOptionsTests.test_daemonize_notifies_poller_before_and_after_fork.<locals>.<lambda>)r| Z
_daemonizer rY Z daemonizeZbefore_daemonizeZassert_called_once_withZafter_daemonize)r r� r r r �4test_daemonize_notifies_poller_before_and_after_fork� s
zGServerOptionsTests.test_daemonize_notifies_poller_before_and_after_fork)�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 r; r< r= r> r? r@ rA rB rC rD rE rL rO rQ rV rW rX r[ ra rb rc rk rl rm rn rp rv rw ry r r rN rz 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� 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 r r r r r r r r r r� � s
D
##
2
'(%$
.4Y@
# $
"$"$r� c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�ProcessConfigTestsc C s ddl m} |S )Nr )�
ProcessConfig)r r )r r r r r r � s z"ProcessConfigTests._getTargetClassc O sH i }xd D ] }|||< q
W xd D ] }d ||< q W |j |� | j� ||�S )!Nr, r� r� r� r� r� r� r� r� r� r� r~ r r� r� �stderr_capture_maxbytes�stderr_events_enabledr� r� r� r� r� r^ r� r� r� r� �stderr_logfile_backups�stderr_logfile_maxbytesr� )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 �arg�kw�defaultsr, r r r r| � s"
zProcessConfigTests._makeOnec C s, t � }| j|d d�}| j|j� |j� � d S )N)r� )r
r| rN �get_path)r r6 r� r r r �.test_get_path_env_is_None_delegates_to_options
s zAProcessConfigTests.test_get_path_env_is_None_delegates_to_optionsc C s0 t � }| j|ddid�}| j|j� |j� � d S )Nr� r� )r� )r
r| rN r! )r r6 r� r r r �8test_get_path_env_dict_with_no_PATH_delegates_to_options
s zKProcessConfigTests.test_get_path_env_dict_with_no_PATH_delegates_to_optionsc C sF t � }| j|ddid�}| j|j� |j� � | j|j� dddg� d S )Nr� z/a:/b:/c)r� z/az/bz/c)r
r| ZassertNotEqualr! rN )r r6 r� r r r �(test_get_path_env_dict_with_PATH_uses_it
s z;ProcessConfigTests.test_get_path_env_dict_with_PATH_uses_itc C sT t � }| j|�}ddlm} ||_||_|j� | j|j|j� | j|j|j� d S )Nr )r� ) r
r| r3 r� r� r� Zcreate_autochildlogsrN Z
tempfile_name)r r6 r� r� r r r �test_create_autochildlogs
s
z,ProcessConfigTests.test_create_autochildlogsc C sD t � }| j|�}|j� }ddlm} | j|j|� | j|jd � d S )Nr )�
Subprocess)r
r| � make_process�supervisor.processr& rN r� r� )r r6 r� �processr& r r r �test_make_process)
s
z$ProcessConfigTests.test_make_processc C sF t � }| j|�}|jd�}ddlm} | j|j|� | j|jd� d S )NrB r )r& )r
r| r' r( r& rN r� r� )r r6 r� r) r& r r r � test_make_process_with_group1
s
z/ProcessConfigTests.test_make_process_with_groupc
C s� t � }| j|�}tj� ��}tj� ��}|j|_|j|_d|_t|�}|j |�\}}| j
|d j d� ddl m
} | j
|d j|� | j
|d d� | j
|d j d� ddl m} | j
|d j| � | j
|d d� W d Q R X W d Q R X d S ) NFr� re r )� ProcessCommunicationStdoutEventr\ rd )� ProcessCommunicationStderrEvent)r
r| rq rr r, r� r� r� r
�make_dispatchersrN �channel�supervisor.eventsr, �
event_typer- )
r r6 r� r� r� �process1� dispatchersrj r, r- r r r �+test_make_dispatchers_stderr_not_redirected9
s&
z>ProcessConfigTests.test_make_dispatchers_stderr_not_redirectedc
C sx t � }| j|�}tj� �V}|j|_t|�}|j|�\}}| j|d j d� | j|d d� | j|d d � W d Q R X d S )Nr� re rd )
r
r| rq rr r, r� r
r. rN r/ )r r6 r� r� r2 r3 rj r r r �'test_make_dispatchers_stderr_redirectedN
s
z:ProcessConfigTests.test_make_dispatchers_stderr_redirectedN)
r r r r r| r" r# r$ r% r* r+ r4 r5 r r r r r � s
r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�EventListenerConfigTestsc C s ddl m} |S )Nr )�EventListenerConfig)r r7 )r r7 r r r r Z
s z(EventListenerConfigTests._getTargetClassc O sH i }xd D ] }|||< q
W xd D ] }d ||< q W |j |� | j� ||�S )!Nr, 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� 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| ^
s"
z!EventListenerConfigTests._makeOnec
C s t � }| j|�}tj� ��}tj� ��}|j|_|j|_d|_t|�}|j |�\}}| j
|d j d� | j
|d j d� | j
|d j d� ddl
m} | j
|d jj|j� | j
|d d� | j
|d j d � dd
lm} | j
|d j| � | j
|d d� W d Q R X W d Q R X d S ) NFrL re r� re r )�EventListenerStatesr\ rd )r- )r
r| rq rr r, r� r� r� r
r. rN r/ rZ Zsupervisor.statesr8 r) Zlistener_stateZ ACKNOWLEDGEDr0 r- r1 )
r r6 r� r� r� r2 r3 rj r8 r- r r r �test_make_dispatchersq
s*
z.EventListenerConfigTests.test_make_dispatchersN)r r r r r| r9 r r r r r6 Y
s r6 c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �FastCGIProcessConfigTestsc C s ddl m} |S )Nr )r� )r r� )r r� r r r r �
s z)FastCGIProcessConfigTests._getTargetClassc O sH i }xd D ] }|||< q
W xd D ] }d ||< q W |j |� | j� ||�S )!Nr, 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� 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| �
s"
z"FastCGIProcessConfigTests._makeOnec C s" t � }| j|�}| jt|j� d S )N)r
r| r9 �NotImplementedErrorr' )r r6 r� r r r r* �
s
z+FastCGIProcessConfigTests.test_make_processc C sF t � }| j|�}|jd�}ddlm} | j|j|� | j|jd� d S )NrB r )�FastCGISubprocess)r
r| r' r( r< rN r� r� )r r6 r� r) r< r r r r+ �
s
z6FastCGIProcessConfigTests.test_make_process_with_groupc
C s t � }| j|�}tj� ��}tj� ��}|j|_|j|_d|_t|�}|j |�\}}| j
|d j d� | j
|d j d� | j
|d j d� ddl
m} | j
|d j|� | j
|d d� | j
|d j d
� dd l
m} | j
|d j| � | j
|d
d � W d Q R X W d Q R X d S ) NFrL re Tr� re r )r, r\ rd )r- )r
r| rq rr r, r� r� r� r
r. rN r/ rZ r0 r, r1 r- )
r r6 r� r� r� r2 r3 rj r, r- r r r r9 �
s*
z/FastCGIProcessConfigTests.test_make_dispatchersN)r r r r r| r* r+ r9 r r r r r: �
s
r: c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �ProcessGroupConfigTestsc C s ddl m} |S )Nr )�ProcessGroupConfig)r r> )r r> r r r r �
s z'ProcessGroupConfigTests._getTargetClassc C s | j � ||||�S )N)r )r r6 r, r� r� r r r r| �
s z ProcessGroupConfigTests._makeOnec C sR t � }| j|ddg �}| j|j|� | j|jd� | j|jd� | j|jg � d S )N�whateveri� )r
r| rN r6 r, r� r� )r r6 r� r r r � test_ctor�
s z!ProcessGroupConfigTests.test_ctorc C sB t � }t|dd�g}| j|dd|�}|j� | j|d jd� d S )Nr2 z
/bin/process1r? i� r T)r
r r| � after_setuidrN �autochildlogs_created)r r6 r� r� r r r �test_after_setuid�
s
z)ProcessGroupConfigTests.test_after_setuidc C sJ t � }t|dd�g}| j|dd|�}|j� }ddlm} | j|j|� d S )Nr2 z
/bin/process1r? i� r )� ProcessGroup)r
r r| �
make_groupr( rD rN r� )r r6 r� r� r� rD r r r �test_make_group�
s z'ProcessGroupConfigTests.test_make_groupN)r r r r r| r@ rC rF r r r r r= �
s
r= c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
� EventListenerPoolConfigTestsc C s ddl m} |S )Nr )�EventListenerPoolConfig)r rH )r rH r r r r �
s z,EventListenerPoolConfigTests._getTargetClassc C s | j � |||||||�S )N)r )r r6 r, r� r� � buffer_sizeZ pool_eventsr� r r r r| �
s z%EventListenerPoolConfigTests._makeOnec C sH t � }t|dd�g}| j|dd|dg d �}|j� | j|d jd� d S )Nr2 z
/bin/process1r, i� r` r T)r
r r| rA rN rB )r r6 r� r� r r r rC �
s
z.EventListenerPoolConfigTests.test_after_setuidc C sP t � }t|dd�g}| j|dd|dg d �}|j� }ddlm} | j|j|� d S )Nr2 z
/bin/process1r, i� r` r )�EventListenerPool)r
r r| rE r( rJ rN r� )r r6 r� r� r� rJ r r r rF �
s z,EventListenerPoolConfigTests.test_make_groupN)r r r r r| rC rF r r r r rG �
s rG c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�FastCGIGroupConfigTestsc C s ddl m} |S )Nr )r� )r r� )r r� r r r r �
s z'FastCGIGroupConfigTests._getTargetClassc O s | j � ||�S )N)r )r r r r r r r| s z FastCGIGroupConfigTests._makeOnec C sj t � }td�}| j|ddg |�}| j|j|� | j|jd� | j|jd� | j|jg � | j|j|� d S )NrK r? i� ) r
r r| rN r6 r, r� r� r� )r r6 � sock_configr� r r r r@ s z!FastCGIGroupConfigTests.test_ctorc C sZ t � }td�}| j|ddg |�}td�}| j|ddg |�}| j||k� | j||k� d S )NrK r? i� )r
r r| rl r )r r6 � sock_config1� instance1� sock_config2� instance2r r r �test_same_sockets_are_equal s z3FastCGIGroupConfigTests.test_same_sockets_are_equalc C sZ t � }td�}| j|ddg |�}td�}| j|ddg |�}| j||k� | j||k� d S )NrK r? i� r\ )r
r r| rl r )r r6 rM rN rO rP r r r � test_diff_sockets_are_not_equal s z7FastCGIGroupConfigTests.test_diff_sockets_are_not_equalc C sF t � }td�}| j|ddg |�}|j� }ddlm} | j|j|� d S )NrK r, i� r )�FastCGIProcessGroup)r
r r| rE r( rS rN r� )r r6 rL r� r� rS r r r rF & s z'FastCGIGroupConfigTests.test_make_groupN) r r r r r| r@ rQ rR rF r r r r rK �
s
rK c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�SignalReceiverTestsc C s& ddl m} |� }| j|j� d � d S )Nr )�SignalReceiver)r rU rN r$ )r rU �srr r r �test_returns_None_initially/ s z/SignalReceiverTests.test_returns_None_initiallyc C sf ddl m} |� }|jtjd� |jtjd� | j|j� tj� | j|j� tj� | j|j� d � d S )Nr )rU �frame)r rU r" r� r� r# rN r$ )r rU rV r r r �&test_returns_signals_in_order_received4 s z:SignalReceiverTests.test_returns_signals_in_order_receivedc C sT ddl m} |� }|jtjd� |jtjd� | j|j� tj� | j|j� d � d S )Nr )rU rX )r rU r" r� r� rN r$ )r rU rV r r r �%test_does_not_queue_duplicate_signals= s z9SignalReceiverTests.test_does_not_queue_duplicate_signalsc C sv ddl m} |� }|jtjd� | j|j� tj� | j|j� d � |jtjd� | j|j� tj� | j|j� d � d S )Nr )rU rX )r rU r" r� r� rN r$ r# )r rU rV r r r �%test_queues_again_after_being_emptiedE s z9SignalReceiverTests.test_queues_again_after_being_emptiedN)r r r rW rY rZ r[ r r r r rT . s rT c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!S )"�UnhosedConfigParserTestsc C s ddl m} |S )Nr )r4 )r r4 )r r4 r r r r P s z(UnhosedConfigParserTests._getTargetClassc O s | j � ||�S )N)r )r r r r r r r| T s z!UnhosedConfigParserTests._makeOnec C s6 | j � }|jd� ddlm} | j|j|jdd� d S )Nz[supervisord]
r )� ConfigParserr� �missing)r| r9 r r] r9 Z
NoOptionError�saneget)r r r] r r r �test_saneget_no_defaultW s
z0UnhosedConfigParserTests.test_saneget_no_defaultc C s2 | j � }|jd� |jdddd�}| j|d� d S )Nz[supervisord]
r� r^ rB )r+ )r| r9 r_ rN )r r �resultr r r �test_saneget_with_default^ s
z2UnhosedConfigParserTests.test_saneget_with_defaultc C s< | j � }ddi|_|jd� |jdddd�}| j|d� d S )Nr� r� z[supervisord]
r� rg z%(pet)s)r+ )r| r� r9 r_ rN )r r ra r r r �$test_saneget_with_default_and_expandd s
z=UnhosedConfigParserTests.test_saneget_with_default_and_expandc C s> | j � }ddi|_|jd� |jddddd�}| j|d� d S ) Nr� r� z[supervisord]
r� rg z%(pet)sF)r+ � do_expand)r| r� r9 r_ rN )r r ra r r r �#test_saneget_with_default_no_expandk s
z<UnhosedConfigParserTests.test_saneget_with_default_no_expandc C s2 | j � }|jd� |jdddd�}| j|d� d S )Nz[supervisord]
foo=%(pet)s
r� rg F)rd z%(pet)s)r| r9 r_ rN )r r ra r r r �!test_saneget_no_default_no_expands s
z:UnhosedConfigParserTests.test_saneget_no_default_no_expandc C s8 | j � }ddi|_|jd� |jdd�}| j|d� d S )Nr� r� z[supervisord]
foo=%(pet)s
r� rg )r| r� r9 r_ rN )r r ra r r r �(test_saneget_expands_instance_expansionsy s
zAUnhosedConfigParserTests.test_saneget_expands_instance_expansionsc C s@ | j � }ddi|_|jd� |jddddid�}| j|d� d S )Nr� r� z[supervisord]
foo=%(pet)s
r� rg r� )r� )r| r� r9 r_ rN )r r ra r r r �#test_saneget_expands_arg_expansions� s
z<UnhosedConfigParserTests.test_saneget_expands_arg_expansionsc C s. | j � }|jd|j � | j|jd�d� d S )Nz
[%s]
foo=bar
rg rh )r| r9 Z mysectionrN Z
getdefault)r r r r r �+test_getdefault_does_saneget_with_mysection� s zDUnhosedConfigParserTests.test_getdefault_does_saneget_with_mysectionc
C sR | j � }tjdd��$}|jd� |j� |j|j�}W d Q R X | j||jg� d S )Nzw+)r� z[foo]
)r| rq rr r� r rs r, rN )r r rs � ok_filenamesr r r � test_read_filenames_as_string� s
z6UnhosedConfigParserTests.test_read_filenames_as_stringc
C sT | j � }tjdd��&}|jd� |j� |j|jg�}W d Q R X | j||jg� d S )Nzw+)r� z[foo]
)r| rq rr r� r rs r, rN )r r rs rj r r r �test_read_filenames_as_list� s
z4UnhosedConfigParserTests.test_read_filenames_as_listc
C sl t jjt jjt�d�}| j� }tjdd��(}|jd� |j � |j
||j g�}W d Q R X | j ||j g� d S )Nr� zw+)r� z[foo]
)
rU r� r� r� r� r| rq rr r� r rs r, rN )r r� r rs rj r r r �3test_read_returns_ok_filenames_like_rawconfigparser� s
zLUnhosedConfigParserTests.test_read_returns_ok_filenames_like_rawconfigparserc C s | j � }| j|ji � d S )N)r| rN �section_to_file)r r r r r �)test_read_section_to_file_initially_empty� s zBUnhosedConfigParserTests.test_read_section_to_file_initially_emptyc
C sX | j � }tjdd��&}|jd� |j� |j|jg� W d Q R X | j|jd |j� d S )Nzw+)r� z[foo]
rg ) r| rq rr r� r rs r, rN rn )r r rs r r r �'test_read_section_to_file_read_one_file� s
[email protected]_read_section_to_file_read_one_filec C s� | j � }tjdd��T}tjdd��<}|jd� |j� |jd� |j� |j|j|jg� W d Q R X W d Q R X | j|jd |j� | j|jd |j� d S )Nzw+)r� z[foo]
z[bar]
rg rh ) r| rq rr r� r rs r, rN rn )r r r� r� r r r �-test_read_section_to_file_read_multiple_files� s
&zFUnhosedConfigParserTests.test_read_section_to_file_read_multiple_filesN)r r r r r| r` rb rc re rf rg rh ri rk rl rm ro rp rq r r r r r\ O s r\ c @ s e Zd Zdd� Zdd� ZdS )�UtilFunctionsTestsc C s4 ddl m} | j|dd�d� | j|dd�d� d S )Nr )�
make_namespecr� r) z
group:process)r rs rN )r rs r r r �test_make_namespec� s z%UtilFunctionsTests.test_make_namespecc C sT ddl m} |}| j|d�d� | j|d�d � | j|d�d
� | j|d�d � d S ) Nr )�split_namespecz
process:groupr) r� zgroup:zgroup:*)r) r� )r) r) )r� N)r� N)r ru rN )r ru r� r r r �test_split_namespec� s z&UtilFunctionsTests.test_split_namespecN)r r r rt rv r r r r rr � s rr c C s t jtjt �S )N)�unittestZ
findTestCasesr� r� r r r r r �
test_suite� s rx �__main__)Z defaultTest)+�__doc__rU r� rq r� rw r� r� r� r r r r r� r r r Zsupervisor.loggersr r r r
r r r
r r ZTestCaser rz r� r r6 r: r= rG rK rT r\ rr rx r �mainr r r r �<module> sx h 7 Sb0< 0!o