Edit File: test_supervisorctl.cpython-36.pyc
3 �k�`�@ � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZm Z d dl m Z G dd� dej �Z G d d � d ej �ZG d d � d ej �ZG d d� dej �ZG dd� d�ZG dd� d�ZG dd� d�ZG dd� d�ZG dd� d�Zdd� Zedkr�ejdd � dS ) � N)�xmlrpc)�StringIO)� xmlrpclib)�LSBInitExitStatuses�LSBStatusExitStatuses)�DummyRPCServerc @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�fgthread_Testsc C s ddl m} |S )Nr )�fgthread)�supervisor.supervisorctlr )�selfr � r �(/usr/lib/python3.6/test_supervisorctl.py�_getTargetClass s z fgthread_Tests._getTargetClassc C s | j � ||�S )N)r )r Zprogram�ctlr r r �_makeOne s zfgthread_Tests._makeOnec C s, t � }t|�}| jd |�}| j|jd� d S )NF)�DummyClientOptions�DummyControllerr � assertEqual�killed)r �optionsr �instr r r � test_ctor s zfgthread_Tests.test_ctorc C s: t � }t|�}| jd |�}|jd dd �}| j||j� d S )NZcall)r r r � globaltracer � localtrace)r r r r �resultr r r �test_globaltrace_call s z$fgthread_Tests.test_globaltrace_callc C s8 t � }t|�}| jd |�}|jd d d �}| j|d � d S )N)r r r r r )r r r r r r r r �test_globaltrace_noncall s z'fgthread_Tests.test_globaltrace_noncallc C sr t � }t|�}| jd |�}d|_y|jd dd � W n0 tk rb } z| j|jd � W Y d d }~X n X | jd� d S )NT�linez(No exception thrown. Excepted SystemExit) r r r r r � SystemExitr �codeZfail)r r r r �er r r � test_localtrace_killed_whyline% s z-fgthread_Tests.test_localtrace_killed_whylinec C s@ t � }t|�}| jd |�}d|_|jd d d �}| j||j� d S )NT)r r r r r r )r r r r r r r r �"test_localtrace_killed_not_whyline1 s z1fgthread_Tests.test_localtrace_killed_not_whylinec C st t � }t|�}| jd |�}d|_G dd� dt�}|� |_|� |_|j� | j|j� | j|jj � | j|jj � d S )NTc @ s e Zd Zdd� ZdS )z0fgthread_Tests.test_kill.<locals>.DummyCloseablec S s d| _ d S )NT)�closed)r r r r �close? s z6fgthread_Tests.test_kill.<locals>.DummyCloseable.closeN)�__name__� __module__� __qualname__r$ r r r r �DummyCloseable> s r( ) r r r r �objectZoutput_handlerZ error_handler�kill� assertTruer# )r r r r r( r r r � test_kill9 s zfgthread_Tests.test_killN) r% r& r' r r r r r r! r" r, r r r r r s r c @ s4 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'dKS )L�ControllerTestsc C s ddl m} |S )Nr )� Controller)r r. )r r. r r r r I s z ControllerTests._getTargetClassc C s | j � |�S )N)r )r r r r r r M s zControllerTests._makeOnec C s( t � }| j|�}| j|j|jd � d S )Nz> )r r r �prompt)r r � controllerr r r r Q s zControllerTests.test_ctorc C s( t � }| j|�}|j� }| j|d� d S )NT)r r �upcheckr )r r r0 r r r r � test__upcheckV s z ControllerTests.test__upcheckc C sP t � }dd� |jj_| j|�}t� |_|j� }| j|d� | j|jj � d� d S )Nc W s dS )Nz1.0r )�xr r r �<lambda>^ s zDControllerTests.test__upcheck_wrong_server_version.<locals>.<lambda>FzvSorry, this version of supervisorctl expects to talk to a server with API version 3.0, but the remote version is 1.0. ) r �_server� supervisor� getVersionr r �stdoutr1 r �getvalue)r r r0 r r r r �"test__upcheck_wrong_server_version\ s z2ControllerTests.test__upcheck_wrong_server_versionc sd t � }ddlm� � fdd�}||jj_| j|�}t� |_|j � }| j |d� | j |jj � d� d S )Nr )�Faultsc s t j� jd��d S )NZduh)r �FaultZUNKNOWN_METHODr )r; r r r7 k s z@ControllerTests.test__upcheck_unknown_method.<locals>.getVersionFz�Sorry, supervisord responded but did not recognize the supervisor namespace commands that supervisorctl uses to control it. Please check that the [rpcinterface:supervisor] section is enabled in the configuration file (see sample.conf). ) r �supervisor.xmlrpcr; r5 r6 r7 r r r8 r1 r r9 )r r r7 r0 r r )r; r � test__upcheck_unknown_methodh s z,ControllerTests.test__upcheck_unknown_methodc s^ t � }ddlm� � fdd�}||jj_| j|�}t� |_| j t j |j � | j |jtj� d S )Nr )r; c s t j� jd��d S )N� )r r< �FAILED)�arg�kw)r; r r �f} s zEControllerTests.test__upcheck_reraises_other_xmlrpc_faults.<locals>.f)r r= r; r5 r6 r7 r r r8 � assertRaisesr r< r1 r � exitstatusr �GENERIC)r r rC r0 r )r; r �*test__upcheck_reraises_other_xmlrpc_faultsz s z:ControllerTests.test__upcheck_reraises_other_xmlrpc_faultsc s� t � }dd l�dd l� � �fdd�}||jj_| j|�}t� |_|j � }| j |d� |jj � }| j d|k� | j |j tj� d S )Nr c s �j � jd��d S )Nz nobody home)�error� ECONNREFUSED)rA rB )�errno�socketr r � raise_fault� s zTControllerTests.test__upcheck_catches_socket_error_ECONNREFUSED.<locals>.raise_faultFzrefused connection)r rK rJ r5 r6 r7 r r r8 r1 r r9 r+ rE r ZINSUFFICIENT_PRIVILEGES)r r rL r0 r �outputr )rJ rK r �/test__upcheck_catches_socket_error_ECONNREFUSED� s z?ControllerTests.test__upcheck_catches_socket_error_ECONNREFUSEDc s� t � }dd l�dd l� � �fdd�}||jj_| j|�}t� |_|j � }| j |d� |jj � }| j d|k� | j |j tj� d S )Nr c s �j � jd��d S )Nz nobody home)rH �ENOENT)rA rB )rJ rK r r rL � s zNControllerTests.test__upcheck_catches_socket_error_ENOENT.<locals>.raise_faultFz no such file)r rK rJ r5 r6 r7 r r r8 r1 r r9 r+ rE r � NOT_RUNNING)r r rL r0 r rM r )rJ rK r �)test__upcheck_catches_socket_error_ENOENT� s z9ControllerTests.test__upcheck_catches_socket_error_ENOENTc sT t � }dd l�dd l� � �fdd�}||jj_| j|�}t� |_| j �j |j � d S )Nr c s �j � jd��d S )Nr? )rH ZEBADF)rA rB )rJ rK r r rC � s zEControllerTests.test__upcheck_reraises_other_socket_faults.<locals>.f) r rK rJ r5 r6 r7 r r r8 rD rH r1 )r r rC r0 r )rJ rK r �*test__upcheck_reraises_other_socket_faults� s z:ControllerTests.test__upcheck_reraises_other_socket_faultsc C sP t � }| j|�}t� |_t� }|f|j_|jd�}| j|d � | j|j d� d S )N�helpT) r r r r8 � DummyPluginr �plugins�onecmdr �helped)r r r0 �pluginr r r r � test_onecmd� s zControllerTests.test_onecmdc C sd t � }| j|�}t� |_t� }|f|j_d|_|jd� | j |j� d|_|jd� | j |j� d S )NFrS r? ) r r r r8 rT r rU rW rV r+ Z assertFalse)r r r0 rX r r r �.test_onecmd_empty_does_not_repeat_previous_cmd� s z>ControllerTests.test_onecmd_empty_does_not_repeat_previous_cmdc C s: t � }| j|�}t� |_i |_|jd� | j|jd � d S )NrS )r r r r8 Z_complete_inforV r )r r r0 r r r �#test_onecmd_clears_completion_cache� s z3ControllerTests.test_onecmd_clears_completion_cachec C sH t � }| j|�}t� |_|jd� | j|jj� d� | j|jtj � d S )NZbadcmdz*** Unknown syntax: badcmd ) r r r r8 rV r r9 rE r rF )r r r0 r r r � test_onecmd_bad_command_error� s z-ControllerTests.test_onecmd_bad_command_errorc C s\ t � }| j|�}t� |_dg|_|jdddd�}| j|d� |jdddd�}| j|d � d S )NrS r? r )r zhelp � )r r r r8 �vocab�completer )r r r0 r r r r �test_complete_action_empty� s z*ControllerTests.test_complete_action_emptyc C s\ t � }| j|�}t� |_dg|_|jdddd�}| j|d� |jdddd�}| j|d � d S )NrS �hr )r zhelp r] )r r r r8 r^ r_ r )r r r0 r r r r � test_complete_action_partial� s z,ControllerTests.test_complete_action_partialc C s@ t � }| j|�}t� |_dg|_|jdddd�}| j|d� d S )NrS r )r zhelp )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_action_whole� s z*ControllerTests.test_complete_action_wholec C s8 t � }| j|�}t� |_|jdddd�}| j|d � d S )N�badr )r )r r r r8 r_ r )r r r0 r r r r �*test_complete_unknown_action_uncompletable� s z:ControllerTests.test_complete_unknown_action_uncompletablec C sB t � }| j|�}t� |_ddg|_|jdddd�}| j|d � d S )NrS �addr? r] zbad )r )r r r r8 r^ r_ r )r r r0 r r r r �.test_complete_unknown_action_arg_uncompletable� s z>ControllerTests.test_complete_unknown_action_arg_uncompletablec C sz t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d� |jdd dd�}| j|d � d S ) NrS �startr? r zhelp )r r] zstart � )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_help_empty s z(ControllerTests.test_complete_help_emptyc C s^ t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � d S ) NrS rh Zher zhelp he)r zhelp r] )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_help_action s z)ControllerTests.test_complete_help_actionc C s� t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � |jdd dd�}| j|d � |jdd dd�}| j|d � |jdddd�}| j|d � d S )NrS rh r? r zstart )r zfoo r] zbar ri z baz:baz_01 � zbaz:* � )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_start_empty s z)ControllerTests.test_complete_start_emptyc C s^ t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � d S ) NrS rh rC r zstart f)r zfoo r] )r r r r8 r^ r_ r )r r r0 r r r r � test_complete_start_no_colon- s z,ControllerTests.test_complete_start_no_colonc C sz t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � |jdd dd�}| j|d � d S ) NrS rh zfoo:r z start foo:)r zfoo:foo r] zfoo:* ri )r r r r8 r^ r_ r )r r r0 r r r r � test_complete_start_with_colon7 s z.ControllerTests.test_complete_start_with_colonc C sB t � }| j|�}t� |_ddg|_|jdddd�}| j|d � d S )NrS rh rd r z start bad)r )r r r r8 r^ r_ r )r r r0 r r r r �!test_complete_start_uncompletableC s z1ControllerTests.test_complete_start_uncompletablec C sf t � }| j|�}t� |_ddg|_|jdddd�}| j|d � dd� }||jjj _ |jdd dd� d S ) NrS rh r? r zstart )r c _ s t d��d S )Nz(should not have called getAllProcessInfo)� Exception)rA rB r r r rC R s z<ControllerTests.test_complete_caches_process_info.<locals>.fr] ) r r r r8 r^ r_ ZassertNotEqualr r5 r6 �getAllProcessInfo)r r r0 r rC r r r �!test_complete_caches_process_infoK s z1ControllerTests.test_complete_caches_process_infoc C s� t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � |jdd dd�}| j|d � |jdd dd�}| j|d � d S ) NrS rf r? r zadd )r zfoo r] zbar ri zbaz rl )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_add_emptyW s z'ControllerTests.test_complete_add_emptyc C sB t � }| j|�}t� |_ddg|_|jdddd�}| j|d � d S )NrS rf rd r zadd bad)r )r r r r8 r^ r_ r )r r r0 r r r r � test_complete_add_uncompletablee s z/ControllerTests.test_complete_add_uncompletablec C s^ t � }| j|�}t� |_ddg|_|jdddd�}| j|d� |jdddd�}| j|d � d S ) NrS rf rC r zadd f)r zfoo r] )r r r r8 r^ r_ r )r r r0 r r r r �test_complete_add_groupm s z'ControllerTests.test_complete_add_groupc C sB t � }| j|�}t� |_ddg|_|jdddd�}| j|d � d S )NrS �reloadr? r] zreload )r )r r r r8 r^ r_ r )r r r0 r r r r �&test_complete_reload_arg_uncompletablew s z6ControllerTests.test_complete_reload_arg_uncompletablec C s" t � }| j|�}| j|jd� d S )Nz*** No help on %s)r r r �nohelp)r r r0 r r r � test_nohelp s zControllerTests.test_nohelpc C sH t � }| j|�}t� |_|jd�}|jj� }| j|d � | j|d� d S )Nr? z foo helped)r r r r8 �do_helpr9 r )r r r0 �results�helpvalr r r � test_do_help� s z ControllerTests.test_do_helpc C sJ t � }| j|�}t� |_|jd�}| j|d � |jj� }| jd|k� d S )NrS zhelp Print a list)r r r r8 r| r r9 r+ )r r r0 r} r~ r r r �test_do_help_for_help� s z%ControllerTests.test_do_help_for_helpc C s2 t � }| j|�}|j� }|j� j}| j||� d S )N)r r �get_supervisor�getServerProxyr6 r )r r r0 �proxy�expectedr r r �<test_get_supervisor_returns_serverproxy_supervisor_namespace� s zLControllerTests.test_get_supervisor_returns_serverproxy_supervisor_namespacec C s0 t � }| j|�}|j� }|j� }| j||� d S )N)r r �get_server_proxyr� r )r r r0 r� r� r r r �6test_get_server_proxy_with_no_args_returns_serverproxy� s zFControllerTests.test_get_server_proxy_with_no_args_returns_serverproxyc C s4 t � }| j|�}|jd�}|j� j}| j||� d S )N�system)r r r� r� r� r )r r r0 r� r� r r r �;test_get_server_proxy_with_namespace_returns_that_namespace� s zKControllerTests.test_get_server_proxy_with_namespace_returns_that_namespacec C sL ddl m} g }|� }| jt|j�dk� g |_|j|td� | j|� d S )Nr )� ClientOptions)�doc)Zsupervisor.optionsr� r+ �lenZ searchpathsZrealize�__doc__r )r r� �argsr r r r �#test_real_controller_initialization� s z3ControllerTests.test_real_controller_initializationN)(r% r& r' r r r r2 r: r> rG rN rQ rR rY rZ r[ r\ r` rb rc re rg rj rk rn ro rp rq rt ru rv rw ry r{ r r� r� r� r� r� r r r r r- H sJ r- c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �TestControllerPluginBasec C s ddl m} |S )Nr )�ControllerPluginBase)r r� )r r� r r r r � s z(TestControllerPluginBase._getTargetClassc O s* | j � }t� }t|�}||f|�|�}|S )N)r r r )r rA rB �klassr r rX r r r r � s z!TestControllerPluginBase._makeOnec C s� | j � }|jd �}| j|d � | j|jjj� d� | jt|jj�d� |jjd }| j|d d� | j|d g � | j|d d� | j|d d� d S ) N� r] r z%unnamed commands (type help <topic>):ri � rl �P )r r| r r r8 r9 r� �topics_printed)r rX r Ztopicsr r r �test_do_help_noarg� s z+TestControllerPluginBase.test_do_help_noargc C sJ | j � }|jd�}| j|d � | j|jjj� d� | jt|jj�d� d S )N�foozno help on foo r )r r| r r r8 r9 r� r� )r rX r r r r �test_do_help_witharg� s z-TestControllerPluginBase.test_do_help_withargN)r% r& r' r r r� r� r r r r r� � s r� c @ sl 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�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d Zcd�dĄ Zdd�dƄ Zed�dȄ Zfd�dʄ Zgd�d̄ Zhd�d΄ Zid�dЄ Zjd�d҄ Zkd�dԄ Zld�dք Zmd�d Znd�dڄ Zod�d܄ Zpd�dބ Zqd�d� Zrd�d� Zsd�d� Ztd�d� Zud�d� Zvd�d� Zwd�d� Zxd�d� Zyd�d� Zzd�d� Z{d�d� Z|d�d�� Z}d�d�� Z~d�d�� Zd�d�� Z�d�d�� Z�d��d � Z��d�d� Z��d�d� Z��d�d� Z��d�d� Z��d �d � Z��d �d � Z��d �d� Z��d�d� Z��d�d� Z��d�d� Z��d�d� Z��d�d� Z��d�d� Z��d�d � Z��d �d � Z��d �d � Z��d!�d"� Z��d#�d$� Z��d%�d&� Z��d'�d(� Z��d)�d*� Z��d+�d,� Z��d-�d.� Z��d/�d0� Z��d1�d2� Z��d3�d4� Z��d5�d6� Z��d7�d8� Z��d9�d:� Z��d;S (< �TestDefaultControllerPluginc C s ddl m} |S )Nr )�DefaultControllerPlugin)r r� )r r� r r r r � s z+TestDefaultControllerPlugin._getTargetClassc O s* | j � }t� }t|�}||f|�|�}|S )N)r r r )r rA rB r� r r rX r r r r � s z$TestDefaultControllerPlugin._makeOnec C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nr? r� r zError: too few arguments) r �do_tailr r r8 r9 �splitrE r rF )r rX r �linesr r r �test_tail_toofewargs� s z0TestDefaultControllerPlugin.test_tail_toofewargsc C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nzone two three fourr� r zError: too many arguments) r r� r r r8 r9 r� rE r rF )r rX r r� r r r �test_tail_toomanyargs� s z1TestDefaultControllerPlugin.test_tail_toomanyargsc C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nz-fr� r z!Error: tail requires process name) r r� r r r8 r9 r� rE r rF )r rX r r� r r r �test_tail_f_noprocname� s z2TestDefaultControllerPlugin.test_tail_f_noprocnamec C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nz-z foor� r zError: bad argument -z) r r� r r r8 r9 r� rE r rF )r rX r r� r r r �test_tail_bad_modifier� s z2TestDefaultControllerPlugin.test_tail_bad_modifierc C sT | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� d S )Nr� r� � r z stdout line)r r� r r r8 r9 r� r� )r rX r r� r r r �test_tail_defaults s z.TestDefaultControllerPlugin.test_tail_defaultsc C sf | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� | j|jjt j � d S )N�NO_FILEr� ri r z NO_FILE: ERROR (no log file)) r r� r r r8 r9 r� r� rE r rF )r rX r r� r r r �test_tail_no_file s z-TestDefaultControllerPlugin.test_tail_no_filec C sf | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� | j|jjt j � d S )Nr@ r� ri r z)FAILED: ERROR (unknown error reading log)) r r� r r r8 r9 r� r� rE r rF )r rX r r� r r r �test_tail_failed s z,TestDefaultControllerPlugin.test_tail_failedc C sf | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� | j|jjt j � d S )N�BAD_NAMEr� ri r z&BAD_NAME: ERROR (no such process name)) r r� r r r8 r9 r� r� rE r rF )r rX r r� r r r �test_tail_bad_name! s z.TestDefaultControllerPlugin.test_tail_bad_namec C sT | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� d S )Nz-10 foor� rl r z dout line)r r� r r r8 r9 r� r� )r rX r r� r r r �test_tail_bytesmodifier* s z3TestDefaultControllerPlugin.test_tail_bytesmodifierc C sT | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� d S )Nz foo stdoutr� r� r z stdout line)r r� r r r8 r9 r� r� )r rX r r� r r r �,test_tail_explicit_channel_stdout_nomodifier2 s zHTestDefaultControllerPlugin.test_tail_explicit_channel_stdout_nomodifierc C sT | j � }|jd�}| j|d � |jjj� jd�}| jt|�d� | j|d d� d S )Nz foo stderrr� r� r z stderr line)r r� r r r8 r9 r� r� )r rX r r� r r r �,test_tail_explicit_channel_stderr_nomodifier: s zHTestDefaultControllerPlugin.test_tail_explicit_channel_stderr_nomodifierc C sP | j � }|jd�}| j|d � |jjj� j� }| j|d� | j|jjtj � d S )Nz foo fudgezError: bad channel 'fudge') r r� r r r8 r9 �striprE r rF )r rX r �valuer r r �'test_tail_explicit_channel_unrecognizedB s zCTestDefaultControllerPlugin.test_tail_explicit_channel_unrecognizedc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 L s zFTestDefaultControllerPlugin.test_tail_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)�append)rA rB )�calledr r rC N s z?TestDefaultControllerPlugin.test_tail_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 ZreadProcessStdoutLogr� r )r rX rC r )r� r �test_tail_upcheck_failedJ s z4TestDefaultControllerPlugin.test_tail_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz status <name>)r Z help_statusr r8 r9 r+ )r rX �outr r r �test_status_helpT s z,TestDefaultControllerPlugin.test_status_helpc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 \ s zHTestDefaultControllerPlugin.test_status_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC ^ s zATestDefaultControllerPlugin.test_status_upcheck_failed.<locals>.fr? ) r r r1 r r5 r6 rs � do_statusr )r rX rC r )r� r �test_status_upcheck_failedZ s z6TestDefaultControllerPlugin.test_status_upcheck_failedc C sJ | j � }|jd�}| j|d � |jjj� jd�}| j|d jd�d� d S )Nr? r� r �RUNNING�! )r r� r r r8 r9 r� �index)r rX r r� r r r �*test_status_table_process_column_min_widthd s zFTestDefaultControllerPlugin.test_status_table_process_column_min_widthc C sv | j � }|jj}dd� }||jj_| j|jd�d � |jjj � j d�}| j|d j d�d� | j|d j d�d� d S ) Nc _ sH ddl m} dd dd|jddddddd � d d d |jdddddd d � gS ) Nr )� ProcessStatesr� �2 � r� r? zfoo description) �name�group�pid�state� statenamerh �stop�spawnerr�now� description�barr� zbar description)�supervisor.statesr� r� �FATAL)rA rB r� r r r rC n s* zOTestDefaultControllerPlugin.test_status_table_process_column_expands.<locals>.fr? r� r r� � r] ) r r r r5 r6 rs r r� r8 r9 r� r� )r rX r rC r� r r r �(test_status_table_process_column_expandsk s zDTestDefaultControllerPlugin.test_status_table_process_column_expandsc C s� | j � }|jd�}| j|d � |jjj� jd�}| j|d jd d�dddg� | j|d jd d�d d d g� | j|d jd d�d d dg� | j|jjtj � d S )Nr? r� r ri r� r� zfoo descriptionr] r� r� zbar descriptionz baz:baz_01�STOPPEDzbaz description) r r� r r r8 r9 r� rE r rP )r rX r r� r r r � test_status_all_processes_no_arg� s z<TestDefaultControllerPlugin.test_status_all_processes_no_argc C sd | j � }|jd�}| j|d � | j|jjtj� |jjj� j d�}| j|d j d d�dddg� d S )Nr� r� r ri r� zfoo description) r r� r r rE r �SUCCESSr8 r9 r� )r rX r r� r r r �test_status_success� s z/TestDefaultControllerPlugin.test_status_successc C sL | j � }|jd�}| j|d � |jjj� }| jd|� | j|jjtj� d S )NZunknownprogramz(unknownprogram: ERROR (no such process) ) r r� r r r8 r9 rE r �UNKNOWN)r rX r r� r r r �test_status_unknown_process� s z7TestDefaultControllerPlugin.test_status_unknown_processc C s� | j � }|jd�}| j|d � |jjj� jd�}| j|d jd d�dddg� | j|d jd d�d d d g� | j|d jd d�d d dg� | j|jjtj � d S )N�allr� r ri r� r� zfoo descriptionr] r� r� zbar descriptionz baz:baz_01r� zbaz description) r r� r r r8 r9 r� rE r rP )r rX r r� r r r �!test_status_all_processes_all_arg� s z=TestDefaultControllerPlugin.test_status_all_processes_all_argc C s^ | j � }|jd�}| j|d � |jjj� j� }| j|jd d�dddg� | j|jjt j � d S )Nr� ri r� zfoo description) r r� r r r8 r9 r� r� rE r r� )r rX r r� r r r �test_status_process_name� s z4TestDefaultControllerPlugin.test_status_process_namec C sd | j � }|jd�}| j|d � |jjj� jd�}| j|d jd d�dddg� | j|jjtj � d S )Nzbaz:*r� r ri z baz:baz_01r� zbaz description) r r� r r r8 r9 r� rE r rP )r rX r r� r r r �test_status_group_name� s z2TestDefaultControllerPlugin.test_status_group_namec C s� | j � }|jd�}| j|d � |jjj� jd�}| j|d jd d�dddg� | j|d jd d�d d d g� | j|jjtj � d S ) Nz foo baz:*r� r ri r� r� zfoo descriptionr] z baz:baz_01r� zbaz description) r r� r r r8 r9 r� rE r rP )r rX r r� r r r �test_status_mixed_names� s z3TestDefaultControllerPlugin.test_status_mixed_namesc C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nz badgroup:*r� r z badgroup: ERROR (no such group)) r r� r r r8 r9 r� rE r r� )r rX r r� r r r �test_status_bad_group_name� s z6TestDefaultControllerPlugin.test_status_bad_group_namec C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )NZ badprocessr� r z#badprocess: ERROR (no such process)) r r� r r r8 r9 r� rE r r� )r rX r r� r r r � test_status_bad_process_name� s z8TestDefaultControllerPlugin.test_status_bad_process_namec C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nzbadgroup:badprocessr� r z,badgroup:badprocess: ERROR (no such process)) r r� r r r8 r9 r� rE r r� )r rX r r� r r r �'test_status_bad_process_name_with_group� s zCTestDefaultControllerPlugin.test_status_bad_process_name_with_groupc C s. | j � }|j� |jjj� }| jd|k� d S )Nz start <name>)r Z help_startr r8 r9 r+ )r rX r� r r r �test_start_help� s z+TestDefaultControllerPlugin.test_start_helpc C sV | j � }|jd�}| j|d � d}| j|jjj� jd�d |� | j|jjtj � d S )Nr? z$Error: start requires a process namer� r ) r �do_startr r r8 r9 r� rE r � INVALID_ARGS)r rX r r� r r r �test_start_fail� s z+TestDefaultControllerPlugin.test_start_failc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z"BAD_NAME: ERROR (no such process) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_start_badname� s z.TestDefaultControllerPlugin.test_start_badnamec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z NO_FILE: ERROR (no such file) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_start_no_file s z.TestDefaultControllerPlugin.test_start_no_filec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NZNOT_EXECUTABLEz/NOT_EXECUTABLE: ERROR (file is not executable) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_start_not_executable s z5TestDefaultControllerPlugin.test_start_not_executablec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NZALREADY_STARTEDz)ALREADY_STARTED: ERROR (already started) ) r r� r r r8 r9 rE r r� )r rX r r r r �test_start_alreadystarted s z5TestDefaultControllerPlugin.test_start_alreadystartedc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NZ SPAWN_ERRORz!SPAWN_ERROR: ERROR (spawn error) ) r r� r r r8 r9 rE r rP )r rX r r r r �test_start_spawnerror s z1TestDefaultControllerPlugin.test_start_spawnerrorc C sL | j � }|jd�}| j|d � d}| j|jjj� |� | j|jjtj� d S )NZABNORMAL_TERMINATIONz3ABNORMAL_TERMINATION: ERROR (abnormal termination) ) r r� r r r8 r9 rE r rP )r rX r r� r r r � test_start_abnormaltermination$ s z:TestDefaultControllerPlugin.test_start_abnormalterminationc C s6 | j � }|jd�}| j|d � | j|jjj� d� d S )Nr� z foo: started )r r� r r r8 r9 )r rX r r r r �test_start_one_success, s z2TestDefaultControllerPlugin.test_start_one_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo:fooz foo: started ) r r� r r r8 r9 rE r r� )r rX r r r r �&test_start_one_with_group_name_success3 s zBTestDefaultControllerPlugin.test_start_one_with_group_name_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo barzfoo: started bar: started ) r r� r r r8 r9 rE r r� )r rX r r r r �test_start_many; s z+TestDefaultControllerPlugin.test_start_manyc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo:z(foo:foo_00: started foo:foo_01: started ) r r� r r r8 r9 rE r r� )r rX r r r r �test_start_groupC s z,TestDefaultControllerPlugin.test_start_groupc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nz BAD_NAME:z BAD_NAME: ERROR (no such group) ) r r� r r r8 r9 rE r r� )r rX r r r r �test_start_group_bad_nameM s z5TestDefaultControllerPlugin.test_start_group_bad_namec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� zDfoo: started foo2: started failed_group:failed: ERROR (spawn error) ) r r� r r r8 r9 rE r rP )r rX r r r r �test_start_allU s z*TestDefaultControllerPlugin.test_start_allc sV | j � }dd� |j_g � � fdd�}|jjjj}||_||_|jd� | j � g � d S )Nc S s dS )NFr r r r r r4 b s zGTestDefaultControllerPlugin.test_start_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC d s z@TestDefaultControllerPlugin.test_start_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 ZstartAllProcessesZstartProcessGroupr� r )r rX rC r6 r )r� r �test_start_upcheck_failed` s z5TestDefaultControllerPlugin.test_start_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz stop <name>)r Z help_stopr r8 r9 r+ )r rX r� r r r �test_stop_helpl s z*TestDefaultControllerPlugin.test_stop_helpc C sR | j � }|jd�}| j|d � | j|jjj� jd�d d� | j|jjtj � d S )Nr? r� r z#Error: stop requires a process name) r �do_stopr r r8 r9 r� rE r rF )r rX r r r r �test_stop_failr s z*TestDefaultControllerPlugin.test_stop_failc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z"BAD_NAME: ERROR (no such process) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_stop_badnamez s z-TestDefaultControllerPlugin.test_stop_badnamec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NrP z!NOT_RUNNING: ERROR (not running) ) r r� r r r8 r9 rE r r� )r rX r r r r �test_stop_notrunning� s z0TestDefaultControllerPlugin.test_stop_notrunningc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr@ zFAILED ) r r� r r r8 r9 rE r rF )r rX r r r r �test_stop_failed� s z,TestDefaultControllerPlugin.test_stop_failedc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z foo: stopped ) r r� r r r8 r9 rE r r� )r rX r r r r �test_stop_one_success� s z1TestDefaultControllerPlugin.test_stop_one_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo:fooz foo: stopped ) r r� r r r8 r9 rE r r� )r rX r r r r �%test_stop_one_with_group_name_success� s zATestDefaultControllerPlugin.test_stop_one_with_group_name_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo barzfoo: stopped bar: stopped ) r r� r r r8 r9 rE r r� )r rX r r r r �test_stop_many� s z*TestDefaultControllerPlugin.test_stop_manyc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo:z(foo:foo_00: stopped foo:foo_01: stopped ) r r� r r r8 r9 rE r r� )r rX r r r r �test_stop_group� s z+TestDefaultControllerPlugin.test_stop_groupc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nz BAD_NAME:z BAD_NAME: ERROR (no such group) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_stop_group_bad_name� s z4TestDefaultControllerPlugin.test_stop_group_bad_namec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� zHfoo: stopped foo2: stopped failed_group:failed: ERROR (no such process) ) r r� r r r8 r9 rE r rF )r rX r r r r � test_stop_all� s z)TestDefaultControllerPlugin.test_stop_allc sV | j � }dd� |j_g � � fdd�}|jjjj}||_||_|jd� | j � g � d S )Nc S s dS )NFr r r r r r4 � s zFTestDefaultControllerPlugin.test_stop_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC � s z?TestDefaultControllerPlugin.test_stop_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 �stopAllProcesses�stopProcessGroupr� r )r rX rC r6 r )r� r �test_stop_upcheck_failed� s z4TestDefaultControllerPlugin.test_stop_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nzsignal <signal name> <name>)r Z help_signalr r8 r9 r+ )r rX r� r r r �test_signal_help� s z,TestDefaultControllerPlugin.test_signal_helpc C sV | j � }|jd�}| j|d � d}| j|jjj� jd�d |� | j|jjtj � d S )Nr? z7Error: signal requires a signal name and a process namer� r ) r � do_signalr r r8 r9 r� rE r rF )r rX r �msgr r r �test_signal_fail_no_arg� s z3TestDefaultControllerPlugin.test_signal_fail_no_argc C sV | j � }|jd�}| j|d � d}| j|jjj� jd�d |� | j|jjtj � d S )NZhupz7Error: signal requires a signal name and a process namer� r ) r r� r r r8 r9 r� rE r rF )r rX r r� r r r �test_signal_fail_one_arg� s z4TestDefaultControllerPlugin.test_signal_fail_one_argc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NzBAD_SIGNAL fooz foo: ERROR (bad signal name) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_signal_bad_signal� s z2TestDefaultControllerPlugin.test_signal_bad_signalc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nz HUP BAD_NAMEz"BAD_NAME: ERROR (no such process) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_signal_bad_name� s z0TestDefaultControllerPlugin.test_signal_bad_namec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nz HUP BAD_NAME:z BAD_NAME: ERROR (no such group) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_signal_bad_group� s z1TestDefaultControllerPlugin.test_signal_bad_groupc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NzHUP NOT_RUNNINGz!NOT_RUNNING: ERROR (not running) ) r r� r r r8 r9 rE r rP )r rX r r r r �test_signal_not_running� s z3TestDefaultControllerPlugin.test_signal_not_runningc C sF | j � }|jd�}| j|d � | j|jjj� d� | j|jjd� d S )Nz HUP FAILEDzFAILED r] )r r� r r r8 r9 rE )r rX r r r r �test_signal_failed s z.TestDefaultControllerPlugin.test_signal_failedc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NzHUP foozfoo: signalled ) r r� r r r8 r9 rE r r� )r rX r r r r �test_signal_one_success s z3TestDefaultControllerPlugin.test_signal_one_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nz HUP foo barz foo: signalled bar: signalled ) r r� r r r8 r9 rE r r� )r rX r r r r �test_signal_many s z,TestDefaultControllerPlugin.test_signal_manyc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NzHUP foo:z,foo:foo_00: signalled foo:foo_01: signalled ) r r� r r r8 r9 rE r r� )r rX r r r r �test_signal_group s z-TestDefaultControllerPlugin.test_signal_groupc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NzHUP allzLfoo: signalled foo2: signalled failed_group:failed: ERROR (no such process) ) r r� r r r8 r9 rE r rF )r rX r r r r �test_signal_all' s z+TestDefaultControllerPlugin.test_signal_allc sV | j � }dd� |j_g � � fdd�}|jjjj}||_||_|jd� | j � g � d S )Nc S s dS )NFr r r r r r4 3 s zHTestDefaultControllerPlugin.test_signal_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC 5 s zATestDefaultControllerPlugin.test_signal_upcheck_failed.<locals>.fzterm foo) r r r1 r r5 r6 ZsignalAllProcessesZsignalProcessGroupr� r )r rX rC r6 r )r� r �test_signal_upcheck_failed1 s z6TestDefaultControllerPlugin.test_signal_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nzrestart <name>)r Z help_restartr r8 r9 r+ )r rX r� r r r �test_restart_help= s z-TestDefaultControllerPlugin.test_restart_helpc C sR | j � }|jd�}| j|d � | j|jjj� jd�d d� | j|jjtj � d S )Nr? r� r z&Error: restart requires a process name) r � do_restartr r r8 r9 r� rE r rF )r rX r r r r �test_restart_failC s z-TestDefaultControllerPlugin.test_restart_failc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� zfoo: stopped foo: started ) r r r r r8 r9 rE r r� )r rX r r r r �test_restart_oneK s z,TestDefaultControllerPlugin.test_restart_onec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z�foo: stopped foo2: stopped failed_group:failed: ERROR (no such process) foo: started foo2: started failed_group:failed: ERROR (spawn error) ) r r r r r8 r9 rE r rP )r rX r r r r �test_restart_allS s z,TestDefaultControllerPlugin.test_restart_allc sV | j � }dd� |j_g � � fdd�}|jjjj}||_||_|jd� | j � g � d S )Nc S s dS )NFr r r r r r4 ` s zITestDefaultControllerPlugin.test_restart_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC b s zBTestDefaultControllerPlugin.test_restart_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 r� r� r r )r rX rC r6 r )r� r �test_restart_upcheck_failed^ s z7TestDefaultControllerPlugin.test_restart_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz clear <name>)r Z help_clearr r8 r9 r+ )r rX r� r r r �test_clear_helpj s z+TestDefaultControllerPlugin.test_clear_helpc C sR | j � }|jd�}| j|d � | j|jjj� jd�d d� | j|jjtj � d S )Nr? r� r z$Error: clear requires a process name) r �do_clearr r r8 r9 r� rE r rF )r rX r r r r �test_clear_failp s z+TestDefaultControllerPlugin.test_clear_failc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z"BAD_NAME: ERROR (no such process) ) r r r r r8 r9 rE r rF )r rX r r r r �test_clear_badnamex s z.TestDefaultControllerPlugin.test_clear_badnamec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z foo: cleared ) r r r r r8 r9 rE r r� )r rX r r r r �test_clear_one_success� s z2TestDefaultControllerPlugin.test_clear_one_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo:fooz foo: cleared ) r r r r r8 r9 rE r r� )r rX r r r r �!test_clear_one_with_group_success� s z=TestDefaultControllerPlugin.test_clear_one_with_group_successc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nzfoo barzfoo: cleared bar: cleared ) r r r r r8 r9 rE r r� )r rX r r r r �test_clear_many� s z+TestDefaultControllerPlugin.test_clear_manyc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z?foo: cleared foo2: cleared failed_group:failed: ERROR (failed) ) r r r r r8 r9 rE r rF )r rX r r r r �test_clear_all� s z*TestDefaultControllerPlugin.test_clear_allc sV | j � }dd� |j_g � � fdd�}|jjjj}||_||_|jd� | j � g � d S )Nc S s dS )NFr r r r r r4 � s zGTestDefaultControllerPlugin.test_clear_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC � s z@TestDefaultControllerPlugin.test_clear_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 ZclearAllProcessLogsZclearProcessLogsr r )r rX rC r6 r )r� r �test_clear_upcheck_failed� s z5TestDefaultControllerPlugin.test_clear_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz open <url>)r Z help_openr r8 r9 r+ )r rX r� r r r �test_open_help� s z*TestDefaultControllerPlugin.test_open_helpc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NZbadnamez&ERROR: url must be http:// or unix:// ) r �do_openr r r8 r9 rE r rF )r rX r r r r �test_open_fail� s z*TestDefaultControllerPlugin.test_open_failc C s� | j � }|jd�}| j|d � |jjj� jd�}| j|d jd d�dddg� | j|d jd d�d d d g� | j|d jd d�d d dg� | j|jjtj � d S )Nzhttp://localhost:9002r� r ri r� r� zfoo descriptionr] r� r� zbar descriptionz baz:baz_01r� zbaz description) r r r r r8 r9 r� rE r r� )r rX r r� r r r �test_open_succeed� s z-TestDefaultControllerPlugin.test_open_succeedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz*Show the version of the remote supervisord)r Z help_versionr r8 r9 r+ )r rX r� r r r �test_version_help� s z-TestDefaultControllerPlugin.test_version_helpc C s* | j � }|jd � | j|jjj� d� d S )Nz3000 )r � do_versionr r r8 r9 )r rX r r r � test_version� s z(TestDefaultControllerPlugin.test_versionc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nrd z#Error: version accepts no arguments) r r r r r8 r9 r+ � startswithrE r rF )r rX r �valr r r �test_version_arg� s z,TestDefaultControllerPlugin.test_version_argc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 � s zITestDefaultControllerPlugin.test_version_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC � s zBTestDefaultControllerPlugin.test_version_upcheck_failed.<locals>.fr? ) r r r1 r r5 r6 ZgetSupervisorVersionr r )r rX rC r )r� r �test_version_upcheck_failed� s z7TestDefaultControllerPlugin.test_version_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz Restart the remote supervisord)r Z help_reloadr r8 r9 r+ )r rX r� r r r �test_reload_help� s z,TestDefaultControllerPlugin.test_reload_helpc C sF | j � }|jj}d|jj_|jd�}| j|d � | j|jjjd� d S )NFr? ) r r r r5 r6 Z _restartable� do_reloadr � _restarted)r rX r r r r r �test_reload_fail� s z,TestDefaultControllerPlugin.test_reload_failc C s< | j � }|jj}|jd�}| j|d � | j|jjjd� d S )Nr? T)r r r r$ r r5 r6 r% )r rX r r r r r � test_reload� s z'TestDefaultControllerPlugin.test_reloadc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nrd z"Error: reload accepts no arguments) r r$ r r r8 r9 r+ r rE r rF )r rX r r r r r �test_reload_arg� s z+TestDefaultControllerPlugin.test_reload_argc C s. | j � }|j� |jjj� }| jd|k� d S )Nz Shut the remote supervisord down)r Z help_shutdownr r8 r9 r+ )r rX r� r r r �test_shutdown_help s z.TestDefaultControllerPlugin.test_shutdown_helpc C s< | j � }|jj}|jd�}| j|d � | j|jjjd� d S )Nr? T)r r r � do_shutdownr r5 r6 � _shutdown)r rX r r r r r � test_shutdown s z)TestDefaultControllerPlugin.test_shutdownc sn | j � }ddlm� � fdd�}||jjjj_|jd�}| j|d � | j|jj j � d� | j|jj t j � d S )Nr )r c s t j� jjd��d S )NZbye)r r< r; �SHUTDOWN_STATE)rA rB )r r r rL s zbTestDefaultControllerPlugin.test_shutdown_catches_xmlrpc_fault_shutdown_state.<locals>.raise_faultr? z ERROR: already shutting down )r r6 r r r r5 �shutdownr* r r8 r9 rE r r� )r rX rL r r )r r �1test_shutdown_catches_xmlrpc_fault_shutdown_state s zMTestDefaultControllerPlugin.test_shutdown_catches_xmlrpc_fault_shutdown_statec sV | j � }ddlm� � fdd�}||jjjj_| jtj |j d� | j |jj t j� d S )Nr )r c s t j� jjd��d S )NZouch)r r< r; � CANT_REREAD)rA rB )r r r rL # s z[TestDefaultControllerPlugin.test_shutdown_reraises_other_xmlrpc_faults.<locals>.raise_faultr? )r r6 r r r r5 r. rD r r< r* r rE r rF )r rX rL r )r r �*test_shutdown_reraises_other_xmlrpc_faults s zFTestDefaultControllerPlugin.test_shutdown_reraises_other_xmlrpc_faultsc sz | j � }dd l�dd l� � �fdd�}||jjjj_|jd�}| j |d � |jj j � }| j d|k� | j |jj tj� d S )Nr c s �j � jd��d S )Nz nobody home)rH rI )rA rB )rJ rK r r rL 0 s z`TestDefaultControllerPlugin.test_shutdown_catches_socket_error_ECONNREFUSED.<locals>.raise_faultr? z'refused connection (already shut down?))r rK rJ r r r5 r6 r. r* r r8 r9 r+ rE r rF )r rX rL r rM r )rJ rK r �/test_shutdown_catches_socket_error_ECONNREFUSED+ s zKTestDefaultControllerPlugin.test_shutdown_catches_socket_error_ECONNREFUSEDc sz | j � }dd l�dd l� � �fdd�}||jjjj_|jd�}| j |d � |jj j � }| j d|k� | j |jj tj� d S )Nr c s �j � jd��d S )Nzno file)rH rO )rA rB )rJ rK r r rL @ s zZTestDefaultControllerPlugin.test_shutdown_catches_socket_error_ENOENT.<locals>.raise_faultr? z!no such file (already shut down?))r rK rJ r r r5 r6 r. r* r r8 r9 r+ rE r rF )r rX rL r rM r )rJ rK r �)test_shutdown_catches_socket_error_ENOENT; s zETestDefaultControllerPlugin.test_shutdown_catches_socket_error_ENOENTc s\ | j � }dd l�dd l� � �fdd�}||jjjj_| j�j |j d� | j |jj t j� d S )Nr c s �j � jd��d S )NZdenied)rH ZEPERM)rA rB )rJ rK r r rL P s z[TestDefaultControllerPlugin.test_shutdown_reraises_other_socket_errors.<locals>.raise_faultr? )r rK rJ r r r5 r6 r. rD rH r* r rE r rF )r rX rL r )rJ rK r �*test_shutdown_reraises_other_socket_errorsK s zFTestDefaultControllerPlugin.test_shutdown_reraises_other_socket_errorsc C s2 | j � }|jdgdgdgg� |jg g g g� d S )N�added�changed�removed)r �_formatChanges)r rX r r r �test__formatChangesX s z/TestDefaultControllerPlugin.test__formatChangesc C s@ | j � }|j� |jjj� }| jd|k� | j|jjtj � d S )Nz'Reload the daemon's configuration files) r Z help_rereadr r8 r9 r+ r rE r r� )r rX r� r r r �test_reread_help^ s z,TestDefaultControllerPlugin.test_reread_helpc sb | j � }g � � fdd�|_|jd �}| j|d � | j� d dgdgdgg� | j|jjtj� d S )Nc s � j | �S )N)r� )r3 )�callsr r r4 h s z9TestDefaultControllerPlugin.test_reread.<locals>.<lambda>r r5 r6 r7 )r r8 � do_rereadr r rE r r� )r rX r r )r; r � test_rereade s z'TestDefaultControllerPlugin.test_rereadc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nrd z"Error: reread accepts no arguments) r r< r r r8 r9 r+ r rE r rF )r rX r r r r r �test_reread_argn s z+TestDefaultControllerPlugin.test_reread_argc sb | j � }ddlm� � fdd�}||jjjj_|jd � | j|jj j � d� | j|jj t j � d S )Nr )r c s t j� jjd��d S )NZcant)r r< r; r0 )rA rB )r r r � reloadConfigy s zITestDefaultControllerPlugin.test_reread_cant_reread.<locals>.reloadConfigz ERROR: cant )r r6 r r r r5 r? r< r r8 r9 rE r rF )r rX r? r )r r �test_reread_cant_rereadv s z3TestDefaultControllerPlugin.test_reread_cant_rereadc sb | j � }ddlm� � fdd�}||jjjj_|jd � | j|jj j � d� | j|jj t j � d S )Nr )r c s t j� jjd��d S )Nr? )r r< r; r- )rA rB )r r r r? � s zLTestDefaultControllerPlugin.test_reread_shutdown_state.<locals>.reloadConfigz ERROR: supervisor shutting down )r r6 r r r r5 r? r< r r8 r9 rE r rF )r rX r? r )r r �test_reread_shutdown_state� s z6TestDefaultControllerPlugin.test_reread_shutdown_statec sV | j � }ddlm� � fdd�}||jjjj_| jtj |j d� | j |jj t j� d S )Nr )r c s t j� jjd��d S )Nr? )r r< r; r@ )rA rB )r r r r? � s zSTestDefaultControllerPlugin.test_reread_reraises_other_faults.<locals>.reloadConfigr? )r r6 r r r r5 r? rD r r< r< r rE r rF )r rX r? r )r r �!test_reread_reraises_other_faults� s z=TestDefaultControllerPlugin.test_reread_reraises_other_faultsc C s` ddddddd�}| j � }|j|�}| jd|k� ddddddd�}|j|�}| jd|k� d S ) N�group1�process1Ti� )r� r� �inuse� autostart� process_prio� group_priozin useFZavail)r Z_formatConfigInfor+ )r �inforX r r r r �test__formatConfigInfo� s" z2TestDefaultControllerPlugin.test__formatConfigInfoc C s. | j � }|j� |jjj� }| jd|k� d S )NzDisplay all configured)r Z help_availr r8 r9 r+ )r rX r� r r r �test_avail_help� s z+TestDefaultControllerPlugin.test_avail_helpc sP g }| j � }G dd� dt�� � fdd�|j_|j|j_|jd�}| j|d � d S )Nc @ s e Zd Zdd� ZdS )z>TestDefaultControllerPlugin.test_avail.<locals>.FakeSupervisorc S s ddddddd�gS )NrC rD Fi� )r� r� rE rF rG rH r )r r r r �getAllConfigInfo� s zOTestDefaultControllerPlugin.test_avail.<locals>.FakeSupervisor.getAllConfigInfoN)r% r& r' rL r r r r �FakeSupervisor� s rM c s � � S )Nr r )rM r r r4 � s z8TestDefaultControllerPlugin.test_avail.<locals>.<lambda>r? )r r) r r� r� rM �do_availr )r r; rX r r )rM r � test_avail� s z&TestDefaultControllerPlugin.test_availc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nrd z!Error: avail accepts no arguments) r rN r r r8 r9 r+ r rE r rF )r rX r r r r r �test_avail_arg� s z*TestDefaultControllerPlugin.test_avail_argc C sb | j � }|jjjj}dd� }||_|jd�}| j|d � | j|jjj � d� | j|jj t j � d S )Nc S s ddl m} tj| jjd��d S )Nr )r r? )r6 r r r< r; r- )r r r r rL � s zOTestDefaultControllerPlugin.test_avail_shutdown_state.<locals>.getAllConfigInfor? z ERROR: supervisor shutting down ) r r r r5 r6 rL rN r r8 r9 rE r rF )r rX r6 rL r r r r �test_avail_shutdown_state� s z5TestDefaultControllerPlugin.test_avail_shutdown_statec C sJ | j � }|jjjj}dd� }||_| jtj|j d� | j |jj t j � d S )Nc S s ddl m} tj| jjd��d S )Nr )r r? )r6 r r r< r; r@ )r r r r rL � s zVTestDefaultControllerPlugin.test_avail_reraises_other_faults.<locals>.getAllConfigInfor? )r r r r5 r6 rL rD r r< rN r rE r rF )r rX r6 rL r r r � test_avail_reraises_other_faults� s z<TestDefaultControllerPlugin.test_avail_reraises_other_faultsc C s. | j � }|j� |jjj� }| jd|k� d S )Nz add <name>)r Zhelp_addr r8 r9 r+ )r rX r� r r r � test_add_help� s z)TestDefaultControllerPlugin.test_add_helpc C sP | j � }|jd�}| j|d � |jjjj}| j|jdg� | j|jjt j � d S )Nr� ) r �do_addr r r r5 r6 � processesrE r r� )r rX r r6 r r r �test_add� s z$TestDefaultControllerPlugin.test_addc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )NZ ALREADY_ADDEDz$ERROR: process group already active ) r rT r r r8 r9 rE r r� )r rX r r r r �test_add_already_added� s z2TestDefaultControllerPlugin.test_add_already_addedc C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr� z'ERROR: no such process/group: BAD_NAME ) r rT r r r8 r9 rE r rF )r rX r r r r �test_add_bad_name� s z-TestDefaultControllerPlugin.test_add_bad_namec C sH | j � }|jd�}| j|d � | j|jjj� d� | j|jjtj� d S )Nr- zERROR: shutting down ) r rT r r r8 r9 rE r rF )r rX r r r r �test_add_shutdown_state� s z3TestDefaultControllerPlugin.test_add_shutdown_statec C s0 | j � }| jtj|jd� | j|jjtj � d S )Nr@ ) r rD r r< rT r r rE r rF )r rX r r r � test_add_reraises_other_faults s z:TestDefaultControllerPlugin.test_add_reraises_other_faultsc C s@ | j � }|j� |jjj� }| jd|k� | j|jjtj � d S )Nz remove <name>) r Z help_remover r8 r9 r+ r rE r r� )r rX r� r r r �test_remove_help s z,TestDefaultControllerPlugin.test_remove_helpc C sD | j � }|jjjj}dg|_|jd�}| j|d � | j|jg � d S )Nr� )r r r r5 r6 rU � do_remover )r rX r6 r r r r � test_remove s z'TestDefaultControllerPlugin.test_removec C s\ | j � }|jjjj}dg|_|jd�}| j|d � | j|jjj � d� | j|jj t j � d S )Nr� r� z'ERROR: no such process/group: BAD_NAME ) r r r r5 r6 rU r\ r r8 r9 rE r rF )r rX r6 r r r r �test_remove_bad_name s z0TestDefaultControllerPlugin.test_remove_bad_namec C s\ | j � }|jjjj}dg|_|jd�}| j|d � | j|jjj � d� | j|jj t j � d S )Nr� Z STILL_RUNNINGz2ERROR: process/group still running: STILL_RUNNING ) r r r r5 r6 rU r\ r r8 r9 rE r rF )r rX r6 r r r r �test_remove_still_running$ s z5TestDefaultControllerPlugin.test_remove_still_runningc C s0 | j � }| jtj|jd� | j|jjtj � d S )Nr@ ) r rD r r< r\ r r rE r rF )r rX r r r �!test_remove_reraises_other_faults. s z=TestDefaultControllerPlugin.test_remove_reraises_other_faultsc C s. | j � }|j� |jjj� }| jd|k� d S )Nz Reload config and add/remove)r Z help_updater r8 r9 r+ )r rX r� r r r �test_update_help3 s z,TestDefaultControllerPlugin.test_update_helpc C sH | j � }|jjjj}dd� }||_dg|_|jd� | j|jdg� d S )Nc S s ddl m} tj| jjd��d S )Nr )r �blah)r6 r r r< r; r- )r r r r r? < s zMTestDefaultControllerPlugin.test_update_not_on_shutdown.<locals>.reloadConfigr7 r? ) r r r r5 r6 r? rU � do_updater )r rX r6 r? r r r �test_update_not_on_shutdown9 s z7TestDefaultControllerPlugin.test_update_not_on_shutdownc C sL | j � }|jjjj}dd� }||_|jd�}| j|d � | j|jdg� d S )Nc S s dgg g ggS )N�new_procr r r r r r? H s zITestDefaultControllerPlugin.test_update_added_procs.<locals>.reloadConfigr? re ) r r r r5 r6 r? rc r rU )r rX r6 r? r r r r �test_update_added_procsD s z3TestDefaultControllerPlugin.test_update_added_procsc C s | j � }|jjjj}dd� }||_ddg|_|jd� | jt |j�t ddg�� |jd� | jt |j�t ddddg�� |jd� | jt |j�t dddg�� ddg|_|jd� | jt |j�t ddg�� ddg|_|jd � | jt |j�t dddg�� d S ) Nc S s ddgdgdgggS )N�added1�added2r6 r7 r r r r r r? T s zHTestDefaultControllerPlugin.test_update_with_gname.<locals>.reloadConfigr6 r7 z added1 added2rg rh zremoved added1r� ) r r r r5 r6 r? rU rc r �sorted)r rX r6 r? r r r �test_update_with_gnameP s, z2TestDefaultControllerPlugin.test_update_with_gnamec sB ddl m} | j� }|jjjj }g � dd� }||_� fdd�|_|jd� dd|j j d d �g�� �fd d �}||_ |j d � | j � dg� |jd� g � d d �< dd|j jd d �dd|j jd d �g�d d �< |j d � | j � dg� |jd� g � d d �< dd|j jd d �dd|j j d d �g�d d �< |j d � | j � dg� d S )Nr )r c S s g dgg ggS )N� changed_groupr r r r r r? w s zKTestDefaultControllerPlugin.test_update_changed_procs.<locals>.reloadConfigc s � j d| f�S )Nrh )r� )r3 )r; r r r4 z s zGTestDefaultControllerPlugin.test_update_changed_procs.<locals>.<lambda>rk Zchanged_processrb )r� r� �statusr� c s � j d| f� �S )Nr� )r� )r� )r; r} r r r� � s zOTestDefaultControllerPlugin.test_update_changed_procs.<locals>.stopProcessGroupr? r� Zchanged_process1Zchanged_process2)r� rk )r� rk )r� rk )r6 r r r r r5 r? Z startProcessZaddProcessGroupr; r� r� rc r rP r@ )r r rX r6 r? r� r )r; r} r �test_update_changed_procsp sP z5TestDefaultControllerPlugin.test_update_changed_procsc s� ddl m} | j� }|jjjj }dd� }||_dd|jjdd�g� dg|_ � fd d �}||_ |j d � | j |j g � dd|jj dd�g� d d �< dg|_ |j d � | j |j g � dd|jjdd�g� d d �< dg|_ |j d � | j |j dg� d S ) Nr )r c S s g g dgggS )N� removed_groupr r r r r r? � s zKTestDefaultControllerPlugin.test_update_removed_procs.<locals>.reloadConfigZremoved_processrn rb )r� r� rl r� c s � S )Nr )r� )r} r r r� � s zOTestDefaultControllerPlugin.test_update_removed_procs.<locals>.stopProcessGroupr? )r6 r r r r r5 r? r; r� rU r� rc r rP r@ )r r rX r6 r? r� r )r} r �test_update_removed_procs� s8 z5TestDefaultControllerPlugin.test_update_removed_procsc C sH | j � }|jjjj}dd� }||_| jtj|j d� | j |jj d� d S )Nc S s ddl m} tj| jjd��d S )Nr )r r@ )r6 r r r< r; r@ )r r r r r? � s zSTestDefaultControllerPlugin.test_update_reraises_other_faults.<locals>.reloadConfigr? r] ) r r r r5 r6 r? rD r r< rc r rE )r rX r6 r? r r r �!test_update_reraises_other_faults� s z=TestDefaultControllerPlugin.test_update_reraises_other_faultsc C s. | j � }|j� |jjj� }| jd|k� d S )Nz pid <name>)r Zhelp_pidr r8 r9 r+ )r rX r� r r r � test_pid_help� s z)TestDefaultControllerPlugin.test_pid_helpc C sh | j � }|jd�}| j|d � |jj}|jjj� jd�}| jt|�d� | j|d t |j j j � �� d S )Nr? r� ri r ) r �do_pidr r r r8 r9 r� r� �strr5 r6 �getPID)r rX r r r� r r r �test_pid_supervisord� s z0TestDefaultControllerPlugin.test_pid_supervisordc C sZ | j � }|jd�}| j|d � |jjj� j� }| j|j� dddg� | j|jjt j � d S )Nr� �11Z12Z13) r rr r r r8 r9 r� r� rE r r� )r rX r r� r r r �test_pid_allprocesses� s z1TestDefaultControllerPlugin.test_pid_allprocessesc C sP | j � }|jd�}| j|d � |jjj� j� }| j|d� | j|jjtj � d S )Nr� zNo such process BAD_NAME) r rr r r r8 r9 r� rE r rF )r rX r r� r r r �test_pid_badname� s z,TestDefaultControllerPlugin.test_pid_badnamec C sL | j � }|jd�}| j|d � | j|jjj� j� d� | j|jjtj � d S )Nr� rv ) r rr r r r8 r9 r� rE r r� )r rX r r r r �test_pid_oneprocess� s z/TestDefaultControllerPlugin.test_pid_oneprocessc C sf | j � }|jj}dd� }||jj_|jd�}| j|d � | j|jjj � j � d� | j|jj t j � d S )Nc _ s( ddl m} ddd|jddddddd� S )Nr )r� r� r� r? zfoo description) r� r� r� r� r� rh r� r� r� r� )r� r� r� )rA rB r� r r r rC s zFTestDefaultControllerPlugin.test_pid_oneprocess_not_running.<locals>.fr� �0)r r r r5 r6 �getProcessInforr r r8 r9 r� rE r rP )r rX r rC r r r r � test_pid_oneprocess_not_running s z;TestDefaultControllerPlugin.test_pid_oneprocess_not_runningc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 s zETestDefaultControllerPlugin.test_pid_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC s z>TestDefaultControllerPlugin.test_pid_upcheck_failed.<locals>.fr? ) r r r1 r r5 r6 rt rr r )r rX rC r )r� r �test_pid_upcheck_failed s z3TestDefaultControllerPlugin.test_pid_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz tail of supervisor main log file)r Z help_maintailr r8 r9 r+ )r rX r� r r r �test_maintail_help! s z.TestDefaultControllerPlugin.test_maintail_helpc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nzfoo barzError: too many) r � do_maintailr r r8 r9 r+ r rE r rF )r rX r r r r r �test_maintail_toomanyargs' s z5TestDefaultControllerPlugin.test_maintail_toomanyargsc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )Nz-wrongzError: bad argument -wrong) r r r r r8 r9 r+ r rE r rF )r rX r r r r r � test_maintail_minus_string_fails/ s z<TestDefaultControllerPlugin.test_maintail_minus_string_failsc C sR | j � }|jd�}| j|d � |jjj� }| j|jd�|� | j|jjt j � d S )NZwrongzError: bad argument wrong) r r r r r8 r9 r+ r rE r rF )r rX r r r r r �test_maintail_wrong7 s z/TestDefaultControllerPlugin.test_maintail_wrongc C s| | j � }t� |_|jd�}| j|d � |jj}| jt|�d� |d }| j|jjd� | j|d d� | jd|d k� d S )Nz-fr] r z"http://localhost:65532/mainlogtailzCannot connect) r � DummyListenerZlistenerr r �errorsr� r# r+ )r rX r r� rH r r r �_dont_test_maintail_dashf? s z5TestDefaultControllerPlugin._dont_test_maintail_dashfc C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nz-zr� r zError: bad argument -z) r r r r r8 r9 r� rE r rF )r rX r r� r r r �test_maintail_bad_modifierP s z6TestDefaultControllerPlugin.test_maintail_bad_modifierc C s6 | j � }|jd�}| j|d � | j|jjj� d� d S )Nr? z mainlogdata )r r r r r8 r9 )r rX r r r r �test_maintail_nobytesX s z1TestDefaultControllerPlugin.test_maintail_nobytesc C s6 | j � }|jd�}| j|d � | j|jjj� d� d S )Nz-100z mainlogdata )r r r r r8 r9 )r rX r r r r �test_maintail_dashbytes^ s z3TestDefaultControllerPlugin.test_maintail_dashbytesc C sh | j � }|jj� }ddlm} |jj|_|jd�}| j |d � | j |jj j � d� | j |jj t j� d S )Nr )r z-100z!supervisord: ERROR (no log file) )r r r� r6 r r; r� �_readlog_errorr r r8 r9 rE r rF )r rX �supervisor_rpcr r r r r �"test_maintail_readlog_error_nofiled s z>TestDefaultControllerPlugin.test_maintail_readlog_error_nofilec C sh | j � }|jj� }ddlm} |jj|_|jd�}| j |d � | j |jj j � d� | j |jj t j� d S )Nr )r z-100z/supervisord: ERROR (unknown error reading log) )r r r� r6 r r; r@ r� r r r8 r9 rE r rF )r rX r� r r r r r �"test_maintail_readlog_error_failedo s z>TestDefaultControllerPlugin.test_maintail_readlog_error_failedc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 | s zJTestDefaultControllerPlugin.test_maintail_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC ~ s zCTestDefaultControllerPlugin.test_maintail_upcheck_failed.<locals>.fr? ) r r r1 r r5 r6 ZreadLogr r )r rX rC r )r� r � test_maintail_upcheck_failedz s z8TestDefaultControllerPlugin.test_maintail_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )Nz fg <process>)r Zhelp_fgr r8 r9 r+ )r rX r� r r r � test_fg_help� s z(TestDefaultControllerPlugin.test_fg_helpc C sV | j � }|jd�}| j|d � |jjj� jd�}| j|d d� | j|jjtj � d S )Nr? r� r z ERROR: no process name supplied) r �do_fgr r r8 r9 r� rE r rF )r rX r r� r r r �test_fg_too_few_args� s z0TestDefaultControllerPlugin.test_fg_too_few_argsc C sL | j � }|jd�}| j|d � |jjj� }| j|d� | j|jjtj� d S )Nzfoo barz'ERROR: too many process names supplied ) r r� r r r8 r9 rE r rF )r rX r r r r r �test_fg_too_many_args� s z1TestDefaultControllerPlugin.test_fg_too_many_argsc C sL | j � }|jd�}| j|d � |jjj� }| j|d� | j|jjtj� d S )Nr� z!ERROR: bad process name supplied ) r r� r r r8 r9 rE r rF )r rX r r r r r �test_fg_badprocname� s z/TestDefaultControllerPlugin.test_fg_badprocnamec C s� | j � }|jd�}| j|d � |jjj� }| j|d� |jd�}|jjj� jd�}| j|d � | j|d d� | j|jjtj � d S )Nr� zERROR: process not running Zbaz_01r� ri zERROR: process not running���) r r� r r r8 r9 r� rE r rF )r rX r r r� r r r �test_fg_procnotrunning� s z2TestDefaultControllerPlugin.test_fg_procnotrunningc sL | j � }dd� |j_g � � fdd�}||jjjj_|jd� | j� g � d S )Nc S s dS )NFr r r r r r4 � s zDTestDefaultControllerPlugin.test_fg_upcheck_failed.<locals>.<lambda>c s � j d� d S )NT)r� )rA rB )r� r r rC � s z=TestDefaultControllerPlugin.test_fg_upcheck_failed.<locals>.fr� ) r r r1 r r5 r6 r{ r� r )r rX rC r )r� r �test_fg_upcheck_failed� s z2TestDefaultControllerPlugin.test_fg_upcheck_failedc C s. | j � }|j� |jjj� }| jd|k� d S )NzExit the supervisor shell)r Z help_exitr r8 r9 r+ )r rX r� r r r �test_exit_help� s z*TestDefaultControllerPlugin.test_exit_helpc C s. | j � }|j� |jjj� }| jd|k� d S )NzExit the supervisor shell)r Z help_quitr r8 r9 r+ )r rX r� r r r �test_quit_help� s z*TestDefaultControllerPlugin.test_quit_helpN)�r% r& r' r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r r r r r r r r r r r r r r r r r r r! r" r# r& r' r( r) r, r/ r1 r2 r3 r4 r9 r: r= r> r@ rA rB rJ rK rO rP rQ rR rS rV rW rX rY rZ r[ r] r^ r_ r` ra rd rf rj rm ro rp rq ru rw rx ry r| r} r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� � s: ! 5 ) r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r� c C s g | _ d S )N)r� )r r r r �__init__� s zDummyListener.__init__c C s | j j||f� d S )N)r� r� )r �urlr� r r r rH � s zDummyListener.errorc C s || _ d S )N)r# )r r� r r r r$ � s zDummyListener.closeN)r% r& r' r� rH r$ r r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�DummyPluginFactoryc K s || _ d S )N)r )r r rB r r r r� � s zDummyPluginFactory.__init__c C s | j jjd� d S )Nz foo helped)r r8 �write)r rA r r r r| � s zDummyPluginFactory.do_helpN)r% r& r' r� r| r r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )r c C sD d| _ d| _d| _d| _d | _f | _t� | _d| _dt i fg| _ d S )Nr6 zhttp://localhost:65532ZchrismZ123FZdummy) r/ Z serverurlZusernameZpasswordZ history_filerU r r5 � interactiver� Zplugin_factories)r r r r r� � s zDummyClientOptions.__init__c C s | j S )N)r5 )r r r r r� � s z!DummyClientOptions.getServerProxyN)r% r& r' r� r� r r r r r � s r c @ sL e Zd ZdZdd� Zdd� Zdd� Zdd d �Zd d � Zd d� Z ddd�Z dS )r z no help on %sc C s || _ g | _t� | _tj| _d S )N)r r� r r8 r r� rE )r r r r r r� � s zDummyController.__init__c C s dS )NTr )r r r r r1 � s zDummyController.upcheckc C s | j d�S )Nr6 )r� )r r r r r� � s z DummyController.get_supervisorNc C s$ | j j� }|d kr|S t||�S d S )N)r r� �getattr)r � namespacer� r r r r� � s z DummyController.get_server_proxyc C s | j j|d � d S )Nr� )r8 r� )r �datar r r rM � s zDummyController.outputc C s | j j||||f� d S )N)r� r� )r Z doc_headersZcmds_docZrowsZcolsr r r � print_topics� s z DummyController.print_topicsc C s< ddl m} ||tjjfkr n||kr0tj| _ntj| _d S )Nr )�DEAD_PROGRAM_FAULTS) r r� r r; r� r rP rE rF )r Z faultcodeZignored_faultcoder� r r r � set_exitstatus_from_xmlrpc_fault� s z0DummyController.set_exitstatus_from_xmlrpc_fault)N)N) r% r& r' rz r� r1 r� r� rM r� r� r r r r r � s r c @ s e Zd Zddd�Zdd� ZdS )rT Nc C s || _ d S )N)r )r r0 r r r r� s zDummyPlugin.__init__c C s d| _ d S )NT)rW )r rA r r r r| s zDummyPlugin.do_help)N)r% r& r' r� r| r r r r rT s rT c C s t jtjt �S )N)�unittestZ findTestCases�sys�modulesr% r r r r � test_suite s r� �__main__)Z defaultTest)r� r� r6 r Zsupervisor.compatr r r r r Zsupervisor.tests.baser ZTestCaser r- r� r� r� r� r r rT r� r% �mainr r r r �<module> s> ? u u$
Back to File Manager