Edit File: test_rpcinterfaces.cpython-36.pyc
3 �k�`m� � @ sN d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z d dlm Z d d lmZ d d lmZ d d lmZmZ d d lmZ G d d� de j�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de j�ZG dd� de j�ZG dd� d�Z dd � Z e d k�rJe j d d � dS ) � N)� DummyOptions)�DummySupervisor)� DummyProcess)� DummyPConfig)�DummyPGroupConfig)�DummyProcessGroup)�PopulatedDummySupervisor)�_NOW)� _TIMEFORMAT)� as_string�PY2)� Automaticc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�TestBasec C s d S )N� )�selfr r �(/usr/lib/python3.6/test_rpcinterfaces.py�setUp s zTestBase.setUpc C s d S )Nr )r r r r �tearDown s zTestBase.tearDownc O sZ ddl m} y|||� W n2 |jk rL } z| j|j|� W Y d d }~X n X td��d S )Nr )�xmlrpcz Didn't raise)� supervisorr �RPCError� assertEqual�code�AssertionError)r r �callable�args�kwr �instr r r �_assertRPCError s zTestBase._assertRPCErrorN)�__name__� __module__� __qualname__r r r r r r r r s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �MainXMLRPCInterfaceTestsc C s ddl m} |jS )Nr )r )r r ZRootRPCInterface)r r r r r �_getTargetClass( s z(MainXMLRPCInterfaceTests._getTargetClassc O s | j � ||�S )N)r# )r r r r r r �_makeOne, s z!MainXMLRPCInterfaceTests._makeOnec C s | j dg�}| j|jd � d S )Nr )r N)r$ r r )r � interfacer r r � test_ctor/ s z"MainXMLRPCInterfaceTests.test_ctorc C s� t � }| jd|fg�}ddlm} | j|jj|j|dg � | j|jj|j|dg � | j|jj|j|ddg� | j |j|dg �d� d S ) N�dummyr )r znotthere.hellozsupervisor._readFilez dummy.hello� zHello!) �DummyRPCInterfacer$ r r r �FaultsZUNKNOWN_METHODZtraverse�INCORRECT_PARAMETERSr )r r' r% r r r r � test_traverse3 s z&MainXMLRPCInterfaceTests.test_traverseN)r r r! r# r$ r& r, r r r r r" & s r" c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd 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�S )��'SupervisorNamespaceXMLRPCInterfaceTestsc C s ddl m} |jS )Nr )� rpcinterface)r r. � SupervisorNamespaceRPCInterface)r r. r r r r# C s z7SupervisorNamespaceXMLRPCInterfaceTests._getTargetClassc O s | j � ||�S )N)r# )r r r r r r r$ G s z0SupervisorNamespaceXMLRPCInterfaceTests._makeOnec C sb ddl m} ddlm} t� }| j|�}|jd� | j|jd� |j |j _ | j |j j|jd� d S )Nr )r )�SupervisorStates�foo)r r �supervisor.supervisordr0 r r$ Z_updater � update_textZSHUTDOWN�options�moodr r* ZSHUTDOWN_STATE)r r r0 � supervisordr% r r r � test_updateJ s z3SupervisorNamespaceXMLRPCInterfaceTests.test_updatec C sD ddl m} t� }| j|�}|j� }| j||j� | j|jd� d S )Nr )r. � getAPIVersion)r r. r r$ r8 r Z API_VERSIONr3 )r r. r6 r% �versionr r r �test_getAPIVersionU s z:SupervisorNamespaceXMLRPCInterfaceTests.test_getAPIVersionc C s$ t � }| j|�}| j|j|j� d S )N)r r$ r r8 Z getVersion)r r6 r% r r r �3test_getAPIVersion_aliased_to_deprecated_getVersion] s z[SupervisorNamespaceXMLRPCInterfaceTests.test_getAPIVersion_aliased_to_deprecated_getVersionc C sD t � }| j|�}|j� }ddlm} | j||j� | j|jd� d S )Nr )r4 �getSupervisorVersion)r r$ r< r r4 r �VERSIONr3 )r r6 r% r9 r4 r r r �test_getSupervisorVersionb s zASupervisorNamespaceXMLRPCInterfaceTests.test_getSupervisorVersionc C s: t � }| j|�}|j� }| j||jj� | j|jd� d S )N�getIdentification)r r$ r? r r4 � identifierr3 )r r6 r% r@ r r r �test_getIdentificationk s z>SupervisorNamespaceXMLRPCInterfaceTests.test_getIdentificationc C sf ddl m} t� }| j|�}|j� }|jj}||�}| j|d |� | j|d |� | j|jd� d S )Nr )� getSupervisorStateDescription� statecode� statename�getState) �supervisor.statesrB r r$ rE r4 r5 r r3 )r rB r6 r% Z stateinforC rD r r r � test_getStater s z5SupervisorNamespaceXMLRPCInterfaceTests.test_getStatec C s> t � }t|�}| j|�}| j|j� |j� � | j|jd� d S )N�getPID)r r r$ r rH Zget_pidr3 )r r4 r6 r% r r r � test_getPID} s z3SupervisorNamespaceXMLRPCInterfaceTests.test_getPIDc C s$ t � }| j|�}| j|j|j� d S )N)r r$ r Z readMainLog�readLog)r r6 r% r r r �.test_readLog_aliased_to_deprecated_readMainLog� s zVSupervisorNamespaceXMLRPCInterfaceTests.test_readLog_aliased_to_deprecated_readMainLogc C s8 ddl m} t� }| j|�}| j|jj|jddd� d S )Nr )r r( )�offset�length)r r r r$ r r* �NO_FILErJ )r r r6 r% r r r �test_readLog_unreadable� s z?SupervisorNamespaceXMLRPCInterfaceTests.test_readLog_unreadablec C s� ddl m} t� }| j|�}z`|jj}t|d��}|jdd � W d Q R X | j|j j |j ddd� | j|j j |j d d d� W d t j |� X d S ) Nr )r zw+�xi r( )rL rM ���rQ rQ )r r r r$ r4 �logfile�open�writer r* � BAD_ARGUMENTSrJ �os�remove)r r r6 r% rR �fr r r �test_readLog_badargs� s z<SupervisorNamespaceXMLRPCInterfaceTests.test_readLog_badargsc C s� t � }| j|�}|jj}z�t|d��"}|jdd � |jdd � W d Q R X |jddd�}| j|jd� | j|dd dd � |jddd�}| j|dd � |jddd�}| j|dd � |jd dd�}| j|d � W d t j |� X d S ) Nzw+rP i �yr )rL rM rJ � ����yyyy) r r$ r4 rR rS rT rJ r r3 rV rW )r r6 r% rR rX �datar r r � test_readLog� s" z4SupervisorNamespaceXMLRPCInterfaceTests.test_readLogc C s2 ddl m} t� }| j|�}| j|jj|j� d S )Nr )r )r r r r$ r r* rN �clearLog)r r r6 r% r r r �test_clearLog_unreadable� s z@SupervisorNamespaceXMLRPCInterfaceTests.test_clearLog_unreadablec C sf ddl m} t� }|jg|_ttjtj tj��|_ t |�}| j |�}| j |j|j� | j|jd� d S )Nr )r r` )r r r rR �existing�OSError�errnoZEPERMrV �strerrorZremove_exceptionr r$ � assertRaisesr r` r r3 )r r r4 r6 r% r r r �test_clearLog_unremoveable� s zBSupervisorNamespaceXMLRPCInterfaceTests.test_clearLog_unremoveablec C s~ t � }|jg|_t|�}| j|�}|j� }| j|jd� | j|d� | j|jd |j� x |j j j D ]}| j|j d� qdW d S )Nr` Tr ) r rR rb r r$ r` r r3 Zremovedr4 ZloggerZhandlersZreopened)r r4 r6 r% �resultZhandlerr r r � test_clearLog� s z5SupervisorNamespaceXMLRPCInterfaceTests.test_clearLogc C s8 t � }| j|�}|j� }| j|d� | j|jjd� d S )NTr( rQ )r r$ Zshutdownr r4 r5 )r r6 r% �valuer r r � test_shutdown� s z5SupervisorNamespaceXMLRPCInterfaceTests.test_shutdownc C s8 t � }| j|�}|j� }| j|d� | j|jjd� d S )NTr )r r$ Zrestartr r4 r5 )r r6 r% rj r r r � test_restart� s z4SupervisorNamespaceXMLRPCInterfaceTests.test_restartc sn t � }t|�}| j|�}t|d�gt|d�gt|d�gg� � fdd�|_|j� }| j|dgdgdggg� d S )NZaddedZchangedZdroppedc s � S )Nr r )�changesr r �<lambda>� s zKSupervisorNamespaceXMLRPCInterfaceTests.test_reloadConfig.<locals>.<lambda>)r r r$ r Zdiff_to_active� reloadConfigr )r r4 r6 r% rj r )rm r �test_reloadConfig� s z9SupervisorNamespaceXMLRPCInterfaceTests.test_reloadConfigc C sH ddl m} t� }dd� }||_t|�}| j|�}| j|jj|j � d S )Nr )r c _ s t d��d S )Nr1 )� ValueError)�argr r r r � raise_exc� s zmSupervisorNamespaceXMLRPCInterfaceTests.test_reloadConfig_process_config_raises_ValueError.<locals>.raise_exc) r r r Zprocess_configr r$ r r* Z CANT_REREADro )r r r4 rs r6 r% r r r �2test_reloadConfig_process_config_raises_ValueError� s zZSupervisorNamespaceXMLRPCInterfaceTests.test_reloadConfig_process_config_raises_ValueErrorc C s� ddl m} ddlm} t� }||�}t|dtdd�}t|d|gd�}|g|j_ | j |�}|j d�}| j |� | j t|jj� �dg� | j|jj|j d� | j t|jj� �dg� | j|jj|j d � | j t|jj� �dg� d S ) Nr )� Supervisor)r r1 F)� autostart�group1)�pconfigs�asdf)r2 ru r r r r �__file__r r4 �process_group_configsr$ �addProcessGroup� assertTruer �list�process_groups�keysr r* Z ALREADY_ADDED�BAD_NAME) r ru r r4 r6 �pconfig�gconfigr% rh r r r �test_addProcessGroup� s" z<SupervisorNamespaceXMLRPCInterfaceTests.test_addProcessGroupc C s� ddl m} t� }||�}t|dtdd�}t|d|gd�}|g|j_| j|�}|j d� |j d�}| j |� | j t |jj� �g � d S )Nr )ru r1 F)rv rw )rx )r2 ru r r rz r r4 r{ r$ r| �removeProcessGroupr} r r~ r r� )r ru r4 r6 r� r� r% rh r r r �test_removeProcessGroup s z?SupervisorNamespaceXMLRPCInterfaceTests.test_removeProcessGroupc C sr ddl m} ddlm} t� }||�}t|dtdd�}t|d|gd�}|g|j_ | j |�}| j |j j |jd � d S ) Nr )ru )r r1 F)rv rw )rx ry )r2 ru r r r r rz r r4 r{ r$ r r* r� r� )r ru r r4 r6 r� r� r% r r r � test_removeProcessGroup_bad_name s zHSupervisorNamespaceXMLRPCInterfaceTests.test_removeProcessGroup_bad_namec C s� ddl m} ddlm} t� }||�}t|dtdd�}t|d|gd�}|g|j_ t |�}d g|_ d|i|_ | j |�}| j|jj|jd� d S ) Nr )ru )r r1 F)rv rw )rx �{ )r2 ru r r r r rz r r4 r{ r Zunstopped_processesr r$ r r* Z STILL_RUNNINGr� ) r ru r r4 r6 r� r� �processr% r r r �%test_removeProcessGroup_still_running+ s zMSupervisorNamespaceXMLRPCInterfaceTests.test_removeProcessGroup_still_runningc C s^ ddl m} t� }t|dtdd�}t|d|�}|jddd� | j|�}| j|j j |j d� d S )Nr )r r1 F)rv �pid� ) r r r r rz r � set_procattrr$ r r* ZALREADY_STARTED� startProcess)r r r4 r� r6 r% r r r �!test_startProcess_already_started: s zISupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_already_startedc C s� ddl m} ddlm} t� }t|dtdd�}t|d|�}|jddd� |jdd |j � | j |�}| j |j j |jd� |jd jd }| j|jd� d S ) Nr )r )� ProcessStatesr1 F)rv r� r� �state)r r rF r� r r rz r r� �UNKNOWNr$ r r* �FAILEDr� r � processesr �spawned)r r r� r4 r� r6 r% r� r r r � test_startProcess_unknown_stateF s zGSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_unknown_statec C sP t � }t|dtdd�}t|d|�}| j|�}ddlm} | j|jj |j d� d S )Nr1 F)rv rw r )r z group2:foo) r r rz r r$ r r r r* r� r� )r r4 r� r6 r% r r r r � test_startProcess_bad_group_nameV s zHSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_bad_group_namec C sP t � }t|dtdd�}t|d|�}| j|�}ddlm} | j|jj |j d� d S )Nr1 F)rv rw r )r z group1:bar) r r rz r r$ r r r r* r� r� )r r4 r� r6 r% r r r r �"test_startProcess_bad_process_name_ s zJSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_bad_process_namec C sr t � }t|dddd�}ddlm} t|d|�}|jd jd }||_| j|�}ddl m } | j |j j |jd� d S )Nr1 z/foo/barF)rv r )�NotFound)r )r r �supervisor.optionsr� r r r� �execv_arg_exceptionr$ r r r r* rN r� )r r4 r� r� r6 r� r% r r r r � test_startProcess_file_not_foundh s zHSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_file_not_foundc C sr t � }t|dddd�}ddlm} t|d|�}|jd jd }||_| j|�}ddl m } | j |j j |jd� d S )Nr1 z/foo/barF)rv r )� NotExecutable)r )r r r� r� r r r� r� r$ r r r r* ZNOT_EXECUTABLEr� )r r4 r� r� r6 r� r% r r r r �%test_startProcess_file_not_executablet s zMSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_file_not_executablec C s� ddl m} t� }t|dtdd�}ddlm} t|d|�}|jdd|j � |j d j d }d|_ | j |�}| j|jj|jd� d S ) Nr )r r1 F)rv )r� r� �abc)r r r r rz �supervisor.processr� r r� �STOPPEDr r� �spawnerrr$ r r* � SPAWN_ERRORr� )r r r4 r� r� r6 r� r% r r r �test_startProcess_spawnerr� s zBSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_spawnerrc C s� t � }t|dtddd�}ddlm} t|d|�}|jdd|j� | j|�}|j d�}|j d j d }| j |j d� | j |jd � |j|_| j |d� d S ) Nr1 Fg{�G�z�?)rv � startsecsr )r� r� Tr� )r r rz r� r� r r� r� r$ r� r r� r r� r3 �RUNNINGr� )r r4 r� r� r6 r% rh r� r r r �test_startProcess� s z9SupervisorNamespaceXMLRPCInterfaceTests.test_startProcessc s� ddl m} t� }t|dtdd�}ddlm� t|d|�}|jdd� j � |j d j d �� �fdd �}�fd d �}|�_ |�_ | j|�}|jd�}| j|jj|� d S ) Nr )r r1 F)rv )r� r� c s d�_ � j�_d S )NT)r� �STARTINGr� r )r� r� r r �spawn� s z[SupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_spawnerr_in_onwait.<locals>.spawnc s d� _ d S )Nr� )r� r )r� r r � transition� s z`SupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_spawnerr_in_onwait.<locals>.transition)r r r r rz r� r� r r� r� r r� r� r� r$ r� r r* r� ) r r r4 r� r6 r� r� r% �callbackr )r� r� r �$test_startProcess_spawnerr_in_onwait� s zLSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_spawnerr_in_onwaitc s� t � }t|dtdd�}ddlm� t|d|�}|jdd� j� |jd j d �� �fdd�}|�_ | j |�}|j d�}� j �_| j|� d � d S ) Nr1 F)rv r )r� r� c s d�_ � j�_d S )NT)r� r� r� r )r� r� r r r� � s zZSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_success_in_onwait.<locals>.spawnT)r r rz r� r� r r� r� r r� r� r$ r� r� r� r )r r4 r� r6 r� r% r� r )r� r� r �#test_startProcess_success_in_onwait� s zKSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_success_in_onwaitc C s� t � }t|dtdd�}ddlm} t|d|�}|jdd|j� | j|�}|j ddd�}| j |d� |j d j d }| j |j d� | j |jd � d S ) Nr1 F)rv r )r� r� )�waitTr� )r r rz r� r� r r� r� r$ r� r r r� r� r3 )r r4 r� r� r6 r% rh r� r r r �test_startProcess_nowait� s z@SupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_nowaitc s� t � }t|dtdd�}ddlm� ddlm} t|d|�}|jdd� j � | j |�}|j d j d �� �fdd �}|�_ |jdd �}|� }| j||j� | j�jd � | j|jd � � j�_dd lm} | j| jj|� d S )Nr1 F)rv r )r� )�httpr� c s d�_ � j�_d S )NT)r� r� r� r )r� r� r r r� � s zjSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_abnormal_term_process_not_running.<locals>.spawn�d Tr� )r )r r rz r� r� r r� r r� r� r$ r r� r� r� r � NOT_DONE_YETr� r3 ZBACKOFFr� r r r* ZABNORMAL_TERMINATION) r r4 r� r� r6 r% r� r� rh r r )r� r� r �3test_startProcess_abnormal_term_process_not_running� s$ z[SupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_abnormal_term_process_not_runningc C s� t � }t|dtddd�}t|dtddd�}t|d||�}d d lm} |jdd |j� |jdd |j� | j|�}|j d � | j |j d � d S )N�process1Fg{�G�z�?)rv r� �process2� )�priorityr� r1 r )r� r� zfoo:*�startProcessGroup) r r rz r r� r� r� r� r$ r� r r3 )r r4 �pconfig1�pconfig2r6 r� r% r r r �/test_startProcess_splat_calls_startProcessGroup� s zWSupervisorNamespaceXMLRPCInterfaceTests.test_startProcess_splat_calls_startProcessGroupc C s� t � }t|dtddd�}t|dtddd�}t|d||�}dd lm} dd lm} |jdd |j � |jdd |j � | j |�}|j d�}| j |� d|j d dd �d|j d dd �g� | j |jd� |jd jd } | j | jd� |jd jd } | j | jd� d S )Nr� r( g{�G�z�?)r� r� r� r� r1 r )r� )r* r� �OK)�group�status� description�namer� T)r r rz r r� r� �supervisor.xmlrpcr* r� r� r$ r� r �SUCCESSr3 r r� r� ) r r4 r� r� r6 r� r* r% r� r� r� r r r �test_startProcessGroup� s8 z>SupervisorNamespaceXMLRPCInterfaceTests.test_startProcessGroupc C s� t � }t|dtddd�}t|dtddd�}t|d||�}dd lm} |jdd |j� |jdd |j� | j|�}|j dd d �}dd l m } | j |� d|j ddd�d|j ddd�g� d S )Nr� r( g{�G�z�?)r� r� r� r� r1 r )r� r� F)r� )r* r� )r� r� r� r� )r r rz r r� r� r� r� r$ r� r� r* r r� ) r r4 r� r� r6 r� r% r� r* r r r � test_startProcessGroup_nowait s. zESupervisorNamespaceXMLRPCInterfaceTests.test_startProcessGroup_nowaitc C s4 ddl m} t� }| j|�}| j|jj|jd� d S )Nr )r r1 )r r r r$ r r* r� r� )r r r6 r% r r r � test_startProcessGroup_badname2 s zFSupervisorNamespaceXMLRPCInterfaceTests.test_startProcessGroup_badnamec C s� t � }t|dtddd�}t|dtddd�}t|d||�}dd lm} |jdd |j� |jdd |j� | j|�}|j � }dd l m } | j |� d|j d dd �d|j d dd �g� | j |jd� |jd jd } | j | jd� |jd jd } | j | jd� d S )Nr� r( g{�G�z�?)r� r� r� r� r1 r )r� r� )r* r� )r� r� r� r� r� T)r r rz r r� r� r� r� r$ �startAllProcessesr� r* r r� r3 r r� r� ) r r4 r� r� r6 r� r% r� r* r� r� r r r �test_startAllProcesses: s8 z>SupervisorNamespaceXMLRPCInterfaceTests.test_startAllProcessesc C s� t � }t|dtddd�}t|dtddd�}t|d||�}dd lm} |jdd |j� |jdd |j� | j|�}|j d d �}dd l m } | j |� d|j ddd�d|j ddd�g� d S )Nr� r( g{�G�z�?)r� r� r� r� r1 r )r� r� F)r� )r* r� )r� r� r� r� )r r rz r r� r� r� r� r$ r� r� r* r r� ) r r4 r� r� r6 r� r% r� r* r r r � test_startAllProcesses_nowait^ s. zESupervisorNamespaceXMLRPCInterfaceTests.test_startAllProcesses_nowaitc C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� | j|�}|jd�}| j |� | j |j d� |j d j d }| j |jd� | j |jd� | j|j� | j |j|j� | j |j� | j t|j d j �d� | j |j d� d S )Nr1 z/bin/foor )r� r� � stopProcessr( )r r r� r� r r� r� r$ r� r} r r3 r r� ZbackoffZdelay� assertFalse�killingr� r� �stop_report_called�len)r r4 r� r� r6 r% rh r� r r r �test_stopProcessz s" z8SupervisorNamespaceXMLRPCInterfaceTests.test_stopProcessc C s� t � }t|dt�}ddlm} t|d|�}|jdd|j� | j|�}|j ddd�}| j |d� |j d j d }| j |j d� | j|j� | j |jd� d S ) Nr1 r )r� r� F)r� Tr� )r r rz r� r� r r� r� r$ r� r r r� � stop_calledr} r� r3 )r r4 r� r� r6 r% rh r� r r r �test_stopProcess_nowait� s z?SupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_nowaitc s� t � }t|dd�}ddlm} t|d|�}|jd jd }|j|j|j g� � fdd�}||_ | j |�}|j d�}| j |jd� | j|� � d S )Nr1 z/bin/foor )r� c s � j d�S )Nr )�popr )�Lr r � get_state� s z]SupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_success_in_onwait.<locals>.get_stater� )r r r� r� r r r� r� �STOPPINGr� r� r$ r� r r3 r} ) r r4 r� r� r6 r� r� r% r� r )r� r �"test_stopProcess_success_in_onwait� s zJSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_success_in_onwaitc s� ddl m} t� }t|dd�}ddlm} t|d|�}|jd jd }|j |j |j g� � fdd�}||_ | j |�}|j d�} | j| � |� | j|jd� d S ) Nr )r� r1 z/bin/foo)r� c s � j d�S )Nr )r� r )r� r r r� � s zYSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_NDY_in_onwait.<locals>.get_stater� )�supervisor.httpr� r r r� r� r r r� r� r� r� r$ r� r r3 ) r r� r4 r� r� r6 r� r� r% r� r )r� r � test_stopProcess_NDY_in_onwait� s zFSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_NDY_in_onwaitc C s2 ddl m} t� }| j|�}| j|j|jd� d S )Nr )r* r1 )r� r* r r$ r r� r� )r r* r6 r% r r r �test_stopProcess_bad_name� s zASupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_bad_namec C sf ddl m} ddlm} t� }t|dd�}t|d|�}|jdd|j� | j |�}| j |j |j d� d S )Nr )r� )r* r1 z/bin/foor� ) rF r� r� r* r r r r� ZEXITEDr$ r � NOT_RUNNINGr� )r r� r* r4 r� r6 r% r r r � test_stopProcess_not_running� s zDSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_not_runningc C s\ ddl m} t� }t|dd�}t|d|�}|jdddd� � | j|�}| j|j|j d� d S )Nr )r* r1 z/bin/foo�stopc S s dS )NZ unstoppabler r r r r rn � s zQSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_failed.<locals>.<lambda>) r� r* r r r r� r$ r r� r� )r r* r4 r� r6 r% r r r �test_stopProcess_failed� s z?SupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_failedc C s t � }t|dddd�}t|dddd�}dd lm} t|d ||�}|jdd |j� |jdd |j� | j|�}|jd �}| j |j d � dd l m } |j } x|� } | |j k r�P q�W ddlm} | j | | jd ddd�| jd ddd�g� |jd jd } | j | jd� |jd jd } | j | jd� d S )Nr� z/bin/foor( )r� r� z /bin/foo2r� r )r� r1 r� �stopProcessGroup)r� )r* r� )r� r� r� r� T)r r r� r� r r� r� r$ r� r r3 r r� r� r� r* r� r r� r� ) r r4 r� r� r� r6 r% r� r� rj r* r� r� r r r �test_stopProcessGroup� s> z=SupervisorNamespaceXMLRPCInterfaceTests.test_stopProcessGroupc C s� t � }t|dtdd�}t|dtdd�}t|d||�}ddlm} |jdd |j� |jdd |j� | j|�}|j dd d �}dd l m } | j |� dd d|j d�dd d|j d�g� d S )Nr� r( )r� r� r� r1 r )r� r� F)r� )r* r� )r� r� r� r� )r r rz r r� r� r� r� r$ r� r� r* r r� ) r r4 r� r� r6 r� r% r� r* r r r � test_stopProcessGroup_nowait� s* zDSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcessGroup_nowaitc C s4 ddl m} t� }| j|�}| j|jj|jd� d S )Nr )r r1 )r r r r$ r r* r� r� )r r r6 r% r r r � test_stopProcessGroup_badname s zESupervisorNamespaceXMLRPCInterfaceTests.test_stopProcessGroup_badnamec C s� t � }t|dtddd�}t|dtddd�}t|d||�}d d lm} |jdd |j� |jdd |j� | j|�}|j d � | j |j d � d S )Nr� Fg{�G�z�?)rv r� r� r� )r� r� r1 r )r� r� zfoo:*r� ) r r rz r r� r� r� r� r$ r� r r3 )r r4 r� r� r6 r� r% r r r �-test_stopProcess_splat_calls_stopProcessGroup s zUSupervisorNamespaceXMLRPCInterfaceTests.test_stopProcess_splat_calls_stopProcessGroupc C s t � }t|dddd�}t|dddd�}dd lm} t|d ||�}|jdd |j� |jdd |j� | j|�}|j� }| j |j d � dd l m } |j } x|� } | |j k r�P q�W ddlm} | j | | jd ddd�| jd ddd�g� |jd jd } | j | jd� |jd jd } | j | jd� d S )Nr� z/bin/foor( )r� r� z /bin/foo2r� r )r� r1 r� �stopAllProcesses)r� )r* r� )r� r� r� r� T)r r r� r� r r� r� r$ r� r r3 r r� r� r� r* r� r r� r� ) r r4 r� r� r� r6 r% r� r� rj r* r� r� r r r �test_stopAllProcesses- s> z=SupervisorNamespaceXMLRPCInterfaceTests.test_stopAllProcessesc C s� t � }t|dtdd�}t|dtdd�}t|d||�}ddlm} |jdd |j� |jdd |j� | j|�}|j d d �}dd l m } | j |� d|j d dd�d|j d dd�g� d S )Nr� r( )r� r� r� r1 r )r� r� F)r� )r* r� )r� r� r� r� )r r rz r r� r� r� r� r$ r� r� r* r r� ) r r4 r� r� r6 r� r% r� r* r r r � test_stopAllProcesses_nowaitQ s* zDSupervisorNamespaceXMLRPCInterfaceTests.test_stopAllProcesses_nowaitc C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� | j|�}|jdd�}| j |j d� | j |d� |j |j j d }| j |jd� d S ) Nr1 z/bin/foor )r� r� r� � signalProcessT)r r r� r� r r� r� r$ r� r r3 r � group_namer� � sent_signal)r r4 r� r� r6 r% rh �pr r r �%test_signalProcess_with_signal_numberk s zMSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_with_signal_numberc C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� ddlm} d}||�}| j |�}|j d|�} | j |j d� | j | d � |j |j jd } | j | j|� d S ) Nr1 z/bin/foor )r� r� )� signal_number�quitr� T)r r r� r� r r� r� �supervisor.datatypesr� r$ r� r r3 r r� r� r� ) r r4 r� r� r6 r� �signame�signumr% rh r� r r r �#test_signalProcess_with_signal_namez s zKSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_with_signal_namec C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� | j|�}|jdd�}| j |j d� | j |d� |j |j j d }| j |jd� d S ) Nr1 z/bin/foor )r� r� r� r� T)r r r� r� r r� r� r$ r� r r3 r r� r� r� )r r4 r� r� r6 r% rh r� r r r �test_signalProcess_stopping� s zCSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_stoppingc C sj t � }t|dd�}ddlm} ddlm} t|d|�}|jdd|j� | j |�}| j |j j |j dd� d S )Nr1 z/bin/foor )r� )r r� � )r r r� r� r r r r� r� r$ r r* Z BAD_SIGNALr� )r r4 r� r� r r6 r% r r r � test_signalProcess_badsignal� s zDSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_badsignalc C sj t � }t|dd�}ddlm} ddlm} t|d|�}|jdd|j� | j |�}| j |j j |j dd� d S )Nr1 z/bin/foor )r� )r r� r� )r r r� r� r r r r� r� r$ r r* r� r� )r r4 r� r� r r6 r% r r r � test_signalProcess_notrunning� s zESupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_notrunningc C s� t � }t|dd�}ddlm} ddlm} t|d|�}|jdd|j� dd� }|j |j }|j d }||_ | j |�} | j|jj| jdd � d S ) Nr1 z/bin/foor )r� )r r� c S s dS )N�msgr )Zsigr r r � signalreturn� s zgSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_signal_returns_message.<locals>.signalreturnr� )r r r� r� r r r r� r� r r� r� �signalr$ r r* r� r� ) r r4 r� r� r r6 r� �pgroup�procr% r r r �)test_signalProcess_signal_returns_message� s zQSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_signal_returns_messagec C s t � }t|dd�}t|dd�}ddlm} t|d||�}|jdd|j� |jdd|j� | j|�}|j d d �}| j |j d � t |t jd �d �}ddlm} | j ||jdddd�|jdddd�g� |jd jd } | j | jd � |jd jd } | j | jd � dS )z Test that sending foo:* works r� z/bin/foor� z /bin/foo2r )r� r1 r� zfoo:*r� �signalProcessGroupr� )�key)r* r� )r� r� r� r� N)r r r� r� r r� r� r� r$ r� r r3 �sorted�operator� itemgetterr� r* r� r r� r� ) r r4 r� r� r� r6 r% rh r* r� r� r r r � test_signalProcess_withgroup� s4 zDSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcess_withgroupc C s t � }t|dd�}t|dd�}ddlm} t|d||�}|jdd|j� |jdd|j� | j|�}|jdd �}| j |j d � t |t j d �d �}dd lm} | j ||jdddd�|jdddd�g� |jd jd } | j | jd � |jd jd } | j | jd � d S )Nr� z/bin/foor� z /bin/foo2r )r� r1 r� r� r� r� )r� )r* r� )r� r� r� r� )r r r� r� r r� r� r$ r� r r3 r� r� r� r� r* r� r r� r� ) r r4 r� r� r� r6 r% rh r* r� r� r r r �*test_signalProcessGroup_with_signal_number� s4 zRSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcessGroup_with_signal_numberc C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� ddlm} d}||�}| j |�}|j d|�} | j |j d � dd l m} | j | | jddd d �g� |jd jd } | j | j|� d S ) Nr� z/bin/foor )r� r1 r� )r� Ztermr� )r* r� )r� r� r� r� )r r r� r� r r� r� r� r� r$ r� r r3 r� r* r� r r� r� ) r r4 r� r� r6 r� r� r� r% rh r* r� r r r �(test_signalProcessGroup_with_signal_name s& zPSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcessGroup_with_signal_namec C s� ddl m} t� }t|dd�}t|dd�}ddlm} t|d||�}|jdd |j� |jdd |j� | j |�}| j |j j |j d d � d S ) Nr )r r� z/bin/foor� z /bin/foo2)r� r1 r� �barr� )r r r r r� r� r r� r� r$ r r* r� r� )r r r4 r� r� r� r6 r% r r r �#test_signalProcessGroup_nosuchgroup$ s zKSupervisorNamespaceXMLRPCInterfaceTests.test_signalProcessGroup_nosuchgroupc C s t � }t|dd�}t|dd�}ddlm} t|d||�}|jdd|j� |jdd|j� | j|�}|jd �}| j |j d � t |t j d �d �}dd lm} | j ||jdddd�|jdddd�g� |jd jd } | j | jd � |jd jd } | j | jd � d S )Nr� z/bin/foor� z /bin/foo2r )r� r1 r� r� �signalAllProcessesr� )r� )r* r� )r� r� r� r� )r r r� r� r r� r� r$ r r r3 r� r� r� r� r* r� r r� r� ) r r4 r� r� r� r6 r% rh r* r� r� r r r �*test_signalAllProcesses_with_signal_number3 s4 zRSupervisorNamespaceXMLRPCInterfaceTests.test_signalAllProcesses_with_signal_numberc C s� t � }t|dd�}ddlm} t|d|�}|jdd|j� ddlm} d}||�}| j |�}|j |�} | j |j d � dd l m} | j | | jddd d �g� |jd jd } | j | j|� d S ) Nr� z/bin/foor )r� r1 r� )r� Zhupr )r* r� )r� r� r� r� )r r r� r� r r� r� r� r� r$ r r r3 r� r* r� r r� r� ) r r4 r� r� r6 r� r� r� r% rh r* r� r r r �(test_signalAllProcesses_with_signal_nameT s& zPSupervisorNamespaceXMLRPCInterfaceTests.test_signalAllProcesses_with_signal_namec C s� t � }t|d�}t|dtttd�}t|dtd d d�}t|d||gd�}dt|�i|_|g|j_ | j |�}|j � }| j |d d d � | j |d d d � | j |d d d � | j |d d d � | j |d d d� | j |d d d� | j |d d d� | j |d d d� | j |d d d � | j |d d d� | j |d d d� | j |d d d � | j |d d d� | j |d d d � | j |d d d� | j |d d d � | j |d d d � | j |d d d � | j |d d d*� | j |d d! d� | j |d d" d� | j |d d d� | j |d d# d � | j |d d$ d � | j |d d% d� d&|d d' k�szt �| j |d( d d � | j |d( d d � | j |d( d d � | j |d( d d � | j |d( d d� | j |d( d d� | j |d( d d� | j |d( d d� | j |d( d d � | j |d( d d� | j |d( d d� | j |d( d d � | j |d( d d� | j |d( d d � | j |d( d d� | j |d( d d � | j |d( d d � | j |d( d d)� | j |d( d d+� | j |d( d! d� | j |d( d" d� | j |d( d d� | j |d( d# d � | j |d( d$ d)� | j |d( d% d� d&|d d' k�s�t �d S ),Nr1 r� )�stdout_logfile�stderr_logfiler� rw )rx r rv TZ stopwaitsecsr� Zstdout_events_enabledFZstderr_events_enabledr� Zstdout_capture_maxbytesr� Z stopsignal� Z stderr_syslogZstdout_logfile_maxbytesZ group_prioi� Z killasgroupZ process_prioZ stdout_syslogZstderr_logfile_maxbytesr� �redirect_stderrr �autoZ exitcodesZstderr_capture_maxbytesZ startretriesZinuser Zstdout_logfile_backupsztest_rpcinterfaces.pyZcommandr( Znone)r )r )r r r rz r r r r r4 r{ r$ �getAllConfigInfor r )r r4 r6 r� r� r� r% Zconfigsr r r �test_getAllConfigInfom s� z=SupervisorNamespaceXMLRPCInterfaceTests.test_getAllConfigInfoc C s� t � }t|d�}t|dt�}t|dt�}t|d||gd�}dt|�i|_|g|j_| j |�}t d �g}yddl m } |j |� W n tk r� Y nX xF|D ]>} x8|j� D ],} x&| j� D ]\} } | jt| | �| � q�W q�W q�W d S )Nr1 r� r� rw )rx r )�Enum)r r r rz r r r r4 r{ r$ �type�enumr �append� ImportErrorr �itemsr� � isinstance) r r4 r6 r� r� r� r% Zunmarshallablesr �typ�config�k�vr r r �>test_getAllConfigInfo_filters_types_not_compatible_with_xmlrpc� s$ zfSupervisorNamespaceXMLRPCInterfaceTests.test_getAllConfigInfo_filters_types_not_compatible_with_xmlrpcc C s2 t � }| j|�}td }td }ddlm} dd|j||td�}|j|�}| j|d� dd |j||td d �}|j|�}| j|d � dd |j||td d �} |j| �}| j|d � dd|j ||td d �} |j| �}ddl m } | t j |�d d� � } | j|| j t�� dd|j d|td d �} |j| �}| j|d� d S )Nr� r( r )r� �running)r� r� r� �startr� �nowzpid 1, uptime 0:01:40�fatalr� ZHosed)r� r� r� r r� r r� � z unknown error (try "tail fatal")�stopped� )�datetime� z Not started)r r$ r r� r� r� �_interpretProcessInfor ZFATALr� r! �time� localtime�strftimer )r r6 r% r r� r� r r� r Zfatal2r r! ZstoptimeZstopped2r r r �test__interpretProcessInfo� sf zBSupervisorNamespaceXMLRPCInterfaceTests.test__interpretProcessInfoc C sN t � }| j|�}ddlm} dd|jtd d td�}|j|�}| j|d� d S )Nr )r� r �* r� )r� r� r� r r� r zpid 42, uptime 0:00:00)r r$ r� r� r� r r# r )r r6 r% r� r r� r r r �8test__interpretProcessInfo_doesnt_report_negative_uptime s z`SupervisorNamespaceXMLRPCInterfaceTests.test__interpretProcessInfo_doesnt_report_negative_uptimec C sT ddl m} t� }t|dddd�}t|�}d|_d|_d |_t|dd �}t |�}d|i|_ t d|id �}| j |�}|j d�} | j|jd � | j| d d� | j| d d� | j| d d� | j| d d� | j| d d� | j| d d� | j| d d � | j| d |j� | j| d d� | j| d d� | j| d d� | j| d jd�� d S ) Nr )r� r1 z/bin/fooz/tmp/fleeb.bar)r �o r� � )r� )r �getProcessInforR r r r r� r� r r� r� rD r� � exitstatusr� r� zpid 111)r� r� r r r r� � laststart�laststopr r r� r r$ r, r r3 r� r} � startswith) r r� r4 r r� � pgroup_configr� r6 r% r^ r r r �test_getProcessInfo s6 z;SupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfoc C s� t � }t|ddd d�}t|�}d|_d|_d|_t|dd�}t|�}d|i|_t d|id�}| j |�}|j d�}| j |d d � | j |d d � d S ) Nr1 z/bin/foo)r r* r� r+ )r� )r rR r r ) r r r r� r. r/ r r r� r r$ r, r ) r r4 r r� r1 r� r6 r% r^ r r r � test_getProcessInfo_logfile_NONE7 s zHSupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_logfile_NONEc C sr ddl m} t� }t|dd�}t|d|�}|jdd|j� | j|�}|jd�}| j |d d� | j |d d � d S ) Nr )r� r1 z/bin/foor� rD r� r� r ) rF r� r r r r� r� r$ r, r )r r� r4 r� r6 r% r^ r r r �!test_getProcessInfo_unknown_stateH s zISupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_unknown_statec C s4 ddl m} t� }| j|�}| j|jj|jd� d S )Nr )r � nonexistent)r r r r$ r r* r� r, )r r r6 r% r r r �-test_getProcessInfo_bad_name_when_bad_processS s zUSupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_bad_name_when_bad_processc C sL ddl m} t� }t|dd�}t|d|�}| j|�}| j|jj|j d� d S )Nr )r r1 z/bin/foozfoo:) r r r r r r$ r r* r� r, )r r r4 r� r6 r% r r r �,test_getProcessInfo_bad_name_when_no_processZ s zTSupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_bad_name_when_no_processc s� ddl m� t� }t|ddd d�}t|�}t� jd �|_t� jd �|_t |dd�}t |�}d|i|_ t d|id�}| j |�}� fd d �|_|jd�}| j|d � j� | j|d � j� | j|d � j� d S )Nr )� xmlrpclibr1 z/bin/foo)r r( )r� )r c s t � jd �S )Nr( )�float�MAXINTr )r8 r r rn p s zuSupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_caps_timestamps_exceeding_xmlrpc_maxint.<locals>.<lambda>r r� r )�supervisor.compatr8 r r r r9 r: r. r/ r r r� r r$ Z_nowr, r ) r r4 r r� r1 r� r6 r% r^ r )r8 r �;test_getProcessInfo_caps_timestamps_exceeding_xmlrpc_maxintc s" zcSupervisorNamespaceXMLRPCInterfaceTests.test_getProcessInfo_caps_timestamps_exceeding_xmlrpc_maxintc C s� ddl m} t� }t|ddddd�}t|dd d d d�}t|d ||�}|jdd d� |jddd� |jddd� |jdd|j� |jdd d� |jddd� |jddd� |jdd|j� | j|�}|j � }| j |j d� | j t |�d � |d }| j |d d� | j |d d� | j |d d� | j |d d� | j |d d� | j |d d� | j |d d� | j |d |j� | j |d d � | j |d d� | j |d d� | j |d! d � | j |d" jd#�� |d } |jd jd } | j | d d � | j | d d � | j |d d� | j | d d� | j | d d� | j | d | j� | j | d d� | j | d |j� | j | d d$� | j | d d� | j | d d� | j |d! d � dd%lm} | tj| j�d d&� � } | j | d" | jt�� d S )'Nr )r� r� z /bin/process1r( z/tmp/process1.log)r� r r� z /bin/process2r� z/tmp/process2.logZgnamer� r* r. r� r/ r+ r� � r, rR r r r r� r r� rD r� r- r� r� r� zpid 111r� )r! r" )r� r� r r r r� r� r� r$ ZgetAllProcessInfor r3 r� r} r0 r r� r. r! r$ r% r& r ) r r� r4 Zp1configZp2configr6 r% �infoZp1infoZp2infor� r! Z starttimer r r �test_getAllProcessInfov sl z>SupervisorNamespaceXMLRPCInterfaceTests.test_getAllProcessInfoc C sX ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j dddd� d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r )rL rM ) r r r r r r$ r r* rN �readProcessStdoutLog)r r r4 r� r6 r% r r r �$test_readProcessStdoutLog_unreadable� s zLSupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStdoutLog_unreadablec C s� ddl m} t� }t|ddddd�}t|d|�}| j|�}|jd jd }|jj }z\t |d��}|j d d � W d Q R X | j |j j|jdd dd � | j |j j|jdd dd � W d tj|� X d S )Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r zw+rP i )rL rM rQ rQ rQ )r r r r r r$ r r� r r rS rT r r* rU r@ rV rW ) r r r4 r� r6 r% r� rR rX r r r �!test_readProcessStdoutLog_badargs� s$ zISupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStdoutLog_badargsc C sX ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j d ddd � d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r r1 zfoo:*)rL rM ) r r r r r r$ r r* r� r@ )r r r4 r� r6 r% r r r �-test_readProcessStdoutLog_bad_name_no_process� s zUSupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStdoutLog_bad_name_no_processc C s t � }t|dddd�}t|d|�}| j|�}|jd jd }|jj}z�t|d��"}|j dd � |j dd � W d Q R X |j dd d d �}| j |j d � | j |dd dd � |j ddd d �}| j |dd � |j dd dd �}| j |dd � |j dd d d �}| j |d� W d t j|� X d S )Nr1 z/bin/fooz /tmp/fooooooo)r zw+rP i rZ r )rL rM r@ r[ r\ r] )r r r r$ r r� r r rS rT r@ r r3 rV rW ) r r4 r� r6 r% r� rR rX r^ r r r �test_readProcessStdoutLog� s* zASupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStdoutLogc C s< t � }t|dd�}t|d|�}| j|�}| j|j|j� d S )Nr1 z/bin/foo)r r r r$ r ZreadProcessLogr@ )r r4 r� r6 r% r r r �1test_readProcessLogAliasedTo_readProcessStdoutLog� s zYSupervisorNamespaceXMLRPCInterfaceTests.test_readProcessLogAliasedTo_readProcessStdoutLogc C sX ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j dddd� d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r )rL rM ) r r r r r r$ r r* rN �readProcessStderrLog)r r r4 r� r6 r% r r r �$test_readProcessStderrLog_unreadable s zLSupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStderrLog_unreadablec C s� ddl m} t� }t|ddddd�}t|d|�}| j|�}|jd jd }|jj }z\t |d��}|j d d � W d Q R X | j |j j|jdd dd � | j |j j|jdd dd � W d tj|� X d S )Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r zw+rP i )rL rM rQ rQ rQ )r r r r r r$ r r� r r rS rT r r* rU rF rV rW ) r r r4 r� r6 r% r� rR rX r r r �!test_readProcessStderrLog_badargs s$ zISupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStderrLog_badargsc C sX ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j d ddd � d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r r1 zfoo:*)rL rM ) r r r r r r$ r r* r� rF )r r r4 r� r6 r% r r r �-test_readProcessStderrLog_bad_name_no_process% s zUSupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStderrLog_bad_name_no_processc C s t � }t|dddd�}t|d|�}| j|�}|jd jd }|jj}z�t|d��"}|j dd � |j dd � W d Q R X |j dd d d �}| j |j d � | j |dd dd � |j ddd d �}| j |dd � |j dd dd �}| j |dd � |j dd d d �}| j |d� W d t j|� X d S )Nr1 z/bin/fooz /tmp/fooooooo)r zw+rP i rZ r )rL rM rF r[ r\ r] )r r r r$ r r� r r rS rT rF r r3 rV rW ) r r4 r� r6 r% r� rR rX r^ r r r �test_readProcessStderrLog0 s* zASupervisorNamespaceXMLRPCInterfaceTests.test_readProcessStderrLogc C s8 ddl m} t� }| j|�}| j|jj|jddd� d S )Nr )r r� r� )r r r r$ r r* r� �tailProcessStdoutLog)r r r6 r% r r r �"test_tailProcessStdoutLog_bad_nameH s zJSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_bad_namec C sV ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j d dd � d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r r1 zfoo:*r� ) r r r r r r$ r r* r� rK )r r r4 r� r6 r% r r r �-test_tailProcessStdoutLog_bad_name_no_processO s zUSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_bad_name_no_processc C s� ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }ztt |d��}|j |� W d Q R X |j ddt |�d�\} } } | j|jd � | j| d � | j| t |�� | j| |� W d tj|� X d S ) Nr )�lettersr1 z/bin/fooz /tmp/fooooooo)r zw+)rL rM rK F)r; rN r r r r$ r r� r r rS rT rK r� r r3 rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL �overflowr r r � test_tailProcessStdoutLog_allY s& zESupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_allc C s* ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }z�t |d��}|j |� W d Q R X |j dt |�dd �\} } } | j|jd � | j| d � | j| t |�� | j| d � |j dt |�d dd �\} } } | j|jd � | j| d � | j| t |�� | j| d � W d tj|� X d S )Nr )rN r1 z/bin/fooz /tmp/fooooooo)r zw+r� )rL rM rK Fr � )r; rN r r r r$ r r� r r rS rT rK r� r r3 rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL rO r r r � test_tailProcessStdoutLog_noneq s4 zFSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_nonec C s� ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }zxt |d��}|j |� W d Q R X |j dddd �\} } } | j |jd � | j | d � | j | t|�� | j | |d d � � W d tj|� X d S ) Nr )rN r1 z/bin/fooz /tmp/fooooooo)r zw+rQ )rL rM rK T���)r; rN r r r r$ r r� r r rS rT rK r r3 r� rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL rO r r r �"test_tailProcessStdoutLog_overflow� s$ zJSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_overflowc C sx t � }t|dddd�}t|d|�}| j|�}|jdddd�\}}}| j|jd� | j|d � | j|d� | j|d � d S ) Nr1 z/bin/fooz /tmp/fooooooo)r r r� )rL rM rK Fr )r r r r$ rK r r3 )r r4 r� r6 r% r^ rL rO r r r �$test_tailProcessStdoutLog_unreadable� s zLSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStdoutLog_unreadablec C s< t � }t|dd�}t|d|�}| j|�}| j|j|j� d S )Nr1 z/bin/foo)r r r r$ r ZtailProcessLogrK )r r4 r� r6 r% r r r �1test_tailProcessLogAliasedTo_tailProcessStdoutLog� s zYSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessLogAliasedTo_tailProcessStdoutLogc C s8 ddl m} t� }| j|�}| j|jj|jddd� d S )Nr )r r� r� )r r r r$ r r* r� �tailProcessStderrLog)r r r6 r% r r r �"test_tailProcessStderrLog_bad_name� s zJSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_bad_namec C sV ddl m} t� }t|ddddd�}t|d|�}| j|�}| j|jj|j d dd � d S ) Nr )r r� z /bin/process1r( z/tmp/process1.log)r� r r1 zfoo:*r� ) r r r r r r$ r r* r� rW )r r r4 r� r6 r% r r r �-test_tailProcessStderrLog_bad_name_no_process� s zUSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_bad_name_no_processc C s� ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }ztt |d��}|j |� W d Q R X |j ddt |�d�\} } } | j|jd � | j| d � | j| t |�� | j| |� W d tj|� X d S ) Nr )rN r1 z/bin/fooz /tmp/fooooooo)r zw+)rL rM rW F)r; rN r r r r$ r r� r r rS rT rW r� r r3 rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL rO r r r � test_tailProcessStderrLog_all� s& zESupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_allc C s* ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }z�t |d��}|j |� W d Q R X |j dt |�dd �\} } } | j|jd � | j| d � | j| t |�� | j| d � |j dt |�d dd �\} } } | j|jd � | j| d � | j| t |�� | j| d � W d tj|� X d S )Nr )rN r1 z/bin/fooz /tmp/fooooooo)r zw+r� )rL rM rW Fr rQ )r; rN r r r r$ r r� r r rS rT rW r� r r3 rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL rO r r r � test_tailProcessStderrLog_none� s4 zFSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_nonec C s� ddl m} t� }t|dddd�}t|d|�}| j|�}|jd jd }|jj }zxt |d��}|j |� W d Q R X |j dddd �\} } } | j |jd � | j | d � | j | t|�� | j | |d d � � W d tj|� X d S ) Nr )rN r1 z/bin/fooz /tmp/fooooooo)r zw+rQ )rL rM rW TrS )r; rN r r r r$ r r� r r rS rT rW r r3 r� rV rW ) r rN r4 r� r6 r% r� rR rX r^ rL rO r r r �"test_tailProcessStderrLog_overflow s$ zJSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_overflowc C sx t � }t|dddd�}t|d|�}| j|�}|jdddd�\}}}| j|jd� | j|d � | j|d� | j|d � d S ) Nr1 z/bin/fooz /tmp/fooooooo)r r r� )rL rM rW Fr )r r r r$ rW r r3 )r r4 r� r6 r% r^ rL rO r r r �$test_tailProcessStderrLog_unreadable# s zLSupervisorNamespaceXMLRPCInterfaceTests.test_tailProcessStderrLog_unreadablec C sh ddl m} t� }t|dd�}t|�}td �}d|i|_td|id�}| j|�}| j |j j |j d� d S )Nr )r r1 )r Zbadgroup) r r r r r r r� r r$ r r* r� �clearProcessLogs)r r r4 r� r� r� r6 r% r r r �'test_clearProcessLogs_bad_name_no_group2 s zOSupervisorNamespaceXMLRPCInterfaceTests.test_clearProcessLogs_bad_name_no_groupc C sh ddl m} t� }t|dd�}t|�}td �}d|i|_td|id�}| j|�}| j |j j |j d� d S )Nr )r r1 )r zfoo:*) r r r r r r r� r r$ r r* r� r^ )r r r4 r� r� r� r6 r% r r r �)test_clearProcessLogs_bad_name_no_process? s zQSupervisorNamespaceXMLRPCInterfaceTests.test_clearProcessLogs_bad_name_no_processc C s` t � }t|dd�}t|�}td �}d|i|_td|id�}| j|�}|jd� | j|j d� d S )Nr1 )r T) r r r r r� r r$ r^ r � logsremoved)r r4 r� r� r� r6 r% r r r �test_clearProcessLogsL s z=SupervisorNamespaceXMLRPCInterfaceTests.test_clearProcessLogsc C sl ddl m} t� }t|dd�}t|�}td �}d|i|_d|_td|id�}| j |�}| j |j |j d� d S )Nr )r r1 T)r ) r r r r r r r� �error_at_clearr r$ rf r r^ )r r r4 r� r� r� r6 r% r r r � test_clearProcessLogs_failedW s zDSupervisorNamespaceXMLRPCInterfaceTests.test_clearProcessLogs_failedc C s< t � }t|dd�}t|d|�}| j|�}| j|j|j� d S )Nr1 z/bin/foo)r r r r$ r ZclearProcessLogr^ )r r4 r� r6 r% r r r �.test_clearProcessLogAliasedTo_clearProcessLogsc s zVSupervisorNamespaceXMLRPCInterfaceTests.test_clearProcessLogAliasedTo_clearProcessLogsc C s� t � }t|dddd�}t|dddd�}t|d||�}| j|�}|j� }|� |� }dd lm} | j|d dd|jj d d �� | j|d dd|jj d d �� |j d j d } | j| j d � |j d j d } | j| j d � d S ) Nr� r1 r( )r� r� r r� r )r r� )r� r� r� r� T) r r r r$ �clearAllProcessLogsr r r r* r� r r� ra ) r r4 r� r� r6 r% r� �resultsr r� r� r r r �test_clearAllProcessLogsk s0 z@SupervisorNamespaceXMLRPCInterfaceTests.test_clearAllProcessLogsc C s� t � }t|dddd�}t|dddd�}t|d||�}|jddd � | j|�}|j� }|� |� }|jd jd }| j|j d � |jd jd } | j| j d � | jt |�d� d d l m } | j|d dd| j jd d�� | j|d dd| j jdd�� d S )Nr� r1 r( )r� r� r r� rc TFr )r zFAILED: foo:process1)r� r� r� r� r� )r r r r� r$ rf r r� r ra r� r r r* r� r� ) r r4 r� r� r6 r% r� rg r� r� r r r r �!test_clearAllProcessLogs_onefails� s4 zISupervisorNamespaceXMLRPCInterfaceTests.test_clearAllProcessLogs_onefailsc C s< t � }| j|ji � | j|�}|j� }|� }| j|g � d S )N)r r r r$ rf )r r6 r% r� rg r r r �%test_clearAllProcessLogs_no_processes� s zMSupervisorNamespaceXMLRPCInterfaceTests.test_clearAllProcessLogs_no_processesc C sR t � }t|dd�}t|d|�}| j|�}d}ddlm} | j|jj|j d|� d S )Nr� r1 r( r )r ) r r r r$ r r r r* r+ �sendProcessStdin)r r4 r� r6 r% Zthing_not_charsr r r r �<test_sendProcessStdin_raises_incorrect_params_when_not_chars� s zdSupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_incorrect_params_when_not_charsc C s6 t � }| j|�}ddlm} | j|jj|jdd� d S )Nr )r r5 zchars for stdin)r r$ r r r r* r� rk )r r6 r% r r r r �6test_sendProcessStdin_raises_bad_name_when_bad_process� s z^SupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_bad_name_when_bad_processc C s@ t � }t|d�}| j|�}ddlm} | j|jj|jdd� d S )Nr1 r )r zfoo:*zchars for stdin) r r r$ r r r r* r� rk )r r4 r6 r% r r r r �5test_sendProcessStdin_raises_bad_name_when_no_process� s z]SupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_bad_name_when_no_processc C s\ t � }t|dd�}t|d|�}|jddd� | j|�}ddlm} | j|jj |j dd� d S )Nr� r1 r� r )r zchars for stdin) r r r r� r$ r r r r* r� rk )r r4 r� r6 r% r r r r �=test_sendProcessStdin_raises_not_running_when_not_process_pid� s zeSupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_not_running_when_not_process_pidc C sj t � }t|dd�}t|d|�}|jddd� |jddd� | j|�}ddlm} | j|jj |j dd � d S ) Nr� r1 r� r( r� Tr )r zchars for stdin) r r r r� r$ r r r r* r� rk )r r4 r� r6 r% r r r r �5test_sendProcessStdin_raises_not_running_when_killing� s z]SupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_not_running_when_killingc C s� t � }t|dd�}t|d|�}|jddd� |jddd� |jddttjtjtj��� | j |�}dd l m } | j |j j|jdd � d S ) Nr� r1 r� r( r� F�write_exceptionr )r zchars for stdin)r r r r� rc rd ZEPIPErV re r$ r r r r* rN rk )r r4 r� r6 r% r r r r �<test_sendProcessStdin_raises_no_file_when_write_raises_epipe� s zdSupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_raises_no_file_when_write_raises_epipec C sx t � }t|dd�}t|d|�}|jddd� |jddd� |jddttjtjtj��� | j |�}| j t|j dd� d S ) Nr� r1 r� r( r� Frq zchars for stdin) r r r r� rc rd ZEINTRrV re r$ rf rk )r r4 r� r6 r% r r r �-test_sendProcessStdin_reraises_other_oserrors� s zUSupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_reraises_other_oserrorsc C s| t � }t|dd�}t|d|�}|jddd� | j|�}d}| j|jd|�� | jd|j� |j d j d }| j|j |� d S )Nr� r1 r� r( s chars for stdinrk ) r r r r� r$ r} rk r r3 r r� � stdin_buffer)r r4 r� r6 r% �charsr� r r r �3test_sendProcessStdin_writes_chars_and_returns_true� s z[SupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_writes_chars_and_returns_truec C sh t � }t|dd�}t|d|�}|jddd� | j|�}|jdtd�� |jd jd }| j |j d� d S )Nr� r1 r� r( s fií) r r r r� r$ rk r r r� r rt )r r4 r� r6 r% r� r r r �-test_sendProcessStdin_unicode_encoded_to_utf8 s zUSupervisorNamespaceXMLRPCInterfaceTests.test_sendProcessStdin_unicode_encoded_to_utf8c s� t � }t|�}| j|�}ddlm} g � � fdd�}z&|j|fg|jd d �< |jdd�}W d g |jd d �< |j� X | j |� | j t � �d� � d }| j |j d� | j |j d� d S )Nr )�eventsc s � j | � d S )N)r )�event)r� r r r� s zgSupervisorNamespaceXMLRPCInterfaceTests.test_sendRemoteCommEvent_notifies_subscribers.<locals>.callbackr1 r r( )r r r$ r rx �RemoteCommunicationEvent� callbacks�sendRemoteCommEvent�clearr} r r� r r^ )r r4 r6 r% rx r� rh ry r )r� r �-test_sendRemoteCommEvent_notifies_subscribers s zUSupervisorNamespaceXMLRPCInterfaceTests.test_sendRemoteCommEvent_notifies_subscribersc s� t � }t|�}| j|�}ddlm} g � � fdd�}z.|j|fg|jd d �< |jtd�td��}W d g |jd d �< |j � X | j |� | j t � �d� � d }t r�| j |jd� | j |jd � n | j |jd� | j |jd� d S ) Nr )rx c s � j | � d S )N)r )ry )r� r r r� + s zjSupervisorNamespaceXMLRPCInterfaceTests.test_sendRemoteCommEvent_unicode_encoded_to_utf8.<locals>.callbacku fií onceu fií twicer( u fià onceu fià twice)r r r$ r rx rz r{ r| r r} r} r r� r r r^ )r r4 r6 r% rx r� rh ry r )r� r �0test_sendRemoteCommEvent_unicode_encoded_to_utf8$ s* zXSupervisorNamespaceXMLRPCInterfaceTests.test_sendRemoteCommEvent_unicode_encoded_to_utf8N)zr r r! r# r$ r7 r: r; r> rA rG rI rK rO rY r_ ra rg ri rk rl rp rt r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� 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 r4 r6 r7 r< r? rA rB rC rD rE rG rH rI rJ rL rM rP rR rT rU rV rX rY rZ r[ r\ r] r_ r` rb rd re rh ri rj rl rm rn ro rp rr rs rv rw r~ r r r r r r- B s� " $ $$ # !H> B " " r- c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )�#SystemNamespaceXMLRPCInterfaceTestsc C s ddl m} |jS )Nr )r )r r ZSystemNamespaceRPCInterface)r r r r r r# D s z3SystemNamespaceXMLRPCInterfaceTests._getTargetClassc C s. ddl m} t� }|j|�}| j� d|fg�S )Nr )r. r )r r. r r/ r# )r r. r6 r r r r r$ H s z,SystemNamespaceXMLRPCInterfaceTests._makeOnec C s, | j � }| j|jd � | j|jd � d S )Nr �system)r$ r} � namespaces)r r% r r r r& Q s z-SystemNamespaceXMLRPCInterfaceTests.test_ctorc C s@ | j � }|j� }|j� t|j� j� �}|j� | j||� d S )N)r$ � listMethods�sortr~ � _listMethodsr� r )r r% �methodsr� r r r �test_listMethodsV s z4SystemNamespaceXMLRPCInterfaceTests.test_listMethodsc C sH ddl m} | j� }| j|jj|jdg� |jd�}| j|ddg� d S )Nr )r zfoo.barzsystem.methodSignature�array�string)r r r$ r r* �SIGNATURE_UNSUPPORTED�methodSignaturer )r r r% rh r r r �test_methodSignature^ s z8SystemNamespaceXMLRPCInterfaceTests.test_methodSignaturec C s� ddl m} ddddddd d d g }| j� }|j� }�xL|j� D �]>}y|j|� W n" |jk rt td | ��Y nX |jd d�\}}|j | }t ||�} y | j } W n t k r� | j } Y nX | jd| j� } |jt| j��} g } g }g }g }g }g }g }g }x�| D ]�}|d dk�rR| j|d � |j|d � |j|d � |j|d � nl|d dk�r�|j|d � |j|d � |j|d � |j|d � n$|d d k �rtd|d || f ���qW t| �t|�k�r�tdt| �t|�|f ��x.| D ]&}| jt|�tk|t|�|| f� �q�W x |D ]}| j||k|� �q&W xHtt|��D ]8}|| | | k�rNd|| | | || f }t|���qNW x&|D ] }| jt|�td�k|� �q�W t|�dk�r�td| ��x,|D ]$}| jt|�tk|t|�|f� �q�W x |D ]}| j||k|� �q W x0|D ](}| jt|�td�k|t|�|f� �q W x0|D ](}| jt|�td�k|t|�|f� �qRW q>W d S )Nr )r �intZdoubler� ZbooleanzdateTime.iso8601�base64Zbinaryr� �structz=methodSignature for %s raises RPCError (missing @return doc?)�.r( Zparamr� r r[ �returnz%unknown tag type %s for %s, parsed %sz6Incorrect documentation (%s args, %s doc params) in %sz Name wrong: (%s vs. %s in %s) %sr z'Duplicate @return values in docs for %s)r r r$ r� r� r� r r �splitr� �getattrZ func_code� Exception�__code__� co_varnames� co_argcountZgettags�str�__doc__r r� r} r r� �range) r r Z _RPCTYPESr% r� r Zns_nameZ method_name� namespace�methr ZargnamesZparsedZplinesZptypesZpnamesZptextsZrlinesZrtypesZrnamesZrtexts�thingZdoclineZdoctyperP r� ZdoctextZdocnamer r r �test_allMethodDocsg s� z6SystemNamespaceXMLRPCInterfaceTests.test_allMethodDocsc C sR | j � }|jddgd�dg d�g�}| j|d |jd�� | j|d |j� � d S )Nzsystem.methodHelp)� methodName�paramszsystem.listMethodsr r( )r$ � multicallr � methodHelpr� )r r% rg r r r �test_multicall_simplevals� s z=SystemNamespaceXMLRPCInterfaceTests.test_multicall_simplevalsc C sV ddl m} | j� }|jdg d�g�}|j|jjd�}|j|jd�}| j ||g� d S )Nr )r zsystem.multicall)r� r� z$Recursive system.multicall forbidden)Z faultCodeZ faultString) r r r$ r� r r* r+ r �textr )r r r% rg �eZrecursion_faultr r r � test_multicall_recursion_guard� s zBSystemNamespaceXMLRPCInterfaceTests.test_multicall_recursion_guardc C sT ddl m} | j� }|jddig�}|j}x||jkr>|� }q,W | j|d g � d S )Nr )r� r� zsupervisor.stopAllProcesses)r r� r$ r� r� r )r r� r% r� rg r r r � test_multicall_nested_callback� s zBSystemNamespaceXMLRPCInterfaceTests.test_multicall_nested_callbackc C sH ddl m} | j� }| j|jj|jdg� |jd�}| j||jj� d S )Nr )r zfoo.barzsystem.methodHelp) r r r$ r r* r� r� r r� )r r r% �helpr r r �test_methodHelp� s z3SystemNamespaceXMLRPCInterfaceTests.test_methodHelpN) r r r! r# r$ r& r� r� r� r� r� r� r� r r r r r� C s a r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �Test_make_allfuncc K s ddl m} ||||f|�S )Nr )� make_allfunc)�supervisor.rpcinterfacer� )r r� Z predicate�funcZ extra_kwargsr� r r r �_callFUT� s zTest_make_allfunc._callFUTc s| ddl m� � fdd�}t� }t|dd�}t|�}t|�}dd� }| j||fg||�}|� }| j|d dd� jj d �g� d S ) Nr )r c s � j � jj��d S )N)r r* r� )r� r )r r r �cb� s z7Test_make_allfunc.test_rpcerror_nocallbacks.<locals>.cbr� r1 c S s dS )NTr )r� r r r �pred� s z9Test_make_allfunc.test_rpcerror_nocallbacks.<locals>.predr� )r� r� r� r� ) r r r r r r r� r r* r� ) r r� r4 r� r� r� r� �afrh r )r r �test_rpcerror_nocallbacks� s z+Test_make_allfunc.test_rpcerror_nocallbacksc C sh dd� }t � }t|dd�}t|�}t|�}dd� }| j||fg||�}|� }| j|ddddd �g� d S ) Nc [ s dd� S )Nc S s dS )Nr( r r r r r rn s zTTest_make_allfunc.test_func_callback_normal_return_val.<locals>.cb.<locals>.<lambda>r )r� r r r r r� s zBTest_make_allfunc.test_func_callback_normal_return_val.<locals>.cbr� r1 c S s dS )NTr )r� r r r r� s zDTest_make_allfunc.test_func_callback_normal_return_val.<locals>.predr� �P )r� r� r� r� )r r r r r� r ) r r� r4 r� r� r� r� r� rh r r r �$test_func_callback_normal_return_val s z6Test_make_allfunc.test_func_callback_normal_return_valc sx ddl m� � fdd�}t� }t|dd�}t|�}t|�}dd� }| j||fg||�}|� }| j|d dd dd �g� d S ) Nr )r c s � fdd�}|S )Nc s � j � jj��d S )N)r r* r� r )r r r �inner s zOTest_make_allfunc.test_func_callback_raises_RPCError.<locals>.cb.<locals>.innerr )r� r r� )r r r r� s z@Test_make_allfunc.test_func_callback_raises_RPCError.<locals>.cbr� r1 c S s dS )NTr )r� r r r r� # s zBTest_make_allfunc.test_func_callback_raises_RPCError.<locals>.predr� � )r� r� r� r� )r r r r r r r� r ) r r� r4 r� r� r� r� r� rh r )r r �"test_func_callback_raises_RPCError s z4Test_make_allfunc.test_func_callback_raises_RPCErrorc sl ddl m� � fdd�}t� }t|dd�}t|�}t|�}dd� }| j||fg||�}|� }| j|� � d S ) Nr )r� c s � fdd�}|S )Nc s � S )Nr r )r� r r r� 2 s zTTest_make_allfunc.test_func_callback_returns_NOT_DONE_YET.<locals>.cb.<locals>.innerr )r� r r� )r� r r r� 1 s zETest_make_allfunc.test_func_callback_returns_NOT_DONE_YET.<locals>.cbr� r1 c S s dS )NTr )r� r r r r� 9 s zGTest_make_allfunc.test_func_callback_returns_NOT_DONE_YET.<locals>.pred)r� r� r r r r r� r ) r r� r4 r� r� r� r� r� rh r )r� r �'test_func_callback_returns_NOT_DONE_YET/ s z9Test_make_allfunc.test_func_callback_returns_NOT_DONE_YETN)r r r! r� r� r� r� r� r r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�Test_make_main_rpcinterfacec C s ddl m} ||�S )Nr )�make_main_rpcinterface)r� r� )r r6 r� r r r r� C s z$Test_make_main_rpcinterface._callFUTc C s | j d �}| j|jjd� d S )Nr/ )r� r � __class__r )r r r r r �test_itG s z#Test_make_main_rpcinterface.test_itN)r r r! r� r� r r r r r� B s r� c @ s e Zd Zdd� ZdS )r) c C s dS )NzHello!r )r r r r �helloQ s zDummyRPCInterface.helloN)r r r! r� r r r r r) P s r) c C s t jtjt �S )N)�unittestZ findTestCases�sys�modulesr r r r r � test_suiteT s r� �__main__)Z defaultTest) r� r� r� rV r$ rd Zsupervisor.tests.baser r r r r r r r r r; r r r� r ZTestCaser r" r- r� r� r� r) r� r �mainr r r r �<module> sV .R
Back to File Manager