Edit File: 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 z@SubprocessTests.test_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" =
Back to File Manager