Edit File: test_options.cpython-36.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* &z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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& z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@ServerOptionsTests.test_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 z@UnhosedConfigParserTests.test_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
Back to File Manager