File: //lib/python3.6/site-packages/supervisor/tests/__pycache__/test_process.cpython-36.pyc
3
�k�`v� � @ sj d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
m Z m Z d dl m
Z
d dl mZ d dl mZ d dl mZ d d l mZ d d
l mZ d d l mZ d d l mZ d d
l mZ d dl mZ d dlmZ d dlmZ G dd� dej�Z G dd� dej�Z G dd� dej�Z G dd� de �Z G dd� dej�Z G dd � d e �Z!G d d � d ej�Z"dS ) � N)�as_bytes)�maxint)�Mock�patch�sentinel)� DummyOptions)� DummyPConfig)� DummyProcess)�DummyPGroupConfig)�DummyDispatcher)�
DummyEvent)�DummyFCGIGroupConfig)�DummySocketConfig)�DummyProcessGroup)�DummyFCGIProcessGroup)�
Subprocess)�
BadCommandc @ 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=dwdx� Z>dydz� Z?d{d|� Z@d}d~� ZAdd�� 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�S )��SubprocessTestsc C s ddl m} |S )Nr )r )�supervisor.processr )�selfr � r �"/usr/lib/python3.6/test_process.py�_getTargetClass s z SubprocessTests._getTargetClassc O s | j � ||�S )N)r )r �arg�kwr r r �_makeOne s zSubprocessTests._makeOnec C s ddl m} |� d S )Nr )�clear)�supervisor.eventsr )r r r r r �tearDown" s zSubprocessTests.tearDownc C sN ddl m} ddlm} x0|jj� D ]"\}}t|t�r$| j||�|� q$W d S )Nr )�
ProcessStates)�getProcessStateDescription) �supervisor.statesr r r �__dict__�items�
isinstance�int� assertEqual)r r r Z statename�coder r r � test_getProcessStateDescription& s
z/SubprocessTests.test_getProcessStateDescriptionc C s� t � }t|ddddd�}| j|�}| j|j|� | j|jj|� | j|jd� | j|jd� | j|jd� | j|jd� | j|j d� | j
|j � | j
|j � | j|j
d� | j|ji � | j|ji � | j|jd � d S )N�catzbin/catz/tmp/temp123.logz/tmp/temp456.log)�stdout_logfile�stderr_logfiler )r r r r& �config�options� laststart�pidZlaststop�delay� assertFalse�administrative_stop�killing�backoff�pipes� dispatchers�spawnerr)r r- r, �instancer r r � test_ctor- s$
zSubprocessTests.test_ctorc C sH t � }t|dd�}| j|�}t|�}| j|jd�� | j|jd�� d S )Nr) zbin/catz<Subprocess atz with name cat in state STOPPED>)r r r �repr�
assertTrue�
startswith�endswith)r r- r, r8 �sr r r � test_reprA s
zSubprocessTests.test_reprc C sh t � }t|dd�}| j|�}tdd�tdd�d�|_|j� | j|jd jd� | j|jd jd � d S )
N�testz/testT)�readable)�writable)r � r rC F)r r r r r6 �
reopenlogsr& �
logs_reopened)r r- r, r8 r r r �test_reopenlogsI s
z SubprocessTests.test_reopenlogsc C sh t � }t|dd�}| j|�}tdd�tdd�d�|_|j� | j|jd jd� | j|jd jd � d S )
Nr@ z/testT)rA )rB )r rC r rC F)r r r r r6 �
removelogsr& Z logs_removed)r r- r, r8 r r r �test_removelogsS s
z SubprocessTests.test_removelogsc C sj t � }t|ddddd�}| j|�}tdd�tdd�d �|_|j� | j|jd
j� | j|jd j� d S ) Nr@ z/testz/tmp/fooz/tmp/bar)r* r+ T)rA )rB )r rC r rC ) r r r r r6 Zdrainr; Zread_event_handledZwrite_event_handled)r r- r, r8 r r r �
test_drain] s
zSubprocessTests.test_drainc C s. t � }t|dd�}| j|�}| jt|j� d S )NZ
extraquotez extraquote")r r r � assertRaisesr �get_execv_args)r r- r, r8 r r r �*test_get_execv_args_bad_command_extraquotei s
z:SubprocessTests.test_get_execv_args_bad_command_extraquotec C s. t � }t|dd�}| j|�}| jt|j� d S )N�empty� )r r r rJ r rK )r r- r, r8 r r r �%test_get_execv_args_bad_command_emptyo s
z5SubprocessTests.test_get_execv_args_bad_command_emptyc C s. t � }t|dd�}| j|�}| jt|j� d S )NZwhitespaceonlyz )r r r rJ r rK )r r- r, r8 r r r �.test_get_execv_args_bad_command_whitespaceonlyu s
z>SubprocessTests.test_get_execv_args_bad_command_whitespaceonlyc C s: t � }t|dd�}| j|�}|j� }| j|ddgf� d S )N�nottherez /notthere)r r r rK r& )r r- r, r8 �argsr r r � test_get_execv_args_abs_missing{ s
z/SubprocessTests.test_get_execv_args_abs_missingc C s< t � }t|dd�}| j|�}|j� }| j|dddgf� d S )NrQ z/notthere "an argument"z /nottherez an argument)r r r rK r& )r r- r, r8 rR r r r �*test_get_execv_args_abs_withquotes_missing� s
z:SubprocessTests.test_get_execv_args_abs_withquotes_missingc C s: t � }t|dd�}| j|�}|j� }| j|ddgf� d S )NrQ )r r r rK r& )r r- r, r8 rR r r r � test_get_execv_args_rel_missing� s
z/SubprocessTests.test_get_execv_args_rel_missingc C s< t � }t|dd�}| j|�}|j� }| j|dddgf� d S )NrQ znotthere "an argument"z an argument)r r r rK r& )r r- r, r8 rR r r r �*test_get_execv_args_rel_withquotes_missing� s
z:SubprocessTests.test_get_execv_args_rel_withquotes_missingc C s` d}t � }t|d|�}| j|�}|j� }| jt|�d� | j|d d� | j|d ddg� d S )Nz /bin/sh foo�sh� r z/bin/shrC �foo)r r r rK r& �len)r �
executabler- r, r8 rR r r r �test_get_execv_args_abs� s
z'SubprocessTests.test_get_execv_args_absc C s` d}t � }t|d|�}| j|�}|j� }| jt|�d� | j|d d� | j|d ddg� d S )Nzsh foorW rX r z/bin/shrC rY )r r r rK r& rZ )r r[ r- r, r8 rR r r r �test_get_execv_args_rel� s
z'SubprocessTests.test_get_execv_args_relc s� t j� �x}tjj|j�\� }d| }t� }t|d|�}� fdd�|_| j |�}|j
� }| j |d |j� | j |d |dg� W d Q R X d S )Nz%s foorW c s � gS )Nr r )�dirnamer r �<lambda>� s zUSubprocessTests.test_get_execv_args_rel_searches_using_pconfig_path.<locals>.<lambda>r rC rY ) �tempfileZNamedTemporaryFile�os�path�split�namer r �get_pathr rK r& )r �f�basenamer[ r- r, r8 rR r )r^ r �3test_get_execv_args_rel_searches_using_pconfig_path� s
zCSubprocessTests.test_get_execv_args_rel_searches_using_pconfig_pathc C sL t � }t|dd�}| j|�}|jd� | j|jd� | j|jjd d� d S )Nr@ z/testrY r z
spawnerr: foo)r r r Zrecord_spawnerrr& r7 �logger�data)r r- r, r8 r r r �test_record_spawnerr� s
z$SubprocessTests.test_record_spawnerrc C sr t � }t|dd�}| j|�}d|_ddlm} |j|_|j� }| j |d � | j |j
j d d� | j |j|j� d S )NrW z/bin/shTr )r z process 'sh' already running) r r r r/ r! r �RUNNING�state�spawnr& ri rj )r r- r, r8 r �resultr r r �test_spawn_already_running� s
z*SubprocessTests.test_spawn_already_runningc s t � }t|dd�}| j|�}ddlm} |j|_ddlm} g � |j |j
� fdd�� |j � }| j |d � | j |j
d� | j |jjd d � | j|j� | j|j� ddlm} | j |j|j� | j t� �d
� � d }� d }| j |j|j� | j |j|j� d S ) NZbadz
/bad/filenamer )r )�eventsc s
� j | �S )N)�append)�x)�Lr r r_ � s zBSubprocessTests.test_spawn_fail_check_execv_args.<locals>.<lambda>z bad filenamezspawnerr: bad filenamerX rC )r r r r! r �BACKOFFrm �
supervisorrq � subscribe�ProcessStateEventrn r& r7 ri rj r; r0 r4 rZ � __class__�ProcessStateStartingEvent�ProcessStateBackoffEvent) r r- r, r8 r rq ro �event1�event2r )rt r � test_spawn_fail_check_execv_args� s*
z0SubprocessTests.test_spawn_fail_check_execv_argsc s t � }ttjtjtj��|_t|dd�}| j|�}ddl m
} |j |_ ddl
m} g � |j|j� fdd�� |j� }| j|d � | j|jd� | j|jjd d � | j|j� | j|j� ddl m
} | j|j |j � | jt� �d
� � \}}| j|j|j� | j|j|j � d S ) N�goodz/good/filenamer )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zCSubprocessTests.test_spawn_fail_make_pipes_emfile.<locals>.<lambda>z#too many open files to spawn 'good'z-spawnerr: too many open files to spawn 'good'rX ) r �OSError�errnoZEMFILEra �strerror�make_pipes_exceptionr r r! r ru rm rv rq rw rx rn r& r7 ri rj r; r0 r4 rZ ry rz r{ ) r r- r, r8 r rq ro r| r} r )rt r �!test_spawn_fail_make_pipes_emfile� s0
z1SubprocessTests.test_spawn_fail_make_pipes_emfilec
s t � }ttjtjtj��|_t|dd�}| j|�}ddl m
} |j |_ ddl
m} g � |j|j� fdd�� |j� }| j|d � d}| j|j|� | j|jjd d | � | j|j� | j|j� ddl m
} | j|j |j � | jt� �d
� � \}} | j|j|j� | j| j|j � d S ) Nr z/good/filenamer )r )rq c s
� j | �S )N)rr )rs )rt r r r_ s zBSubprocessTests.test_spawn_fail_make_pipes_other.<locals>.<lambda>z2unknown error making dispatchers for 'good': EPERMz spawnerr: %srX ) r r� r� �EPERMra r� r� r r r! r ru rm rv rq rw rx rn r& r7 ri rj r; r0 r4 rZ ry rz r{ )
r r- r, r8 r rq ro �msgr| r} r )rt r � test_spawn_fail_make_pipes_other� s.
z0SubprocessTests.test_spawn_fail_make_pipes_otherc s t � }t|dddd�}dd� }||_| j|�}ddlm} |j|_dd lm } g � |j
|j � fd
d �� |j � }| j
|d � d }| j
|j|� | j
|jjd d
| � | j|j� | j|j� ddlm} | j
|j|j� | j
t� �d� � \} }
| j
| j|j� | j
|
j|j� d S )Nr) z/bin/catz /a/directory)rd Zcommandr* c S s t tj��d S )N)�IOErrorr� ZEISDIR)�enveloper r r � raise_eisdir s zMSubprocessTests.test_spawn_fail_make_dispatchers_eisdir.<locals>.raise_eisdirr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ ! s zISubprocessTests.test_spawn_fail_make_dispatchers_eisdir.<locals>.<lambda>z2unknown error making dispatchers for 'cat': EISDIRz spawnerr: %srX )r r Zmake_dispatchersr r! r ru rm rv rq rw rx rn r& r7 ri rj r; r0 r4 rZ ry rz r{ ) r r- r, r� r8 r rq ro r� r| r} r )rt r �'test_spawn_fail_make_dispatchers_eisdir s0
z7SubprocessTests.test_spawn_fail_make_dispatchers_eisdirc
s> t � }ttjtjtj��|_t|dd�}| j|�}ddl m
} |j |_ ddl
m} g � |j|j� fdd�� |j� }| j|d � d}| j|j|� | j|jjd d | � | jt|j�d
� | jt|j�d
� | j|j� | j|j� ddl m
} | j|j |j � | jt� �d � � \}} | j|j |j � | j| j |j � d S ) Nr z/good/filenamer )r )rq c s
� j | �S )N)rr )rs )rt r r r_ : s z=SubprocessTests.test_spawn_fork_fail_eagain.<locals>.<lambda>z3Too many processes in process table to spawn 'good'z spawnerr: %s� rX ) r r� r� �EAGAINra r� �fork_exceptionr r r! r ru rm rv rq rw rx rn r& r7 ri rj rZ �parent_pipes_closed�child_pipes_closedr; r0 r4 ry rz r{ )
r r- r, r8 r rq ro r� r| r} r )rt r �test_spawn_fork_fail_eagain0 s2
z+SubprocessTests.test_spawn_fork_fail_eagainc
s> t � }ttjtjtj��|_t|dd�}| j|�}ddl m
} |j |_ ddl
m} g � |j|j� fdd�� |j� }| j|d � d}| j|j|� | j|jjd d | � | jt|j�d
� | jt|j�d
� | j|j� | j|j� ddl m
} | j|j |j � | jt� �d � � \}} | j|j |j � | j| j |j � d S ) Nr z/good/filenamer )r )rq c s
� j | �S )N)rr )rs )rt r r r_ U s z<SubprocessTests.test_spawn_fork_fail_other.<locals>.<lambda>z+unknown error during fork for 'good': EPERMz spawnerr: %sr� rX ) r r� r� r� ra r� r� r r r! r ru rm rv rq rw rx rn r& r7 ri rj rZ r� r� r; r0 r4 ry rz r{ )
r r- r, r8 r rq ro r� r| r} r )rt r �test_spawn_fork_fail_otherK s2
z*SubprocessTests.test_spawn_fork_fail_otherc C s� t � }d|_t|dddd�}| j|�}|j� }| j|d � | j|jd � | j|jd � | j|jd� | jt |j
�d� | jt |j �|j d � | j|j
d� | j|jddgf� | j|jd� | j|jdd i� d S )
Nr r z/good/filenamerC )�uidT� rX z*supervisor: child process was not spawned
)r �forkpidr r rn r& r� r� �pgrp_setrZ �duped�
fds_closed�minfds� privsdropped�
execv_args�
execve_called�written)r r- r, r8 ro r r r � test_spawn_as_child_setuid_okf s"
z-SubprocessTests.test_spawn_as_child_setuid_okc C s� t � }d|_d|_t|dddd�}| j|�}|j� }| j|d � | j|jd � | j|jd � | j|j d� | jt
|j �d� | jt
|j �|j
d � | j|jd d
i� | j|jd � | j|jd � | j|jd � d S )
Nr zfailure reasonr z/good/filenamerC )r� Tr� rX z[supervisor: couldn't setuid to 1: failure reason
supervisor: child process was not spawned
F� )r r� Z
setuid_msgr r rn r& r� r� r� rZ r� r� r� r� r� r� � _exitcode)r r- r, r8 ro r r r � test_spawn_as_child_setuid_fail| s"
z/SubprocessTests.test_spawn_as_child_setuid_failc C s� t � }d|_t|dddd�}| j|�}|j� }| j|d � | j|jd � | j|jd � | j|jd� | jt |j
�d� | jt |j �|j d � | j|j
ddgf� | j|jd� | j|jd� | j|jdd i� d S )
Nr r z/good/filenamez/tmp)� directoryTr� rX z*supervisor: child process was not spawned
)r r� r r rn r& r� r� r� rZ r� r� r� r� �changed_directoryr� r� )r r- r, r8 ro r r r �test_spawn_as_child_cwd_ok� s$
z*SubprocessTests.test_spawn_as_child_cwd_okc C s� t � }d|_t|dddd�}| j|�}|j� }| j|d � | j|jddgf� | j|jd� | j|jd� | j|j ddi� d S )Nr r z/good/filenamerX )�umaskTz*supervisor: child process was not spawned
)
r r� r r rn r& r� Zumasksetr� r� )r r- r, r8 ro r r r � test_spawn_as_child_sets_umask� s
z.SubprocessTests.test_spawn_as_child_sets_umaskc C s� t � }d|_ttjtjtj��|_t|dddd�}| j |�}|j
� }| j |d � | j |j d � | j |j
d � | j |jd� | j t|j�d� | j t|j�|jd � | j |jd � dd i}| j |j|� | j |jd
� | j |jd � | j |jd � d S ) Nr r z/good/filenamez/tmp)r� Tr� rX zUsupervisor: couldn't chdir to /tmp: ENOENT
supervisor: child process was not spawned
r� F)r r� r� r� �ENOENTra r� Zchdir_exceptionr r rn r& r� r� r� rZ r� r� r� r� r� r� r� r� )r r- r, r8 ro �outr r r � test_spawn_as_child_cwd_fail� s(
z,SubprocessTests.test_spawn_as_child_cwd_failc C s� t � }d|_ttjtjtj��|_t|dd�}| j |�}|j
� }| j |d � | j |j d � | j |j
d � | j |jd� | j t|j�d� | j t|j�|jd � ddi}| j |j|� | j |jd � | j |jd� d S ) Nr r z/good/filenameTr� rX zZsupervisor: couldn't exec /good/filename: EPERM
supervisor: child process was not spawned
r� )r r� r� r� r� ra r� �execv_exceptionr r rn r& r� r� r� rZ r� r� r� r� r� r� )r r- r, r8 ro r� r r r �&test_spawn_as_child_execv_fail_oserror� s"
z6SubprocessTests.test_spawn_as_child_execv_fail_oserrorc C s� t � }d|_ttj�|_t|dd�}| j|�}|j� }| j |d � | j |j
d � | j |j d � | j |j d� | j t
|j�d� | j t
|j�|jd � |jd }d}| j|j|�� | jd|k� | j |jd � | j |jd � d S )
Nr r z/good/filenameTr� rX z)supervisor: couldn't exec /good/filename:� RuntimeErrorr� )r r� r� r� r� r� r r rn r& r� r� r� rZ r� r� r� r� r; r< r� r� )r r- r, r8 ro r� �headr r r �,test_spawn_as_child_execv_fail_runtime_error� s$
z<SubprocessTests.test_spawn_as_child_execv_fail_runtime_errorc C sh t � }d|_t|ddddid�}| j|�}|j� }| j|d � | j|jddgf� | j|jd d� d S )Nr r) z/bin/catZ_TEST_�1)Z environment)r r� r r rn r& r� �execv_environment)r r- r, r8 ro r r r �,test_spawn_as_child_uses_pconfig_environment� s
z<SubprocessTests.test_spawn_as_child_uses_pconfig_environmentc C s� t � }d|_t|dd�}| j|�}G dd� d�}|� |_|� |j_|j� }| j|d � | j|jddgf� | j|j d d� | j|j d d� | j|j d d
� | j|j d d � d S )
Nr r) z/bin/catc @ s e Zd ZdZdS )zQSubprocessTests.test_spawn_as_child_environment_supervisor_envvars.<locals>.Dummy�dummyN)�__name__�
__module__� __qualname__rd r r r r �Dummy s r� ZSUPERVISOR_ENABLEDr� ZSUPERVISOR_PROCESS_NAMEZSUPERVISOR_GROUP_NAMEr� ZSUPERVISOR_SERVER_URLzhttp://localhost:9001)
r r� r r �groupr, rn r& r� r� )r r- r, r8 r� ro r r r �2test_spawn_as_child_environment_supervisor_envvars s&
zBSubprocessTests.test_spawn_as_child_environment_supervisor_envvarsc C s� t � }d|_t|dddd�}d|_| j|�}|j� }| j|d � | j|jd � | j|jd � | j|j d� | jt
|j �d� | jt
|j �|j
d � | j|jd� | j|jddgf� | j|jd� | j|jdd i� d S )
Nr r z/good/filenamerC )r� TrX r� z*supervisor: child process was not spawned
)r r� r �redirect_stderrr rn r& r� r� r� rZ r� r� r� r� r� r� r� )r r- r, r8 ro r r r �%test_spawn_as_child_stderr_redirected s$
z5SubprocessTests.test_spawn_as_child_stderr_redirectedc C s, t � }d|_t|dd�}| j|�}|j� }| j|d� | j|jd jt� | j|jd jt� | j|jd jt� | j|j d d� | j|j d d� | j|j d d� | j|j
d � | jt |j �d
� | j|j
jd d � | j|jd � | j|j� | j|jjjd |� d d
lm} | j|j|j� d S )N�
r z/good/filename� � � �stdin�stdout�stderrr� r zspawned: 'good' with pid 10)r )r r� r r rn r& r6 ry r r5 r� rZ r� ri rj r7 r; r0 r, r- �
pidhistoryr! r rm �STARTING)r r- r, r8 ro r r r r �test_spawn_as_parent/ s(
z$SubprocessTests.test_spawn_as_parentc C s� t � }d|_t|dddd�}| j|�}|j� }| j|d� | j|jd jt� | j|jd jt� | j|j d d� | j|j d d� | j|j d
d � d S ) Nr� r z/good/filenameT)r� r� r� r� r� r� )
r r� r r rn r& r6 ry r r5 )r r- r, r8 ro r r r �test_spawn_redirect_stderrE s
z*SubprocessTests.test_spawn_redirect_stderrc C s� d}t � }t|d|�}| j|�}dd }| jt|j|� d|_|j� |j|� |jd }| j ||j
| j � d|_ | jt|j|� d S ) Nz/bin/cat�output�arC �
r� Ti )
r r r rJ r� �writer� rn r5 r& r6 Z input_bufferr3 )r r[ r- r, r8 �sent�stdin_fdr r r �
test_writeS s
zSubprocessTests.test_writec C sr d}t � }t|d|�}| j|�}dd }| jt|j|� d|_|j� |jd }|j | j
� | jt|j|� d S )Nz/bin/catr� r� rC r� r� i ) r r r rJ r� r� r� rn r5 r6 �close)r r[ r- r, r8 r� r� r r r � test_write_dispatcher_closedb s
z,SubprocessTests.test_write_dispatcher_closedc C s� d}t � }t|d|�}| j|�}d|_|j� |jd }|j| j� d |jd< y|jd� | j d� W nH t
k
r� } z,| j |j d t
j� | j |j d d� W Y d d }~X nX d S ) Nz/bin/catr� rC r� rY znothing raisedr z Process has no stdin channel)r r r r� rn r5 r6 r� r� �failr� r& rR r� �EPIPE)r r[ r- r, r8 r� �excr r r �test_write_stdin_fd_noneo s
z(SubprocessTests.test_write_stdin_fd_nonec C s� d}t � }t|d|�}| j|�}dd }| jt|j|� d|_|j� |jd }tt j
t j t j
��|j
| _| jt|j|� d S )Nz/bin/catr� r� rC r� r� i )r r r rJ r� r� r� rn r5 r� r� ra r� r6 Zflush_exception)r r[ r- r, r8 r� r� r r r �(test_write_dispatcher_flush_raises_epipe� s
z8SubprocessTests.test_write_dispatcher_flush_raises_epipec s� ddl m} �zxg � � fdd�}tjtj|� |� }t� }t|d|�}| j|�}|j� }|jj d }| j
|j d�� | j t
|j�d� | j
|j� | j |j|� |j} xNytjd�j� }
P W q� tk
r� } z| jd tjkr� W Y d d } ~ X q�X q�W tjd � | j
|
jtt| ���d k� |j tj �}tjd � | j |d � tj d tj �\} }
tjd�j� }
| j |
jtt| ���d
� | j � g � W d ytj!|� W n Y nX tjtjtj"� X d S )Nr )�makeSpewc s � j d� d S )NT)rr )rR )�sigchldsr r �
sighandler� s z=SubprocessTests._dont_test_spawn_and_kill.<locals>.sighandlerZspewzspawned: 'spew' with pidr� Zpsg�������?rC ���r� r� )#�supervisor.tests.baser� �signal�SIGCHLDr r r rn ri rj r; r< r& rZ r5 r/ ra �popen�readr� rR r� ZEINTR�time�sleep�findr r: �kill�SIGTERM�waitpid�WNOHANG�assertNotEqual�remove�SIG_DFL)r r� r� r[ r- r, r8 ro r� Zorigpidrj Zwhyr/ �stsr )r� r �_dont_test_spawn_and_kill� sJ
z)SubprocessTests._dont_test_spawn_and_killc C s� t � }t|dd�}| j|�}d|_tdd�}d|i|_ddlm} |j|_ t
j
� |_ |j � | j
|j� | j|j d� | j
|j� | j|jjd d � | j
|j� | j|jd tj� d S )
Nr@ z/test� T)rB rY r )r z)killing test (pid 11) with signal SIGTERM)r r r r/ r r6 r! r rl rm r� �laststopreport�stopr; r2 r& r0 ri rj r3 �killsr� r� )r r- r, r8 �
dispatcherr r r r � test_stop� s
zSubprocessTests.test_stopc C s� t � }t|dd�}| j|�}d|_tdd�}d|i|_ddlm} |j|_ y|j
� | j d � W n4 t k
r� } z| j
|jd d
� W Y d d }~X nX d S ) Nr@ z/testr� T)rB rY r )r znothing raisedzCAssertion failed for test: STOPPED not in RUNNING STARTING STOPPING)r r r r/ r r6 r! r �STOPPEDrm r� r� �AssertionErrorr& rR )r r- r, r8 r� r r� r r r �&test_stop_not_in_stoppable_state_error� s
z6SubprocessTests.test_stop_not_in_stoppable_state_errorc C sj t � }t|dd�}| j|�}d|_tdd�}d|i|_ddlm} |j|_ |j
� | j t |j
j�d� d S ) Nr@ z/testr� T)rB rY r )r )r r r r/ r r6 r! r r� rm � stop_reportr& rZ ri rj )r r- r, r8 r� r r r r �3test_stop_report_logs_nothing_if_not_stopping_state� s
zCSubprocessTests.test_stop_report_logs_nothing_if_not_stopping_statec C s� t � }t|dd�}| j|�}d|_tdd�}d|i|_ddlm} |j|_ | j
|j d� |j � | j
t
|jj�d � | j
|jjd d
� | j|j d� |j � | j
t
|jj�d � d S ) Nr@ z/testr� T)rB rY r )r rC zwaiting for test to stop)r r r r/ r r6 r! r �STOPPINGrm r& r� r� rZ ri rj r� )r r- r, r8 r� r r r r �1test_stop_report_logs_throttled_by_laststopreport� s
zASubprocessTests.test_stop_report_logs_throttled_by_laststopreportc C s� t j � d }t� }t|dd�}| j|�}d|_tdd�}d|i|_dd lm} |j |_
||_ |j � | j
t|jj�d� | j|j |k � t jd
� |j � | j
t|jj�d � | j
|jjd d � | j|j d� |j � | j
t|jj�d � d S )
Ni r@ z/testr� T)rB rY r )r rX rC zwaiting for test to stop)r� r r r r/ r r6 r! r r� rm r� r� r& rZ ri rj r; r� r� )r � future_timer- r, r8 r� r r r r �)test_stop_report_laststopreport_in_future� s(
z9SubprocessTests.test_stop_report_laststopreport_in_futurec s� t � }t|dd�}| j|�}g � ddlm} ddlm} |j|j� fdd�� |j |_
|j � | j |j
� | j|j� | j|j� | j|j
|j� | jt� �d� � d }| j|j|j� d S ) Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ " s z.SubprocessTests.test_give_up.<locals>.<lambda>rC )r r r r! r rv rq rw rx ru rm Zgive_upr; � system_stopr1 r0 r4 r& �FATALrZ ry �ProcessStateFatalEvent)r r- r, r8 r rq �eventr )rt r � test_give_up s
z SubprocessTests.test_give_upc C sL t � }t|dd�}| j|�}|jtj� | j|jjd d� | j |j
� d S )Nr@ z/testr z=attempted to kill test with sig SIGTERM but it wasn't running) r r r r� r� r� r& ri rj r1 r3 )r r- r, r8 r r r �test_kill_nopid- s
z SubprocessTests.test_kill_nopidc s� t � }t|dd�}| j|�}d|_g � ddlm} ddlm} |j|j � fdd�� |j
|_ |j t
j� | j|jjd d � | j|j� | j|jd t
j� | jt� �d
� � d }| j|j|j� d S ) Nr@ z/testr� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ > s z9SubprocessTests.test_kill_from_starting.<locals>.<lambda>z)killing test (pid 11) with signal SIGTERMrC )r r r r/ r! r rv rq rw rx r� rm r� r� r� r& ri rj r; r3 r� rZ ry �ProcessStateStoppingEvent)r r- r, r8 r rq r� r )rt r �test_kill_from_starting6 s
z'SubprocessTests.test_kill_from_startingc s� t � }t|dd�}| j|�}d|_g � ddlm} ddlm} |j|j � fdd�� |j
|_ |j t
j� | j|jjd d � | j|j� | j|jd t
j� | jt� �d
� � d }| j|j|j� d S ) Nr@ z/testr� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ Q s z8SubprocessTests.test_kill_from_running.<locals>.<lambda>z)killing test (pid 11) with signal SIGTERMrC )r r r r/ r! r rv rq rw rx rl rm r� r� r� r& ri rj r; r3 r� rZ ry r� )r r- r, r8 r rq r� r )rt r �test_kill_from_runningI s
z&SubprocessTests.test_kill_from_runningc s. t � }t|dd�}ttjtjtj��|_| j|�}g � ddl m
} ddl m } |j
|j� fdd�� d|_|j|_|jtj� | j|jjd d � | j|jjd
jd �� | jd |jjd
k� | j|j� | j|jd� | j|j|j � | jt � �d
� � d }� d
}| j|j |j � | j|j |j � d S )Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ e s z>SubprocessTests.test_kill_from_running_error.<locals>.<lambda>r� z)killing test (pid 11) with signal SIGTERMrC z unknown problem killing test� TracebackrX )!r r r� r� r� ra r� �kill_exceptionr r! r rv rq rw rx r/ rl rm r� r� r� r& ri rj r; r< r1 r3 �UNKNOWNrZ ry r� �ProcessStateUnknownEvent)r r- r, r8 r rq r| r} r )rt r � test_kill_from_running_error\ s0
z,SubprocessTests.test_kill_from_running_errorc s t � }t|dd�}ttjtjtj��|_| j|�}g � ddl m
} ddl m } |j
|j� fdd�� d|_|j|_|jtj� | j|jjd d � | j|jjd
d t|j� � | j|j� | j|jd� | j|j|j� | jt � �d
� � d }| j|j |j � d S ) Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zDSubprocessTests.test_kill_from_running_error_ESRCH.<locals>.<lambda>r� z)killing test (pid 11) with signal SIGTERMrC zFunable to signal test (pid 11), it probably just exited on its own: %s) r r r� r� �ESRCHra r� r r r! r rv rq rw rx r/ rl rm r� r� r� r& ri rj �strr; r3 r� rZ ry r� )r r- r, r8 r rq r| r )rt r �"test_kill_from_running_error_ESRCHw s*
z2SubprocessTests.test_kill_from_running_error_ESRCHc s� t � }t|dd�}| j|�}d|_g � ddlm} ddlm} |j|j � fdd�� |j
|_ |j t
j� | j|jjd d � | j|j� | j|jd t
j� | j� g � d S )
Nr@ z/testr� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s z9SubprocessTests.test_kill_from_stopping.<locals>.<lambda>z)killing test (pid 11) with signal SIGKILL)r r r r/ r! r rv rq rw rx r� rm r� r� �SIGKILLr& ri rj r; r3 r� )r r- r, r8 r rq r )rt r �test_kill_from_stopping� s
z'SubprocessTests.test_kill_from_stoppingc s� t � }t|dd�}| j|�}g � ddlm} ddlm} |j|j� fdd�� |j |_
|j t j
� | j|jjd d� | j|j� � d }| j|j|j� d S ) Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s z8SubprocessTests.test_kill_from_backoff.<locals>.<lambda>z2Attempted to kill test, which is in BACKOFF state.)r r r r! r rv rq rw rx ru rm r� r� r r& ri rj r1 r3 ry �ProcessStateStoppedEvent)r r- r, r8 r rq r� r )rt r �test_kill_from_backoff� s
z&SubprocessTests.test_kill_from_backoffc s� t � }t|dddd�}| j|�}d|_g � ddlm} ddlm} |j|j � fd d
�� |j
|_ |j t
j� | j|jjd d � | j|j� | j|jd t
j� | j� g � d S )
Nr@ z/testT)Z killasgroupr� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zGSubprocessTests.test_kill_from_stopping_w_killasgroup.<locals>.<lambda>z7killing test (pid 11) process group with signal SIGKILLi����)r r r r/ r! r rv rq rw rx r� rm r� r� r r& ri rj r; r3 r� )r r- r, r8 r rq r )rt r �%test_kill_from_stopping_w_killasgroup� s
z5SubprocessTests.test_kill_from_stopping_w_killasgroupc s� t � }t|dddd�}| j|�}d|_g � ddlm} ddlm} |j|j � fd d
�� |j
|_ |j t
j� | j|jjd d � | j|j� | j|jd t
j� | jt� �d � � d }| j|j|j� | j|jdg� | j|j|j
� d S )Nr@ z/testT)Z stopasgroupr� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s z2SubprocessTests.test_stopasgroup.<locals>.<lambda>z7killing test (pid 11) process group with signal SIGTERMrC r/ i����)r/ r� )r r r r/ r! r rv rq rw rx rl rm r� r� r� r& ri rj r; r3 r� rZ ry r� � extra_values�
from_state)r r- r, r8 r rq r� r )rt r �test_stopasgroup� s$
z SubprocessTests.test_stopasgroupc C sf t � }t|dd�}| j|�}ddlm} |j|_|jtj� | j |j
j d d� | j t |j
�d� d S )Nr@ z/testr )r z9attempted to send test sig SIGWINCH but it wasn't running)r r r r! r r� rm r� �SIGWINCHr& ri rj rZ r� )r r- r, r8 r r r r �test_signal_from_stopped� s
z(SubprocessTests.test_signal_from_stoppedc C s� t � }t|dd�}| j|�}d|_ddlm} |j|_|jtj � | j
|j j d d� | j
t
|j�d� | j|j|jk� | j
|j|j tj � d S )Nr@ z/testr� r )r z"sending test (pid 11) sig SIGWINCHrC )r r r r/ r! r rl rm r� r r& ri rj rZ r� r; )r r- r, r8 r r r r �test_signal_from_running� s
z(SubprocessTests.test_signal_from_runningc s� t � }t|dd�}ttjtjtj��|_| j|�}g � ddl m
} ddl m } |j
|j� fdd�� d|_|j|_|jtj� | j|jjd d � | j|jjd
d t|j� � | j|j� | j|j|j� | j|jd� | jt� �d� d S ) Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zFSubprocessTests.test_signal_from_running_error_ESRCH.<locals>.<lambda>r� z"sending test (pid 11) sig SIGWINCHrC zJunable to signal test (pid 11), it probably just now exited on its own: %s)r r r� r� r ra r� r r r! r rv rq rw rx r/ rl rm r� r r& ri rj r r1 r3 rZ )r r- r, r8 r rq r )rt r �$test_signal_from_running_error_ESRCH� s(
z4SubprocessTests.test_signal_from_running_error_ESRCHc s t � }t|dd�}ttjtjtj��|_| j|�}g � ddl m
} ddl m } |j
|j� fdd�� d|_|j|_|jtj� | j|jjd d � | j|jjd
jd �� | jd |jjd
k� | j|j� | j|j|j� | j|jd� | jt � �d
� � d }| j|j |j � d S )
Nr@ z/testr )r )rq c s
� j | �S )N)rr )rs )rt r r r_ s [email protected]_signal_from_running_error.<locals>.<lambda>r� z"sending test (pid 11) sig SIGWINCHrC z%unknown problem sending sig test (11)r ) r r r� r� r� ra r� r r r! r rv rq rw rx r/ rl rm r� r r& ri rj r; r< r1 r3 r rZ ry r )r r- r, r8 r rq r� r )rt r � test_signal_from_running_error s.
z.SubprocessTests.test_signal_from_running_errorc sH t � }t|dddd�}| j|�}d|_||jjjd< d|_ddd �}||_d
d l m
} d
d l m } |j
|_g � |j|j� fd
d�� d|_|jdd� | j|j� | j|jd
� | j|j|� | j|ji � | j|ji � | j|jjd
d� | j|jd� | jt� �d� � d
}| j|j|j � | j|j dg� | j|j |j
� d S )NrQ z /nottherez/tmp/foo)r* �{ rC TrN )r� r� r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ - s z<SubprocessTests.test_finish_stopping_state.<locals>.<lambda>z(stopped: notthere (terminated by SIGHUP)r/ )r rC r� )r/ r ) r r r Z
waitstatusr, r- r� r3 r5 r! r rv rq r� rm rw rx r/ �finishr1 r& r� r6 ri rj �
exitstatusrZ ry r r r )r r- r, r8 r5 r rq r� r )rt r �test_finish_stopping_state s8
z*SubprocessTests.test_finish_stopping_statec sV t � }t|dddd�}| j|�}||jjjd< ddd�}||_dg|j_d d
lm } d d l
m } |j |_
g � |j|j� fd d
�� d|_|jdd� | j|j� | j|jd � | j|j|� | j|ji � | j|ji � | j|jjd d� | j|jd� | jt� �d� � d }| j|j|j � | j|j d� | j|j ddg� | j|j |j � d S )NrQ z /nottherez/tmp/foo)r* r rN )r� r� rC r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ K s zISubprocessTests.test_finish_running_state_exit_expected.<locals>.<lambda>z1exited: notthere (terminated by SIGHUP; expected)T�expectedr/ r� r� )r T)r/ r ) r r r r, r- r� r5 � exitcodesr! r rv rq rl rm rw rx r/ r r1 r3 r& r� r6 ri rj r rZ ry �ProcessStateExitedEventr r r )r r- r, r8 r5 r rq r� r )rt r �'test_finish_running_state_exit_expected> s<
z7SubprocessTests.test_finish_running_state_exit_expectedc s� t � }t|dddd�}| j|�}||jjjd< ddd�}||_dg|j_tj� d |_ d
d l
m } d
d l m
} |j|_g � |j|j� fd
d�� d|_|jdd� | j|j� | j|jd
� | j|j|� | j|ji � | j|ji � | j|jjd
d� | j|jjd d� | j|jd� | jt � �d� � d
}| j|j |j � | j|j d� | j|j dg� | j|j!|j� � d }| j|j |j"� | j|j d� | j|j ddg� | j|j!|j#� d S )NrQ z /nottherez/tmp/foo)r* r rN )r� r� rC i r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ l s zPSubprocessTests.test_finish_starting_state_laststart_in_future.<locals>.<lambda>z�process 'notthere' (123) laststart time is in the future, don't know how long process was running so assuming it did not exit too quicklyz1exited: notthere (terminated by SIGHUP; expected)rX Tr/ r r� r� )r/ r )r T)r/ r )$r r r r, r- r� r5 r r� r. r! r rv rq r� rm rw rx r/ r r1 r3 r& r� r6 ri rj r rZ ry �ProcessStateRunningEventr r r r rl )r r- r, r8 r5 r rq r� r )rt r �.test_finish_starting_state_laststart_in_future^ sJ
z>SubprocessTests.test_finish_starting_state_laststart_in_futurec sB t � }t|ddddd�}| j|�}||jjjd< ddd�}||_dg|j_tj� |_ d
d l
m } d
d l m
} |j|_g � |j|j� fd
d�� d|_|jdd � | j|j� | j|jd
� | j|j|� | j|ji � | j|ji � | j|jjd
d� | j|jd � | jt � �d � � d
}| j|j |j � | j|j |j� d S )NrQ z /nottherez/tmp/foor� )r* � startsecsr rN )r� r� rC r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zOSubprocessTests.test_finish_starting_state_exited_too_quickly.<locals>.<lambda>z5exited: notthere (terminated by SIGHUP; not expected)r� ) r r r r, r- r� r5 r r� r. r! r rv rq r� rm rw rx r/ r r1 r3 r& r� r6 ri rj r rZ ry r{ r )r r- r, r8 r5 r rq r� r )rt r �-test_finish_starting_state_exited_too_quickly� s8
z=SubprocessTests.test_finish_starting_state_exited_too_quicklyc sb t � }t|ddddd�}| j|�}||jjjd< ddd�}||_dg|j_tj� |_ d
d l
m } d
d l m
} |j|_g � |j|j� fd
d�� d|_|jdd � | j|j� | j|jd
� | j|j|� | j|ji � | j|ji � | j|jjd
d� | j|jd� | jt � �d � � d
}| j|j |j � | j|j d� | j|j ddg� | j|j!|j� d S )NrQ z /nottherez/tmp/foor� )r* r r rN )r� r� rC r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zdSubprocessTests.test_finish_running_state_exited_too_quickly_due_to_clock_rollback.<locals>.<lambda>z1exited: notthere (terminated by SIGHUP; expected)Tr r/ r� r� )r T)r/ r )"r r r r, r- r� r5 r r� r. r! r rv rq rl rm rw rx r/ r r1 r3 r& r� r6 ri rj r rZ ry r r r r )r r- r, r8 r5 r rq r� r )rt r �Btest_finish_running_state_exited_too_quickly_due_to_clock_rollback� s>
zRSubprocessTests.test_finish_running_state_exited_too_quickly_due_to_clock_rollbackc sx t � }t|dddd�}| j|�}||jjjd< ddd�}||_dg|j_tj� d |_ d
d l
m } d
d l m
} |j|_g � |j|j� fd
d�� d|_|jdd� | j|j� | j|jd
� | j|j|� | j|ji � | j|ji � | j|jjd
d� | j|jjd d� | j|jd� | jt � �d� � d
}| j|j |j � | j|j d� | j|j ddg� | j|j!|j� d S )NrQ z /nottherez/tmp/foo)r* r rN )r� r� rC i r )r )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zOSubprocessTests.test_finish_running_state_laststart_in_future.<locals>.<lambda>z�process 'notthere' (123) laststart time is in the future, don't know how long process was running so assuming it did not exit too quicklyz1exited: notthere (terminated by SIGHUP; expected)Tr r/ r� r� )r T)r/ r )"r r r r, r- r� r5 r r� r. r! r rv rq rl rm rw rx r/ r r1 r3 r& r� r6 ri rj r rZ ry r r r r )r r- r, r8 r5 r rq r� r )rt r �-test_finish_running_state_laststart_in_future� sB
z=SubprocessTests.test_finish_running_state_laststart_in_futurec s� ddl m} g � |j|j� fdd�� |j|j� fdd�� t� }t|dddd d
�}| j|�}dd lm } |j
|_ t � }||_
|jd d
� | jt� �d� � \}}| j|j|j� | j|j|j� | j|j|� | j|j
|� | j|j
d � d S )Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zOSubprocessTests.test_finish_with_current_event_sends_rejected.<locals>.<lambda>c s
� j | �S )N)rr )rs )rt r r r_ � s rQ z /nottherez/tmp/foor� )r* r )r r rC rX )rv rq rw rx �EventRejectedEventr r r r! r rl rm r r� r r& rZ ry r �process) r rq r- r, r8 r r� r| r} r )rt r �-test_finish_with_current_event_sends_rejected� s*
z=SubprocessTests.test_finish_with_current_event_sends_rejectedc C s6 t � }t|dd�}| j|�}|j� | j|jd � d S )Nr@ z/test)r r r �set_uidr& r� )r r- r, r8 r r r �test_set_uid_no_uid s
z#SubprocessTests.test_set_uid_no_uidc C sF t � }t|dddd�}| j|�}|j� }| j|jd� | j|d � d S )Nr@ z/testrC )r� )r r r r' r& r� )r r- r, r8 r� r r r � test_set_uid
s
z SubprocessTests.test_set_uidc C s� t � }t|ddddd�}| j|�}t|ddddd�}| j|�}t|dddd d�}| j|�}|||g}|j� | j||||g� d S )
NrQ z /nottherez/tmp/foorC )r* �priorityZ notthere1rX Z notthere2r� )r r r �sortr& )r r- r, r8 Z instance1Z instance2rt r r r �test_cmp_bypriority s
z#SubprocessTests.test_cmp_bypriorityc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}| j |�}d|_ |j
|_|j� | j|j|j
� | j� g � d S )Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ . s zYSubprocessTests.test_transition_stopped_to_starting_supervisor_stopping.<locals>.<lambda>)r �SupervisorStatesr% z /bin/process)rv rq rw rx r! r r- r �SHUTDOWN�moodr r r. r� rm �
transitionr& )r rq r r- r- �pconfigr% r )rt r �7test_transition_stopped_to_starting_supervisor_stopping+ s
zGSubprocessTests.test_transition_stopped_to_starting_supervisor_stoppingc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}| j |�}d|_ |j
|_|j� | j|j|j� | jt� �d� � d }| j|j|j� d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ ? s zXSubprocessTests.test_transition_stopped_to_starting_supervisor_running.<locals>.<lambda>)r r- r% z /bin/processrC )rv rq rw rx r! r r- r rl r/ r r r. r� rm r0 r& r� rZ ry rz )r rq r r- r- r1 r% r� r )rt r �6test_transition_stopped_to_starting_supervisor_running< s
zFSubprocessTests.test_transition_stopped_to_starting_supervisor_runningc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}ddl m } ||_
| j|�}d |_d
|_|j|_|j� | j|j|j� | j|j� | j� g � d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ Q s zXSubprocessTests.test_transition_exited_to_starting_supervisor_stopping.<locals>.<lambda>)r r- r% z /bin/process)�RestartUnconditionallyrC T)rv rq rw rx r! r r- r r. r/ r �supervisor.datatypesr4 � autorestartr r. r� �EXITEDrm r0 r& r; )r rq r r- r- r1 r4 r% r )rt r �6test_transition_exited_to_starting_supervisor_stoppingN s"
zFSubprocessTests.test_transition_exited_to_starting_supervisor_stoppingc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}ddlm } ||_
| j |�}d |_ |j
|_|j� | j|j|j� | jt� �d � � d }| j|j|j� d S )
Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ f s z^SubprocessTests.test_transition_exited_to_starting_uncond_supervisor_running.<locals>.<lambda>)r r% z /bin/process)r4 rC )rv rq rw rx r! r r r r5 r4 r6 r r. r7 rm r0 r& r� rZ ry rz )r rq r r- r1 r4 r% r� r )rt r �<test_transition_exited_to_starting_uncond_supervisor_runningc s
zLSubprocessTests.test_transition_exited_to_starting_uncond_supervisor_runningc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}ddlm } ||_
| j |�}d |_ |j
|_d
|_|j� | j|j|j� | jt� �d � � d }| j|j|j� d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ y s z^SubprocessTests.test_transition_exited_to_starting_condit_supervisor_running.<locals>.<lambda>)r r% z /bin/process)�RestartWhenExitUnexpectedrC Zbogus)rv rq rw rx r! r r r r5 r: r6 r r. r7 rm r r0 r& r� rZ ry rz )r rq r r- r1 r: r% r� r )rt r �<test_transition_exited_to_starting_condit_supervisor_runningv s"
zLSubprocessTests.test_transition_exited_to_starting_condit_supervisor_runningc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}ddlm } ||_
| j |�}d |_ |j
|_d|_|j� | j|j|j
� | j� g � d S )
Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zbSubprocessTests.test_transition_exited_to_starting_condit_fls_supervisor_running.<locals>.<lambda>)r r% z /bin/process)r: rC )rv rq rw rx r! r r r r5 r: r6 r r. r7 rm r r0 r& )r rq r r- r1 r: r% r )rt r �@test_transition_exited_to_starting_condit_fls_supervisor_running� s
zPSubprocessTests.test_transition_exited_to_starting_condit_fls_supervisor_runningc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}| j |�}d|_ d|_
d|_|j|_|j� | j|j|j� | j� g � d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zYSubprocessTests.test_transition_backoff_to_starting_supervisor_stopping.<locals>.<lambda>)r r- r% z /bin/processrC )rv rq rw rx r! r r- r r. r/ r r r. r0 r4 ru rm r0 r& )r rq r r- r- r1 r% r )rt r �7test_transition_backoff_to_starting_supervisor_stopping� s
zGSubprocessTests.test_transition_backoff_to_starting_supervisor_stoppingc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}| j |�}d|_ d|_
d|_|j|_|j� | j|j|j� | jt� �d� | j� d j|j� d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zXSubprocessTests.test_transition_backoff_to_starting_supervisor_running.<locals>.<lambda>)r r- r% z /bin/processrC )rv rq rw rx r! r r- r rl r/ r r r. r0 r4 ru rm r0 r& r� rZ ry rz )r rq r r- r- r1 r% r )rt r �6test_transition_backoff_to_starting_supervisor_running� s
zFSubprocessTests.test_transition_backoff_to_starting_supervisor_runningc s� ddl m} g � |j|j� fdd�� ddlm}m} t� }|j|_ t
|ddd�}| j |�}d|_ t
|_d|_|j|_|j� | j|j|j� | j� g � d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s z_SubprocessTests.test_transition_backoff_to_starting_supervisor_running_notyet.<locals>.<lambda>)r r- r% z /bin/processrC )rv rq rw rx r! r r- r rl r/ r r r. r r0 r4 ru rm r0 r& )r rq r r- r- r1 r% r )rt r �=test_transition_backoff_to_starting_supervisor_running_notyet� s
zMSubprocessTests.test_transition_backoff_to_starting_supervisor_running_notyetc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}| j|�}d|_ d|_
d |_ d|_ d|_
d
|_d |_|j|_|j� | j|j d� | j|j
d� | j|j � | j|jjd d � | jt� �d� � d }| j|j|j� d S )
Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zESubprocessTests.test_transition_starting_to_running.<locals>.<lambda>)r r% z /bin/processrC F�abc�defz_success: process entered RUNNING state, process has stayed up for > than 10 seconds (startsecs))rv rq rw rx r! r r r r r4 r0 r� r. r/ �
stdout_buffer�
stderr_bufferr� rm r0 r& r1 ri rj rZ ry r )r rq r r- r1 r% r� r )rt r �#test_transition_starting_to_running� s0
z3SubprocessTests.test_transition_starting_to_runningc sR ddl m} g � |j|j� fdd�� ddlm} tj� d }t� }d}t|ddd |d
�}| j |�}d |_
d |_ d |_ ||_
d |_d
|_d|_|j|_|j� | j|j|j� | j|j
|k � tj|d � |j� | j|j
d� | j|j d� | j|j � | j|j|j� | j|jjd dj|�� | jt � �d � � d }| j|j |j � d S )Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ � s zYSubprocessTests.test_transition_starting_to_running_laststart_in_future.<locals>.<lambda>)r i rX r% z /bin/process)r rC Fr@ rA z_success: process entered RUNNING state, process has stayed up for > than {} seconds (startsecs)) rv rq rw rx r! r r� r r r r4 r0 r� r. r/ rB rC r� rm r0 r& r; r� r1 rl ri rj �formatrZ ry r ) r rq r r� r- Ztest_startsecsr1 r% r� r )rt r �7test_transition_starting_to_running_laststart_in_future� sB
zGSubprocessTests.test_transition_starting_to_running_laststart_in_futurec s� ddl m} g � |j|j� fdd�� ddlm} tj� d }t� }t|ddd�}| j |�}d |_
||_ d|_ |j
|_|j� | j|j|j
� | j|j |k � |j� | j|j|j� | jt� �d � | j� d j|j� d S )
Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ * s zUSubprocessTests.test_transition_backoff_to_starting_delay_in_future.<locals>.<lambda>)r i r% z /bin/processrC )rv rq rw rx r! r r� r r r r. r0 r4 ru rm r0 r& r; r� rZ ry rz )r rq r r� r- r1 r% r )rt r �3test_transition_backoff_to_starting_delay_in_future' s&
zCSubprocessTests.test_transition_backoff_to_starting_delay_in_futurec s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}| j|�}d|_ d |_
d|_ d
|_ d |_
d |_|j|_|j� | j|j
d� | j|j d� | j|j � | j|jjd d
� | jt� �d� � d }| j|j|j� d S )Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ L s zBSubprocessTests.test_transition_backoff_to_fatal.<locals>.<lambda>)r r% z /bin/processrC i' Fr@ rA zHgave up: process entered FATAL state, too many start retries too quickly)rv rq rw rx r! r r r r r. r4 r0 r� rB rC ru rm r0 r& r; ri rj rZ ry r� )r rq r r- r1 r% r� r )rt r � test_transition_backoff_to_fatalI s.
z0SubprocessTests.test_transition_backoff_to_fatalc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}| j|�}t |_
|j |_ |j
� | j|j |j � | j� g � d S )Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ k s zISubprocessTests.test_transition_stops_unkillable_notyet.<locals>.<lambda>)r r% z /bin/process)rv rq rw rx r! r r r r r r0 r� rm r0 r& )r rq r r- r1 r% r )rt r �'test_transition_stops_unkillable_notyeth s
z7SubprocessTests.test_transition_stops_unkillable_notyetc s� ddl m} g � |j|j� fdd�� ddlm} t� }t|ddd�}| j|�}d|_ d|_
d |_ |j |_
|j� | j|j � | j|j d� | j|j
|j � | j|jjd d
� | j|jd tj� | j� g � d S ) Nr )rq c s
� j | �S )N)rr )rs )rt r r r_ { s zBSubprocessTests.test_transition_stops_unkillable.<locals>.<lambda>)r r% z /bin/processrC Fz"killing 'process' (1) with SIGKILL)rv rq rw rx r! r r r r r0 r/ r3 r� rm r0 r; r� r& ri rj r� r� r )r rq r r- r1 r% r )rt r � test_transition_stops_unkillablex s&
z0SubprocessTests.test_transition_stops_unkillablec C s8 t � }t|dd�}| j|�}d|_| j|jd�d� d S )Nr@ z/testr� F)r r r rm r& � change_state)r r- r, r8 r r r �2test_change_state_doesnt_notify_if_no_state_change� s
zBSubprocessTests.test_change_state_doesnt_notify_if_no_state_changec C s\ ddl m} t� }t|dd�}| j|�}d|_|j|j� | j|j d� | j
|j dk� d S )Nr )r r@ z/testr� rC ) r! r r r r rm rK ru r& r4 r; r0 )r r r- r, r8 r r r �(test_change_state_sets_backoff_and_delay� s
z8SubprocessTests.test_change_state_sets_backoff_and_delayN)]r� r� r� r r r r( r9 r? rF rH rI rL rO rP rS rT rU rV r\ r] rh rk rp r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� 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 r8 r9 r; r< r= r> r? rD rF rG rH rI rJ rL rM r r r r r s�
+ "
)"!% 4" r c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z e j
edeejd��dd� �Ze j
edeejd��dd� �Ze j
ededd��dd � �ZdS ) �FastCGISubprocessTestsc C s ddl m} |S )Nr )�FastCGISubprocess)r rO )r rO r r r r � s z&FastCGISubprocessTests._getTargetClassc O s | j � ||�S )N)r )r r r r r r r � s z FastCGISubprocessTests._makeOnec C s ddl m} |� d S )Nr )r )r r )r r r r r r � s z FastCGISubprocessTests.tearDownc C s8 t � }d|_t|dddd�}| j|�}| jt|j� d S )Nr r z/good/filenamerC )r� )r r� r r rJ �NotImplementedErrorrn )r r- r, r8 r r r �
test_no_group� s
z$FastCGISubprocessTests.test_no_groupc C sF t � }d|_t|dddd�}| j|�}tt|��|_| jt|j � d S )Nr r z/good/filenamerC )r� )
r r� r r r r
r� rJ rP rn )r r- r, r8 r r r �test_no_socket_manager� s
z-FastCGISubprocessTests.test_no_socket_managerc C s� t � }d|_t|dddd�}| j|�}td�}t|ddd |�}t|�|_|j� }| j |d � | j t
|j �d � | j |j d d� | j |j |j d
d� | j |j |j d d � | j t
|j
�|jd � d S )
Nr r z/good/filenamerC )r� r� �whateveri� r� Z child_stdoutZ child_stderrrX )r r� r r r r
r r� rn r& rZ r� r5 r� r� )r r- r, r8 � sock_config�gconfigro r r r �test_prepare_child_fds� s
z-FastCGISubprocessTests.test_prepare_child_fdsc C s� t � }d|_t|dddd�}d|_| j|�}td�}t|dd d |�}t|�|_|j � }| j
|d � | j
t |j �d
� | j
|j d d� | j
t |j
�|jd � d S ) Nr r z/good/filenamerC )r� Tr� rS i� rX r� )r r� r r� r r r
r r� rn r& rZ r� r� r� )r r- r, r8 rT rU ro r r r �(test_prepare_child_fds_stderr_redirected� s
z?FastCGISubprocessTests.test_prepare_child_fds_stderr_redirectedc C sn t � }t|dddd�}| j|�}td�}t|ddd |�}t|�|_| j|jd k� |j � | j
|jd k� d S )Nr z/good/filenamerC )r� r� rS i� ) r r r r r
r r� r; � fcgi_sock� before_spawnr1 )r r- r, r8 rT rU r r r �!test_before_spawn_gets_socket_ref� s
z8FastCGISubprocessTests.test_before_spawn_gets_socket_refc C sB t � }t|dddd�}| j|�}d|_|j� | j|jd k� d S )Nr z/good/filenamerC )r� Zhello)r r r rX � after_finishr; )r r- r, r8 r r r �$test_after_finish_removes_socket_ref� s
z;FastCGISubprocessTests.test_after_finish_removes_socket_refr )Z return_valuec C s� t � }t|dddd�}| j|�}t� |_|jtjtj�}| j tj
|d� | j d|jj d� t j}| j d|j d� |j
d d }|j
d d }| j tj|d
� | j tj|d � d S ) Nr z/good/filenamerC )r� z3FastCGISubprocess.finish() did not pass thru resultz0FastCGISubprocess.after_finish() not called oncez#Subprocess.finish() not called oncer rX z*Subprocess.finish() pid arg was not passedz*Subprocess.finish() sts arg was not passed)r r r r r[ r r r/ r� r& �
finish_result�
call_countr � call_args)r r- r, r8 ro Z finish_mockZpid_argZsts_argr r r �test_finish_override� s$
z+FastCGISubprocessTests.test_finish_overridern c C sl t � }t|dddd�}| j|�}t� |_|j� }| jtj|d� | jd|jj d� t
j}| jd|j d� d S )Nr z/good/filenamerC )r� z2FastCGISubprocess.spawn() did not pass thru resultz0FastCGISubprocess.before_spawn() not called oncez"Subprocess.spawn() not called once) r r r r rY rn r& r �ppidr^ r )r r- r, r8 ro Z
spawn_mockr r r �test_spawn_override_success s
z2FastCGISubprocessTests.test_spawn_override_successNc C sj t � }t|dddd�}| j|�}t� |_d|_|j� }| jd |d� | jd|jjd� | jd |jd� d S ) Nr z/good/filenamerC )r� znuke me on errorz2FastCGISubprocess.spawn() did return None on errorz0FastCGISubprocess.before_spawn() not called oncez:FastCGISubprocess.spawn() did not remove sock ref on error) r r r r rY rX rn r& r^ )r r- r, r8 ro r r r �test_spawn_error s
z'FastCGISubprocessTests.test_spawn_error)r� r� r� r r r rQ rR rV rW rZ r\ r �objectr r r r] r` ra rb rc r r r r rN � s rN c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�ProcessGroupBaseTestsc C s ddl m} |S )Nr )�ProcessGroupBase)r rf )r rf r r r r ' s z%ProcessGroupBaseTests._getTargetClassc O s | j � ||�S )N)r )r rR r r r r r + s z ProcessGroupBaseTests._makeOnec C sj t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_|j � }| j
||g� d S )Nr )r �process1z
/bin/process1)rm )�pconfigs) r r! r r r r� r
r � processesZget_unstopped_processesr& )r r- r �pconfig1rg rU r� Z unstoppedr r r � test_get_unstopped_processes. s
z2ProcessGroupBaseTests.test_get_unstopped_processesc C s\ t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_|j � d S )Nr )r rg z
/bin/process1)rm )rh )
r r! r r r r� r
r ri �
before_remove)r r- r rj rg rU r� r r r �test_before_remove9 s
z(ProcessGroupBaseTests.test_before_removec
C s ddl m} t� }t|ddd�}t||jd�}t|ddd�}t||jd�}t|ddd �}t||jd�}t|d
d
d �} t| |jd�}
d |
_ d
|
_
t ||||| gd�} | j | �} ||||
d�| _
| j� | j|jd� | j|jd� | j|jd� | j|
jd� | j|
j|j� d S )Nr )r rg z
/bin/process1)rm �process2z
/bin/process2�process3z
/bin/process3�process4z
/bin/process4i� r� )rh )rg rn ro rp FT)r! r r r r r� rl r� ru r0 r4 r
r ri Zstop_allr& Z stop_calledrm r� )
r r r- rj rg �pconfig2rn Zpconfig3ro Zpconfig4rp rU r� r r r �
test_stop_allC s0
z#ProcessGroupBaseTests.test_stop_allc
C s� t � }ddlm} t|ddd�}t||jd�}dd i|_t|ddd�}t||jd�}d d i|_t|||gd
�}| j|�}||d �|_ |j
� } | j | d d d �� d S )
Nr )r rg z
/bin/process1)rm r� rn z
/bin/process2r� )rh )rg rn )r� r� ) r r! r r r r� r6 r
r ri Zget_dispatchersr& )
r r- r rj rg rq rn rU r� ro r r r �test_get_dispatchersa s
z*ProcessGroupBaseTests.test_get_dispatchersc C sj t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_|j � | j
|j d� d S )Nr )r rg z
/bin/process1)rm )rh T) r r! r r r r� r
r ri rD r& rE )r r- r rj rg rU r� r r r rF p s
z%ProcessGroupBaseTests.test_reopenlogsc C sj t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_|j � | j
|j d� d S )Nr )r rg z
/bin/process1)rm )rh T) r r! r r r r� r
r ri rG r& Z logsremoved)r r- r rj rg rU r� r r r rH { s
z%ProcessGroupBaseTests.test_removelogsc C s� t � }t|�}| j|�}t|�}| j|�}t|�}| j|�}d|j_d|j_d|j_||g}|j� | j|||g� | j||� | j||� d S )Nr� rC )r r
r r, r* r+ r& r� ) r r- Zgconfig1Zgroup1Zgconfig2Zgroup2Zconfig3Zgroup3rt r r r � test_ordering_and_comparison� s
z2ProcessGroupBaseTests.test_ordering_and_comparisonN) r� r� r� r r rk rm rr rs rF rH rt r r r r re & s
re c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�ProcessGroupTestsc C s ddl m} |S )Nr )� ProcessGroup)r rv )r rv r r r r � s z!ProcessGroupTests._getTargetClassc C sD t � }t|�}| j|�}t|�}| jd|k� | j|jd�|� d S )Nz supervisor.process.ProcessGroupznamed whatever>)r r
r r: r; r= )r r- rU r� r> r r r r? � s
zProcessGroupTests.test_reprc C sj t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_|j � | j
|j d� d S )Nr )r rg z
/bin/process1)rm )rh T) r r! r r r r� r
r ri r0 r& � transitioned)r r- r rj rg rU r� r r r �test_transition� s
z!ProcessGroupTests.test_transitionN)r� r� r� r r? rx r r r r ru � s ru c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�FastCGIProcessGroupTestsc C s ddl m} |S )Nr )�FastCGIProcessGroup)r rz )r rz r r r r � s z(FastCGIProcessGroupTests._getTargetClassc K s | j � }||f|�S )N)r )r r, �kwargs�clsr r r r � s z!FastCGIProcessGroupTests._makeOnec C s6 t � }t|�}d |_G dd� dt�}| j||d� d S )Nc @ s e Zd Zdd� Zdd� ZdS )zVFastCGIProcessGroupTests.test___init__without_socket_error.<locals>.DummySocketManagerc S s d S )Nr )r r, ri r r r �__init__� s z_FastCGIProcessGroupTests.test___init__without_socket_error.<locals>.DummySocketManager.__init__c S s d S )Nr )r r r r �
get_socket� s zaFastCGIProcessGroupTests.test___init__without_socket_error.<locals>.DummySocketManager.get_socketN)r� r� r� r} r~ r r r r �DummySocketManager� s r )�
socketManager)r r
�
socket_configrd r )r r- rU r r r r �!test___init__without_socket_error� s
z:FastCGIProcessGroupTests.test___init__without_socket_errorc C s< t � }t|�}d |_G dd� dt�}| jt| j||d� d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )zSFastCGIProcessGroupTests.test___init__with_socket_error.<locals>.DummySocketManagerc S s d S )Nr )r r, ri r r r r} � s z\FastCGIProcessGroupTests.test___init__with_socket_error.<locals>.DummySocketManager.__init__c S s t d��d S )Nr� )�KeyError)r r r r r~ � s z^FastCGIProcessGroupTests.test___init__with_socket_error.<locals>.DummySocketManager.get_socketc S s dS )Nr, r )r r r r r, � s zZFastCGIProcessGroupTests.test___init__with_socket_error.<locals>.DummySocketManager.configN)r� r� r� r} r~ r, r r r r r � s r )r� )r r
r� rd rJ �
ValueErrorr )r r- rU r r r r � test___init__with_socket_error� s z7FastCGIProcessGroupTests.test___init__with_socket_errorN)r� r� r� r r r� r� r r r r ry � s
ry 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'S )(�EventListenerPoolTestsc C s ddl m} |� d S )Nr )r )r r )r r r r r �setUp� s z EventListenerPoolTests.setUpc C s ddl m} |� d S )Nr )r )r r )r r r r r r � s z EventListenerPoolTests.tearDownc C s ddl m} |S )Nr )�EventListenerPool)r r� )r r� r r r r � s z&EventListenerPoolTests._getTargetClassc C s� t � }t|�}G dd� d�}|f|_| j|�}ddlm} | jt|j�d� | j|jd ||j f� | j|jd |j
|j f� | j|j d� d S )Nc @ s e Zd ZdS )z3EventListenerPoolTests.test_ctor.<locals>.EventTypeN)r� r� r� r r r r � EventType� s r� r )rq rX rC r� )
r r
� pool_eventsr rv rq r& rZ � callbacks� _acceptEventr$ �handle_rejected�serial)r r- rU r� �poolrq r r r r9 � s
z EventListenerPoolTests.test_ctorc C sj t � }t|�}G dd� d�}|f|_| j|�}ddlm} | jt|j�d� |j � | jt|j�d� d S )Nc @ s e Zd ZdS )zUEventListenerPoolTests.test_before_remove_unsubscribes_from_events.<locals>.EventTypeN)r� r� r� r r r r r� � s r� r )rq rX )
r r
r� r rv rq r& rZ r� rl )r r- rU r� r� rq r r r �+test_before_remove_unsubscribes_from_events� s
zBEventListenerPoolTests.test_before_remove_unsubscribes_from_eventsc C s� t � }d|_t|�}d|_| j|�}ddlm} |j|jj ddd�}|j
dd �\}}|j
� }| j |d d
� | j |d d � | j |d d
� | j |d d� | j |d d� | j |d d� | j |d d� | j |d� d S )NZthesupervisornameZ thepoolnamer )rq �P � zpayload
�
rC zver:3.0zserver:thesupervisornamerX z serial:80r� zpool:thepoolnamer� z
poolserial:20r� z&eventname:PROCESS_COMMUNICATION_STDOUTr� zlen:8) r Z
identifierr
rd r rv rq Z_eventEnvelopeZ
EventTypesZ PROCESS_COMMUNICATION_STDOUTrc r& ) r r- rU r� rq ro �header�payloadZheadersr r r �test__eventEnvelope� s$
z*EventListenerPoolTests.test__eventEnvelopec s� t � }t|�}t|ddd�}t|��t||gd�}| j|�}d�i|_d d g|_G dd� d�� G � �fdd�d�}|� }d|_|j|� | j |j|j
d d g� d S ) Nrg z
/bin/process1)rh c @ s e Zd ZdZdS )zLEventListenerPoolTests.test_handle_rejected_no_overflow.<locals>.DummyEvent1r@ N)r� r� r� r� r r r r � DummyEvent1 s r� c s e Zd Z�Z� � ZdS )zLEventListenerPoolTests.test_handle_rejected_no_overflow.<locals>.DummyEvent2N)r� r� r� r% r� r )r� rg r r � DummyEvent2 s r� rC ) r r
r r r ri � event_bufferr� r� r& r� )r r- rU rj r� r� Z
dummyeventr )r� rg r � test_handle_rejected_no_overflow s
z7EventListenerPoolTests.test_handle_rejected_no_overflowc s� t � }t|�}t|ddd�}t|��t||gd�}d|_| j|�}d�i|_G dd� d�� G � �fdd�d�}� d �}� d
�}� d �}|d �} |||g|_|j| � d
d� |jD �}
| j |
d d
d g� | j |j
j j j
d d� d S )Nrg z
/bin/process1)rh r� c @ s e Zd Zdd� ZdS )zWEventListenerPoolTests.test_handle_rejected_event_buffer_overflowed.<locals>.DummyEventc S s
|| _ d S )N)r� )r r� r r r r} / s z`EventListenerPoolTests.test_handle_rejected_event_buffer_overflowed.<locals>.DummyEvent.__init__N)r� r� r� r} r r r r r . s r c s e Zd Z� �fdd�ZdS )z_EventListenerPoolTests.test_handle_rejected_event_buffer_overflowed.<locals>.DummyRejectedEventc s �| _ � |�| _d S )N)r% r� )r r� )r rg r r r} 2 s zhEventListenerPoolTests.test_handle_rejected_event_buffer_overflowed.<locals>.DummyRejectedEvent.__init__N)r� r� r� r} r )r rg r r �DummyRejectedEvent1 s r� r� �b�cZrejectedc S s g | ]
}|j �qS r )r� )�.0rs r r r �
<listcomp>; s zWEventListenerPoolTests.test_handle_rejected_event_buffer_overflowed.<locals>.<listcomp>r z9pool whatever event buffer overflowed, discarding event a)r r
r r � buffer_sizer ri r� r� r& r, r- ri rj ) r r- rU rj r� r� Zevent_aZevent_bZevent_cZ rej_eventZserialsr )r rg r �,test_handle_rejected_event_buffer_overflowed% s(
zCEventListenerPoolTests.test_handle_rejected_event_buffer_overflowedc C s� t � }t|�}t|ddd�}ddlm} t||gd�}| j|�}|jd }ttj t
j tj ��|_ |j
|_t� }|j|� |j� | j|j|j
� | j|j|g� | j|jjd d� | j|jjd d� d S ) Nrg z
/bin/process1r )�EventListenerStates)rh zUepipe occurred while sending event abc to listener process1, listener state unchangedrC z<rebuffering event abc for pool whatever (buf size=0, max=10))r r
r r! r� r ri r� r� r� ra r� Zwrite_exception�READY�listener_stater r� �dispatchr& r� ri rj )r r- rU rj r� r� rg r� r r r �test_dispatch_pipe_errorA s&
z/EventListenerPoolTests.test_dispatch_pipe_errorc C s� ddl m} t� }t|�}t|ddd�}t||gd�}| j|�}|jd }ddlm} |j |_
t d �}|j |� | j
|j|j� | j
|jd |j� d S )Nr )� GlobalSerialrg z
/bin/process1)rh )r� rS )r r� r r
r r ri r! r� r� r� r r� r& r� Z pool_serials) r r� r- rU rj r� rg r� r� r r r �1test__acceptEvent_attaches_pool_serial_and_serialW s
zHEventListenerPoolTests.test__acceptEvent_attaches_pool_serial_and_serialc C sB t � }t|�}| j|�}t|�}| jd|k� | j|jd�� d S )Nz$supervisor.process.EventListenerPoolznamed whatever>)r r
r r: r; r= )r r- rU r� r> r r r r? f s
z EventListenerPoolTests.test_reprc C s� t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_t � }d|_
ddlm } |j |_
|j|� |j� | j|jd � | j|j|g� d S )
Nr )r rg z
/bin/process1)rm )rh r� )r� T)r r! r r r r� r
r ri r r� r� �BUSYr� r� r0 r& rw r� ) r r- r rj rg rU r� r� r� r r r � test_transition_nobody_readyn s
z3EventListenerPoolTests.test_transition_nobody_readyc C s� t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_t � }ddlm
} d|_ |j |_
|j|� |j� | j|jd � | j|j|g� | j|jd
� | j|j
|j � d S ) Nr )r rg z
/bin/process1)rm )rh )r� rC T� )r r! r r r r� r
r ri r r� r� r� r� r� r0 r& rw r� � stdin_buffer) r r- r rj rg rU r� r� r� r r r �&test_transition_event_proc_not_running s"
z=EventListenerPoolTests.test_transition_event_proc_not_runningc s� t � }ddlm} t|ddd�}t||jd�}t||gd�� | j� �}d|i|_t � }ddlm
} |j |_ G � fdd �d �}||_
|j|� |j� | j|jd
� | j|jg � |jjd d �\} }
| j|
d
|
� | j|j |j� | j|j|� d S )Nr )r rg z
/bin/process1)rm )rh )r� c s e Zd Z� ZdS )zMEventListenerPoolTests.test_transition_event_proc_running.<locals>.DummyGroupN)r� r� r� r, r )rU r r �
DummyGroup� s r� T�
rC s dummy event)r r! r r r rl r
r ri r r� r� r� r� r� r0 r& rw r� r� rc r� r� ) r r- r rj rg r� r� r� r� r� r� r )rU r �"test_transition_event_proc_running� s(
z9EventListenerPoolTests.test_transition_event_proc_runningc s� t � }ddlm} t|ddd�}t||jd�}t||gd�� | j� �}d|_t j � |_
d|i|_ t � }ddlm
} |j|_G � fd d
�d
�}||_|j|� |j� | j|jd � | j|j|g� d S ) Nr )r rg z
/bin/process1)rm )rh r� )r� c s e Zd Z� ZdS )zkEventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_notyet.<locals>.DummyGroupN)r� r� r� r, r )rU r r r� � s r� T)r r! r r r rl r
r �dispatch_throttler� �
last_dispatchri r r� r� r� r� r� r0 r& rw r� ) r r- r rj rg r� r� r� r� r )rU r �@test_transition_event_proc_running_with_dispatch_throttle_notyet� s$
zWEventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_notyetc s t � }ddlm} t|ddd�}t||jd�}t||gd�� | j� �}d|_t j � d |_
d|i|_ t � }dd lm
} |j|_G � fd
d �d �}||_|j|� |j� | j|jd � | j|jg � |jjd
d�\} }
| j|
d|
� | j|j|j� | j|j|� d S )Nr )r rg z
/bin/process1)rm )rh r� i� )r� c s e Zd Z� ZdS )zjEventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_ready.<locals>.DummyGroupN)r� r� r� r, r )rU r r r� � s r� Tr� rC s dummy event)r r! r r r rl r
r r� r� r� ri r r� r� r� r� r� r0 r& rw r� r� rc r� r� ) r r- r rj rg r� r� r� r� r� r� r )rU r �?test_transition_event_proc_running_with_dispatch_throttle_ready� s,
zVEventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_readyc
s� t j � d }t� }ddlm} t|ddd�}t||jd�}t||gd�� | j� �}d|_ ||_
d|i|_ t � }dd lm
} |j|_G � fd
d �d �} | |_|j|� |j� | j|jd � | j|j|g� | j|j
|k � d S )
Ni r )r rg z
/bin/process1)rm )rh r� )r� c s e Zd Z� ZdS )z|EventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_last_dispatch_in_future.<locals>.DummyGroupN)r� r� r� r, r )rU r r r� � s r� T)r� r r! r r r rl r
r r� r� ri r r� r� r� r� r� r0 r& rw r� r; )
r r� r- r rj rg r� r� r� r� r )rU r �Qtest_transition_event_proc_running_with_dispatch_throttle_last_dispatch_in_future� s(
zhEventListenerPoolTests.test_transition_event_proc_running_with_dispatch_throttle_last_dispatch_in_futurec C sv t � }ddlm} t|ddd�}t||jd�}t||gd�}| j|�}d|i|_t � }|j
|� | j |j |�d� d S )Nr )r rg z
/bin/process1)rm )rh F)
r r! r r r r� r
r ri r r� r& �_dispatchEvent)r r- r rj rg rU r� r� r r r � test__dispatchEvent_notready� s
z3EventListenerPoolTests.test__dispatchEvent_notreadyc
s� t � }ddlm} t|ddd�}t||jd�}dd� }||_t||gd�� | j� �}d|i|_ t
� }dd lm } |j |_
G � fd
d �d �} | |_|j|� | jt|j|� d S ) Nr )r rg z
/bin/process1)rm c S s t tj��d S )N)r� r� r� )r� r r r � raise_epipe s zcEventListenerPoolTests.test__dispatchEvent_proc_write_raises_non_EPIPE_OSError.<locals>.raise_epipe)rh )r� c s e Zd Z� ZdS )zbEventListenerPoolTests.test__dispatchEvent_proc_write_raises_non_EPIPE_OSError.<locals>.DummyGroupN)r� r� r� r, r )rU r r r� s r� )r r! r r r rl r� r
r ri r r� r� r� r� r� rJ r� r� )
r r- r rj rg r� r� r� r� r� r )rU r �7test__dispatchEvent_proc_write_raises_non_EPIPE_OSError� s
zNEventListenerPoolTests.test__dispatchEvent_proc_write_raises_non_EPIPE_OSErrorN)r� r� r� r� r r r9 r� r� r� r� r� r� r? r� r� r� r� r� r� r� r� r r r r r� � s& r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�test_new_serialc C s ddl m} ||�S )Nr )�
new_serial)r r� )r �instr� r r r �_callFUT s ztest_new_serial._callFUTc sN ddl m� G � fdd�dt�}|� }| j|�}| j|jd� | j|d� d S )Nr )r c s e Zd Z� fdd�ZdS )z8test_new_serial.test_inst_serial_is_maxint.<locals>.Instc s
� | _ d S )N)r� )r )r r r r} s zAtest_new_serial.test_inst_serial_is_maxint.<locals>.Inst.__init__N)r� r� r� r} r )r r r �Inst s r� )�supervisor.compatr rd r� r& r� )r r� r� ro r )r r �test_inst_serial_is_maxint s
z*test_new_serial.test_inst_serial_is_maxintc C s> G dd� dt �}|� }| j|�}| j|jd� | j|d� d S )Nc @ s e Zd Zdd� ZdS )z<test_new_serial.test_inst_serial_is_not_maxint.<locals>.Instc S s
d| _ d S )NrC )r� )r r r r r} " s zEtest_new_serial.test_inst_serial_is_not_maxint.<locals>.Inst.__init__N)r� r� r� r} r r r r r� ! s r� rX )rd r� r& r� )r r� r� ro r r r � test_inst_serial_is_not_maxint s
z.test_new_serial.test_inst_serial_is_not_maxintN)r� r� r� r� r� r� r r r r r� s
r� )#r� ra r� r` r� Zunittestr� r r r� r r r r r r r
r r r
r r r r r Zsupervisor.optionsr ZTestCaser rN re ru ry r� r� r r r r �<module> sV v" =