403Webshell
Server IP : 46.62.235.243  /  Your IP : 216.73.216.163
Web Server : Apache/2.4.58 (Ubuntu)
System : Linux Linkabili3Dicembre 6.8.0-100-generic #100-Ubuntu SMP PREEMPT_DYNAMIC Tue Jan 13 16:40:06 UTC 2026 x86_64
User : www-data ( 33)
PHP Version : 8.1.33
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /lib/python3/dist-packages/supervisor/tests/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /lib/python3/dist-packages/supervisor/tests/__pycache__/test_supervisord.cpython-312.pyc
�

k��c�X�ddlZddlZddlZddlZddlZddlZddlZddlmZddlm	Z	ddl
mZddl
mZddl
m
Z
ddl
mZddl
mZdd	l
mZdd
lmZ	ddlZGd�dej*�ZGd
�dej*�Zd�Zedk(rej4d��yy#e$rdZY�PwxYw)�N)�
ProcessStates)�SupervisorStates)�DummyOptions)�DummyPConfig)�DummyPGroupConfig)�DummyProcess)�DummyProcessGroup)�DummyDispatcher)�StringIOc�(�eZdZd�Zerd�Zd�Zd�Zy)�EntryPointTestsc	���ddlm}tjj	tjjtjj
t��dd�}t�}d�|_	tj}	tj�}tjj	|d�}tjj	|d�}|t_|d|d	|d
|dgd�
�|t_tj|�|j!�}|j#d|v|�y#|t_tj�wxYw)Nr��main�fixtures�donothing.confc��y�N��r��C/usr/lib/python3/dist-packages/supervisor/tests/test_supervisord.py�<lambda>z5EntryPointTests.test_main_noprofile.<locals>.<lambda>#��r�log�pid�-c�-l�-j�-nT��args�testzsupervisord started��supervisor.supervisordr�os�path�join�abspath�dirname�__file__r�fileno�sys�stdout�tempfile�mkdtemp�shutil�rmtree�getvalue�
assertTrue�	�selfr�conf�
new_stdout�
old_stdout�tempdirrr�outputs	         r�test_main_noprofilez#EntryPointTests.test_main_noprofiles���/��w�w�|�|��G�G�O�O�B�G�G�O�O�H�5�6�
�����Z�
�%�
���Z�Z�
�		#��&�&�(�G��'�'�,�,�w��.�C��'�'�,�,�w��.�C�#�C�J��t�T�4��d�C��>��
�$�C�J��M�M�'�"��$�$�&�����-��7��@��$�C�J��M�M�'�"�s
�	A0D>�>"E c
���ddlm}tjj	tjjtjj
t��dd�}t�}d�|_	tj}	tj�}tjj	|d�}tjj	|d�}|t_|d|d	|d
|ddgd
��|t_tj|�|j!�}|j#d|v|�y#|t_tj�wxYw)Nrrrrc��yrrrrrrz3EntryPointTests.test_main_profile.<locals>.<lambda>9rrrrrrrr z"--profile_options=cumulative,callsTr!zcumulative time, call countr$r5s	         r�test_main_profilez!EntryPointTests.test_main_profile3s��3��7�7�<�<������������ 9�:�J� �"�D�"��J� )�J�����J�	
'�"�*�*�,���g�g�l�l�7�E�2���g�g�l�l�7�E�2��'��
��4��t�S�$��T�?�A�GK�M�(��
��
�
�g�&��(�(�*�F��O�O�9�V�C�V�L��(��
��
�
�g�&�s
�	A1D?�?"E!c	���ddlm}tjj	tjjtjj
t��dd�}t�}d�|_	tj}	tj�}tjj	|d�}tjj	|d�}|t_|d|d	|d
|dgd�
�|t_tj|�|j!�}|j#t%|�d�y#|t_tj�wxYw)Nrrrrc��yrrrrrrz1EntryPointTests.test_silent_off.<locals>.<lambda>Nrrrrrrrr Tr!)r%rr&r'r(r)r*r+rr,r-r.r/r0r1r2r3�
assertGreater�lenr5s	         r�test_silent_offzEntryPointTests.test_silent_offHs���/��w�w�|�|��G�G�O�O�B�G�G�O�O�H�5�6�
�����Z�
�%�
���Z�Z�
�	#��&�&�(�G��'�'�,�,�w��.�C��'�'�,�,�w��.�C�#�C�J��t�T�4��d�C��>�T�J�#�C�J��M�M�'�"��$�$�&�����3�v�;��*��$�C�J��M�M�'�"�s
�	A0E�"E'c
���ddlm}tjj	tjjtjj
t��dd�}t�}d�|_	tj}	tj�}tjj	|d�}tjj	|d�}|t_|d|d	|d
|ddgd
��|t_tj|�|j!�}|j#t%|�d�y#|t_tj�wxYw)Nrrrrc��yrrrrrrz0EntryPointTests.test_silent_on.<locals>.<lambda>crrrrrrrr z-sTr!)r%rr&r'r(r)r*r+rr,r-r.r/r0r1r2r3�assertEqualrCr5s	         r�test_silent_onzEntryPointTests.test_silent_on]s���/��w�w�|�|��G�G�O�O�B�G�G�O�O�H�5�6�
�����Z�
�%�
���Z�Z�
�	#��&�&�(�G��'�'�,�,�w��.�C��'�'�,�,�w��.�C�#�C�J��t�T�4��d�C��t�D�4�P�#�C�J��M�M�'�"��$�$�&������V��a�(��$�C�J��M�M�'�"�s
�	A1E�"E(N)�__name__�
__module__�__qualname__r<�pstatsr?rDrHrrrr
r
s��A�*�	M�*+�*)rr
c��eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Z d�Z!d �Z"d!�Z#d"�Z$d#�Z%d$�Z&d%�Z'd&�Z(d'�Z)y())�SupervisordTestsc��ddlm}|�y)Nr)�clear)�supervisor.eventsrP)r6rPs  r�tearDownzSupervisordTests.tearDownss
��+�
�rc��ddlm}|S)Nr)�
Supervisor)r%rT)r6rTs  r�_getTargetClassz SupervisordTests._getTargetClassws��5��rc�.�|j�|�S�N)rU)r6�optionss  r�_makeOnezSupervisordTests._makeOne{s��%�t�#�#�%�g�.�.rc���t�}t|ddd�}t|d|g��g}||_d|_d|_|j
|�}|j�|j|jd�|j|jd�|j|jdg�|j|jg�|j|jdg�|j|jd�|jt|j �d	�|j|j dj"j$|�|j|j&d�|j|j(d�|j|j*d�|j|j,d�|j|j.d�y)
N�foo�/bin/foo�/tmp��pconfigsTF�
setuid_called�rlimits_setr)rrr�process_group_configsr#�firstrYrrG�fds_cleaned_upra�parse_criticals�parse_warnings�parse_infos�autochildlogdir_clearedrC�process_groups�configrX�httpservers_opened�signals_set�
daemonized�pidfile_written�
cleaned_up�r6rX�pconfig�gconfigs�supervisords     r�test_main_firstz SupervisordTests.test_main_first~s����.���w��z�6�B��%�g�u��y�I�J��(0��%������
��m�m�G�,����������/�/��7�����,�,�d�3�����0�0�?�2C�D�����/�/��4�����,�,�}�o�>�����8�8�$�?�����[�7�7�8�!�<�����3�3�E�:�A�A�I�I� �	"�����3�3�T�:�����,�,�d�3�����+�+�T�2�����0�0�$�7�����+�+�T�2rc���t�}t|ddd�}t|d|g��g}||_d|_d|_|j
|�}|j�|j|jd�|jt|d��|j|jdg�|j|jg�|j|jg�|j|jd�|jt!|j"�d	�|j|j"dj$j&|�|j|j(d�|j|j*d�|j|j,d�|j|j.d�|j|j0d�y)
Nr[r\r]r^TFrar`r)rrrrbr#rcrYrrGrd�assertFalse�hasattrrerfrgrhrCrirjrXrkrlrmrnrorps     r�test_main_notfirstz#SupervisordTests.test_main_notfirst�s����.���w��z�6�B��%�g�u��y�I�J��(0��%������
��m�m�G�,����������/�/��6������-�8�9�����0�0�?�2C�D�����/�/��4�����,�,�b�1�����8�8�$�?�����[�7�7�8�!�<�����3�3�E�:�A�A�I�I� �	"�����3�3�T�:�����,�,�d�3�����+�+�U�3�����0�0�$�7�����+�+�T�2rc� �t�}d|_t|ddd�}t|�}d|_d|_d|_d|_d|i|_|j|�}|jd�	�|j|jd�y)
N�rr�processr\r]FT�NNr��once�
r�waitpid_returnrr�drained�killing�laststop�
waitstatus�
pidhistoryrY�reaprG�finished�r6rXrqr{rss     r�	test_reapzSupervisordTests.test_reap�s����.��!%����w�	�:�v�F���w�'�����������'�����[����m�m�G�,�����d��#�����)�)�5�1rc��t�}|j|�}|jdd��}|j|d�y)NT�d)r~�recursionguard)rrYr�rG)r6rXrs�results    r�test_reap_recursionguardz)SupervisordTests.test_reap_recursionguard�s<���.���m�m�G�,���!�!�t�C�!�@�������&rc� �t�}d|_t|ddd�}t|�}d|_d|_d|_d|_d|i|_|j|�}|jd	�
�|j|jd�y)Nrzr{r\r]FTr|r�c)r�rr�s     r�test_reap_more_than_oncez)SupervisordTests.test_reap_more_than_once�s����.��!%����w�	�:�v�F���w�'�����������'�����[����m�m�G�,�������+�����)�)�5�1rc�r�t�}d|_t|ddd�}t|�}d|_d|_d|_d|_d|i|_|j|�}|jd�	�|j|jd�|j|jjd
d�y)N)�rr{r\r]FTr|rr}rz$reaped unknown pid 2 (exit status 0))rr�rrr�r�r�r�r�rYr�rGr��logger�datar�s     r�test_reap_unknown_pidz&SupervisordTests.test_reap_unknown_pid�s����.��!%����w�	�:�v�F���w�'�����������'�����\����m�m�G�,�����d��#�����)�)�4�0�������,�,�Q�/�?�	Arc�>�t�}tj|_|j	|�}|j�|j
|jjtj�|j
|jjdd�y)Nrz(received SIGTERM indicating exit request)
r�signal�SIGTERM�_signalrY�
handle_signalrGrX�moodr�SHUTDOWNr�r��r6rXrss   r�test_handle_sigtermz$SupervisordTests.test_handle_sigterm��v���.�� �.�.����m�m�G�,���!�!�#�����,�,�1�1�)�2�2�	4�������,�,�Q�/�C�	Erc�>�t�}tj|_|j	|�}|j�|j
|jjtj�|j
|jjdd�y)Nrz'received SIGINT indicating exit request)
rr��SIGINTr�rYr�rGrXr�rr�r�r�r�s   r�test_handle_sigintz#SupervisordTests.test_handle_sigint�sv���.�� �-�-����m�m�G�,���!�!�#�����,�,�1�1�)�2�2�	4�������,�,�Q�/�B�	Drc�>�t�}tj|_|j	|�}|j�|j
|jjtj�|j
|jjdd�y)Nrz(received SIGQUIT indicating exit request)
rr��SIGQUITr�rYr�rGrXr�rr�r�r�r�s   r�test_handle_sigquitz$SupervisordTests.test_handle_sigquit�r�rc��t�}tj|_|j	|�}|j|jjtj�|j�|j|jjtj�|j|jjdd�y)Nrz*received SIGHUP indicating restart request)rr��SIGHUPr�rYrGrXr�r�RUNNINGr��
RESTARTINGr�r�r�s   r�#test_handle_sighup_in_running_statez4SupervisordTests.test_handle_sighup_in_running_states����.�� �-�-����m�m�G�,������,�,�1�1�)�1�1�	3��!�!�#�����,�,�1�1�)�4�4�	6�������,�,�Q�/�E�	Grc���t�}tj|_|j	|�}t
j|j_|j|jjt
j�|j�|j|jjt
j�|j|jjdd�y)Nrz@ignored SIGHUP indicating restart request (shutdown in progress))
rr�r�r�rYrr�rXr�rGr�r�r�r�s   r�$test_handle_sighup_in_shutdown_statez5SupervisordTests.test_handle_sighup_in_shutdown_state
s����.�� �-�-����m�m�G�,��#3�#<�#<���� �����,�,�1�1�)�2�2�	4��!�!�#�����,�,�1�1�)�2�2�	4�������,�,�Q�/�2�	3rc�D�t�}tj|_|j	|�}|j�|j
|jjtj�d}|j|jjd|v�y)N)z(received SIGCHLD indicating a child quitz'received SIGCLD indicating a child quitr)rr��SIGCHLDr�rYr�rGrXr�rr�r4r�r�)r6rXrs�msgss    r�test_handle_sigchldz$SupervisordTests.test_handle_sigchldsz���.�� �.�.����m�m�G�,���!�!�#�����,�,�1�1�)�1�1�	3�;��������+�+�A�.�$�6�7rc��t�}tj|_t	|ddd�}t|tj��}tj�dz
|_	|j|�}t	|ddd�g}t|d|��|_t|�}d|i|_|j�|j!|j"j$t&j(�|j!|j*d�|j!|j,j.d	d
�|j!|j*d�y)N�process1r\r])�staterr[r^Trz.received SIGUSR2 indicating log reopen request)rr��SIGUSR2r�rrr�STOPPING�time�delayrYrrbr	rir�rGrXr�rr��
logs_reopenedr�r�)r6rX�pconfig1r�rsr_�dummypgroups       r�test_handle_sigusr2z$SupervisordTests.test_handle_sigusr2(s���.�� �.�.������Z��H����
�0F�0F�G������q�����m�m�G�,�� ��%��V�D�E��(9��U��)��%�(��0��&*�;�%7��"��!�!�#�����,�,�1�1�)�1�1�	3�����.�.��5�������,�,�Q�/�I�	K�����2�2�D�9rc�>�t�}tj|_|j	|�}|j�|j
|jjtj�|j
|jjdd�y)Nrz#received SIGUSR1 indicating nothing)
rr��SIGUSR1r�rYr�rGrXr�rr�r�r�r�s   r�test_handle_unknown_signalz+SupervisordTests.test_handle_unknown_signal=sv���.�� �.�.����m�m�G�,���!�!�#�����,�,�1�1�)�1�1�	3�������,�,�Q�/�>�	@rc��t�}|j|�}|j|j�tj
�yrW)rrYrG�	get_staterr�r�s   r�test_get_statezSupervisordTests.test_get_stateGs7���.���m�m�G�,������.�.�0�2B�2J�2J�Krc�.�t�}|j|�}t|ddd�}t|d|g��}|g|j_|j
�\}}}|j||g�|j|g�|j|g�y)Nr�r\r]�group1r^)rrYrrrXrb�diff_to_activerG)r6rXrsrqr��added�changed�removeds        r�&test_diff_to_active_finds_groups_addedz7SupervisordTests.test_diff_to_active_finds_groups_addedLs����.���m�m�G�,���w�
�J��G��"�7�H��y�I��6<�H����1�"-�"<�"<�">���w��������)�����"�%�����"�%rc���t�}|j|�}t|ddd�}t|d|g��}t|ddd�}t|d|g��}||g|j_|j
|�|j
|�|g|j_|j�\}}}|j|g�|j|g�|j||g�y)	Nr�z
/bin/process1r]r�r^�process2z
/bin/process2�group2)	rrYrrrXrb�add_process_groupr�rG)	r6rXrsrqr�r�r�r�r�s	         r�(test_diff_to_active_finds_groups_removedz9SupervisordTests.test_diff_to_active_finds_groups_removed[s����.���m�m�G�,���w�
�O�V�L��"�7�H��y�I���w�
�O�V�L��"�7�H��y�I��6<�V�4D����1��%�%�f�-��%�%�f�-�6<�H����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+rc�l����ddlm�m�t��|j	��}��fd�}��fd�}|ddd��}|d|g�}|d	d	�}|d
|g�}||g}|ddd��}|d|g�}|d	d	�}|d
|g�}	|j|�|j|	�||j_|j�\}
}}|j|
g�|j|g�|j||g�t��|j	��}|dd�}
|d	d	�}|d|
|g�}|g}|j|d|
g��||j_|j�\}
}}|j|
g�|j|g�|j||g�y)Nr)�
ProcessConfig�ProcessGroupConfigc����id|�d|�dd�dd�dd�dd�d	d�d
d�dd�d
d�dd�dd�dd�dd�dd�dd�dd�dddddddddddddd�
�}|j|���fi|��S�N�name�command�	directory�umask�priorityi��	autostartT�autorestart�	startsecs�
�startretries�uid�stdout_logfile�stdout_capture_maxbytesr�stdout_events_enabledF�stdout_logfile_backups�stdout_logfile_maxbytes�
stdout_syslog�stderr_logfile)r)
�stderr_capture_maxbytes�stderr_events_enabled�stderr_logfile_backups�stderr_logfile_maxbytes�
stderr_syslog�redirect_stderr�
stopsignal�stopwaitsecs�stopasgroup�killasgroup�	exitcodes�environment�	serverurl��update)r�r��paramsr�r�rXs    ��r�make_pconfigzBSupervisordTests.test_diff_to_active_changed.<locals>.make_pconfigws�������'����T��#*�D��2<�c��CN�PT���t��&1�"��7E�c���t�	�.�t�	�6O�PQ�	�
(���)�!�
�.G��
� ���!�$��DE�).�*+��!&�#(�"�B�$�$�!�$�T�!�F�$
�M�M�&�!� ��3�F�3�3rc�����|d|�S)N�r)r�r_r�rXs  ��r�make_gconfigzBSupervisordTests.test_diff_to_active_changed.<locals>.make_gconfig�s���%�g�t�R��B�Brr��new)r�r�r�r��old)
�supervisor.optionsr�r�rrYr�rXrbr�rG)r6rsr�r�rqr�r�r��group3�group4r�r�r�r��pconfig2r�r�rXs               @@@r�test_diff_to_active_changedz,SupervisordTests.test_diff_to_active_changedqs����H��.���m�m�G�,��	4�,	C��z�:�5�A���h��	�2���z�:�6���h��	�2���v����z�:�5�A���h��	�2���z�:�6���h��	�2���%�%�f�-��%�%�f�-�47����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+��.���m�m�G�,���
�J�7���
�J�7���h��8�(<�=���h���%�%�l�8�h�Z�&H�I�47����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+rc������ddlm�ddlm�m�t��|j
��}��fd�}�fd�}d��fd�	}|dd�}|d	�}|d
|g|�}|dd�}|d�}|d
|g|�}||g}	|dd�}|d	�}|d
|g|�}
|dd�}|d�}|d
|g|�}|j|
�|j|�|	|j_	|j�\}}
}|j|g�|j|g�|j|
|g�t��|j
��}|dd�}|d	�}|d
|g|�}|dd�}|d�}|d
|g|�}||g}	|dd�}|d�}|d
|g|�}
|dd�}|d�}|d
|g|�}|j|
�|j|�|	|j_	|j�\}}
}|j|g�|j|g�|j|
|g�t��|j
��}|dd�}|d	�}|d
|g|d�}|dd�}|d�}|d
|g|�}||g}	|dd�}|d	�}|d
|g|d�}
|dd�}|d�}|d
|g|�}|j|
�|j|�|	|j_	|j�\}}
}|j|g�|j|g�|j|
|g�y)Nr)�
EventTypes)�EventListenerConfig�EventListenerPoolConfigc����id|�d|�dd�dd�dd�dd�d	d�d
d�dd�d
d�dd�dd�dd�dd�dd�dd�dd�dddddddddddddd�
�}|j|���fi|��Sr�r�)r�r�r�r�rrXs    ��rr�zPSupervisordTests.test_diff_to_active_changed_eventlistener.<locals>.make_pconfig�s�������'����T��#*�D��2<�c��CN�PT���t��&1�"��7E�c���t�	�.�t�	�6O�PQ�	�
(���)�!�
�.G��
� ���!�$��DE�).�*+��!&�#(�"�B�$�$�!�$�T�!�F�$
�M�M�&�!�&�w�9�&�9�9rc�R��g}|D]}|jt�|d��� |SrW)�append�getattr)�pool_event_namesr��pool_event_namers   �r�make_econfigzPSupervisordTests.test_diff_to_active_changed_eventlistener.<locals>.make_econfig�s3����F�#3�
J���
�
�g�j�/�4�H�I�
J��Mrc	� ����|d|d||�S)Nr�r�r)r�r_�pool_events�result_handlerrrXs    ��rr�zPSupervisordTests.test_diff_to_active_changed_eventlistener.<locals>.make_gconfig�s���*�7�D�"�h��K�Yg�h�hrr�zprocess1-new�TICK_60r�r��	TICK_3600r�zprocess1-old�TICK_5znew-result-handlerzold-result-handler)z&supervisor.dispatchers:default_handler)rQrr�rrrrYr�rXrbr�rG)r6rsr�rr�rq�econfigr�r�r�r�r�r�r�r�rrrrXs               @@@@r�)test_diff_to_active_changed_eventlistenerz:SupervisordTests.test_diff_to_active_changed_eventlistener�s����0�S��.���m�m�G�,��	:�,	�	i��z�>�:���y�)���h��	�7�;���z�:�6���{�+���h��	�7�;���v����z�>�:���y�)���h��	�7�;���z�:�6���{�+���h��	�7�;���%�%�f�-��%�%�f�-�47����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+��.���m�m�G�,���z�:�6���y�)���h��	�7�;���z�:�6���{�+���h��	�7�;���v����z�:�6���x�(���h��	�7�;���z�:�6���{�+���h��	�7�;���%�%�f�-��%�%�f�-�47����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+��.���m�m�G�,���z�:�6���y�)���h��	�7�<P�Q���z�:�6���{�+���h��	�7�;���v����z�:�6���y�)���h��	�7�<P�Q���z�:�6���{�+���h��	�7�;���%�%�f�-��%�%�f�-�47����1�"-�"<�"<�">���w�������#�����"�%�����6�(�+rc�
�t�}t|ddd�}t|d|g��}|g|_|j	|�}|j|ji�|j|�}|jt|jj��dg�|j|�|jd}|j|�}|j||jd�|j|�y)Nr[r\r]r^)rrrrbrYrGrir��list�keysr4)r6rXrq�gconfigrsr��groups       r�test_add_process_groupz'SupervisordTests.test_add_process_group/s����.���w��z�6�B��#�G�U�g�Y�G��)0�	��%��m�m�G�,������3�3�R�8��.�.�w�7������k�8�8�=�=�?�@�5�'�J�������*�*�5�1���.�.�w�7������� :� :�5� A�B����F�
�#rc�N��ddlm}g��fd�}|j|j|�t	�}t|ddd�}t
|d|g��}|g|_|j|�}|j|�d|_
|j�|j�d	g�y)
Nr��eventsc�(���jd�yr�r��event�Ls �r�callbackzESupervisordTests.test_add_process_group_emits_event.<locals>.callbackD����
�H�H�Q�Krr[r\r]r^Tr)
�
supervisorr�	subscribe�ProcessGroupAddedEventrrrrbrYr�r#�
runforeverrG�r6rr"rXrqrrsr!s       @r�"test_add_process_group_emits_eventz3SupervisordTests.test_add_process_group_emits_eventAs����%���	�����6�6��A��.���w��z�6�B��#�G�U�g�Y�G��)0�	��%��m�m�G�,���%�%�g�.������� �����Q�C� rc��t�}t|ddd�}t|d|g��}|j|�}|j	t
|jd�|j|�|jd}|j
d�}|j|j�|j|ji�|j|�|j|�td�g|jd_
|j
d�}|jt|jj��dg�|j|�y)Nr[r\r]r^�asdf)rrrrY�assertRaises�KeyError�remove_process_groupr�rir4�before_remove_calledrGr�unstopped_processesrr)r6rXrqrrsrr�s       r�test_remove_process_groupz*SupervisordTests.test_remove_process_groupSs���.���w��z�6�B��#�G�U�g�Y�G���m�m�G�,�����(�K�$D�$D�f�M��%�%�g�.��*�*�5�1���1�1�%�8������2�2�3�����3�3�R�8�������%�%�g�.�AM�d�AS�@T��"�"�5�)�=��1�1�%�8������k�8�8�=�=�?�@�5�'�J����F�
�#rc���ddlm}g��fd�}|j|j|�t	�}t|ddd�}t
|d|g��}|g|_|j|�}|j|�td�g|jd_|jd�d|_|j�|j!�d	g�y)
Nrrc�(���jd�yrrrs �rr"zBSupervisordTests.test_remove_process_group_event.<locals>.callbackkr#rr[r\r]r^Tr)r$rr%�ProcessGroupRemovedEventrrrrbrYr�rri�stopped_processesr.r#r'rGr(s       @r�test_remove_process_group_eventz0SupervisordTests.test_remove_process_group_evenths����%���	�����8�8�(�C��.���w��z�6�B��#�G�U�g�Y�G��)0�	��%��m�m�G�,���%�%�g�.�?K�D�?Q�>R��"�"�5�)�;��(�(��/������� �����Q�C� rc����ddlm}g��fd�}|j|j|�t	�}|j|�}d|_|j�|j�dg�y)Nrrc�(���jd�yrrrs �rr"zNSupervisordTests.test_runforever_emits_generic_startup_event.<locals>.callbackr#rTr)	r$rr%�SupervisorStateChangeEventrrYr#r'rG�r6rr"rXrsr!s     @r�+test_runforever_emits_generic_startup_eventz<SupervisordTests.test_runforever_emits_generic_startup_event|s`���%���	�����:�:�H�E��.���m�m�G�,�������� �����Q�C� rc����ddlm}g��fd�}|j|j|�t	�}d|_|j
|�}|j�|j�dg�y)Nrrc�(���jd�y)Nr�rrs �rr"zOSupervisordTests.test_runforever_emits_generic_specific_event.<locals>.callback�r#rTr�)	r$rr%�SupervisorRunningEventrr#rYr'rGr:s     @r�,test_runforever_emits_generic_specific_eventz=SupervisordTests.test_runforever_emits_generic_specific_event�s`���%���	�����6�6��A��.������m�m�G�,����� �����Q�C� rc��t�}d|_|j|�}|jt	|j
�d�|j
�|jt	|j
�d�y)NTr�)rr#rYrGrC�ticksr'r�s   r�test_runforever_calls_tickz+SupervisordTests.test_runforever_calls_tick�s`���.������m�m�G�,������[�.�.�/��3���� �����[�.�.�/��3rc�:�t�}dgddgf|j_|j|�}t	|dd�}t||g��}t
|�}td��}td�	�}tdt�
�}|||d�|_	d|i|_
d|_|j�|j|jd�|j|jd�|j|j d�|j|j"d�y)N���r[r\r^T)�readable)�writable)rI�error)rErFrG)r�pollerr�rYrrr	r
�OSError�dispatchersrir#r'rG�transitioned�read_event_handled�write_event_handled�
error_handled)	r6rXrsrqr�pgrouprHrIrJs	         r� test_runforever_poll_dispatchersz1SupervisordTests.test_runforever_poll_dispatchers�s����.��!"��a��V�������m�m�G�,���w��z�;��#�G�w�i�@��"�7�+��"�D�1��"�D�1����W�=�� (�H��>���&+�V�_��"������� �����,�,�d�3�����4�4�d�;�����5�5�t�<�����,�,�d�3rc�f�t�}dggf|j_|j|�}t	|dd�}t||g��}t
|�}ddlm}td|j��}d|i|_d|i|_d|_
|j|j|j�y�	NrEr[r\r^r��asyncore_25T�rHrJ�rrKr�rYrrr	�supervisor.medusarWr
�ExitNowrMrir#r,r'�r6rXrsrqrrR�asyncore�exitnows        r�2test_runforever_select_dispatcher_exitnow_via_readzCSupervisordTests.test_runforever_select_dispatcher_exitnow_via_read�s����.��!"��R�������m�m�G�,���w��z�;��#�G�w�i�@��"�7�+��=�!�4�x�7G�7G�H����[���&+�V�_��"�������(�*�*�K�,B�,B�Crc�f�t�}gdgf|j_|j|�}t	|dd�}t||g��}t
|�}ddlm}td|j��}d|i|_d|i|_d|_
|j|j|j�yrUrYr\s        r�3test_runforever_select_dispatcher_exitnow_via_writezDSupervisordTests.test_runforever_select_dispatcher_exitnow_via_write�s����.�� "�Q�C�������m�m�G�,���w��z�;��#�G�w�i�@��"�7�+��=�!�4�x�7G�7G�H����[���&+�V�_��"�������(�*�*�K�,B�,B�Crc�Z�t�}dggf|j_|j|�}t	|dd�}t||g��}t
|�}tdt��}d|i|_	d|i|_
d|_|j�|j|jd�y�NrEr[r\r^TrX�rrKr�rYrrr	r
�NotImplementedErrorrMrir#r'rGrQ�r6rXrsrqrrR�notimpls       r�7test_runforever_select_dispatcher_handle_error_via_readzHSupervisordTests.test_runforever_select_dispatcher_handle_error_via_read�s����.��!"��R�������m�m�G�,���w��z�;��#�G�w�i�@��"�7�+��!�4�7J�K����[���&+�V�_��"������� �����.�.��5rc�Z�t�}gdgf|j_|j|�}t	|dd�}t||g��}t
|�}tdt��}d|i|_	d|i|_
d|_|j�|j|jd�yrcrdrfs       r�8test_runforever_select_dispatcher_handle_error_via_writezISupervisordTests.test_runforever_select_dispatcher_handle_error_via_write�s����.�� "�Q�C�������m�m�G�,���w��z�;��#�G�w�i�@��"�7�+��!�4�7J�K����[���&+�V�_��"������� �����.�.��5rc����t�}|j|�}t|�}t|�}d|i|_t
j|j_g��fd�}ddl	m
}|j|j|�ddl
m}d|_|j!|j"|j$�|j'|j(�|j't+�d|j,��|j't+�d|j��|j't+�d|j.��|j't+�d|j��y)Nr[c�(���j|�yrWrrs �rr"zHSupervisordTests.test_runforever_stopping_emits_events.<locals>.callback�����
�H�H�U�OrrrrVTr)rrYrr	rirr�rXr�r$rr%r9rZrWr#r,r[r'r4�all_stopped�
isinstancer>�SupervisorStoppingEvent)	r6rXrsrrRr"rr]r!s	        @r�%test_runforever_stopping_emits_eventsz6SupervisordTests.test_runforever_stopping_emits_events�s����.���m�m�G�,��#�G�,��"�7�+��&+�V�_��"�#3�#<�#<���� ���	�%�����:�:�H�E�=�������(�*�*�K�,B�,B�C�����*�*�+����
�1�Q�4��)F�)F�G�H����
�1�Q�4��)J�)J�K�L����
�1�Q�4��)G�)G�H�I����
�1�Q�4��)J�)J�K�Lrc���t�}|j|�}t|dd�}t||g��}t	|�}g��fd�}d|i|_tj|j_	d|j_
ddlm}|j|j|j�|j!|j"d�y)Nr[r\r^c�(���jd�yrr�r!s�rr"z,SupervisordTests.test_exit.<locals>.callbackr#rTrrV)rrYrrr	rirr�rXr�r#rZrWr,r[r'rGrn)	r6rXrsrqrrRr"r]r!s	        @r�	test_exitzSupervisordTests.test_exit�s�����.���m�m�G�,���w��z�;��#�G�w�i�@��"�7�+����	�&+�V�_��"�#3�#>�#>���� �#'���� �=����(�*�*�K�,B�,B�C�����+�+�T�2rc���t�}|j|�}t|dd�}t|�}t	||g��}t|�}|g|_g��fd�}d|i|_tj|j_d|j_|j�|j|jd�y)Nr[r\r^c�(���jd�yrrrts�rr"z4SupervisordTests.test_exit_delayed.<locals>.callbackr#rTr)rrYrrrr	r0rirr�rXr�r#r'�assertNotEqual�lastshutdownreport)	r6rXrsrqr{rrRr"r!s	        @r�test_exit_delayedz"SupervisordTests.test_exit_delayeds�����.���m�m�G�,���w��z�;���w�'��#�G�w�i�@��"�7�+��&-�Y��"���	�&+�V�_��"�#3�#>�#>���� �#'���� ���� ����K�:�:�A�>rc�`�ddlm}|tj�}|j	|d�y)Nr)�getSupervisorStateDescriptionr�)�supervisor.statesr|rr�rG)r6r|r�s   r�"test_getSupervisorStateDescriptionz3SupervisordTests.test_getSupervisorStateDescriptions&��C�.�/?�/G�/G�H�������+rc����ddlm}g��fd�}|j|j|�t	�}|j|�}|j
d��|j|jdd�|j|jdd�|j|jdd�|jt��d�|j
d��|j|jdd�|j|jdd�|j|jdd�|jt��d	�|j�d
j|j�|j
d��|j|jdd�|j|jdd�|j|jdd�|jt��d�|j�d
j|j�|j
d
��|j|jdd�|j|jdd�|j|jdd�|jt��d�|j�d
j|j�y)Nrrc�(���j|�yrWrrs �rr"z,SupervisordTests.test_tick.<locals>.callback%rmr)�now��<irEr����=rAi)r$rr%�	TickEventrrY�tickrGrBrC�	__class__�
Tick5Event�Tick60Event�
Tick3600Eventr:s     @r�	test_tickzSupervisordTests.test_tick"sm���%���	�����)�)�8�4��.���m�m�G�,�����Q�������*�*�1�-�q�1�����*�*�2�.��2�����*�*�4�0�!�4�����Q���#����Q�������*�*�1�-�q�1�����*�*�2�.��2�����*�*�4�0�!�4�����Q���#�����2����&�*;�*;�<����R�� �����*�*�1�-�r�2�����*�*�2�.��3�����*�*�4�0�!�4�����Q���#�����2����&�*<�*<�=����T��"�����*�*�1�-�t�4�����*�*�2�.��5�����*�*�4�0�$�7�����Q���#�����2����&�*>�*>�?rN)*rIrJrKrRrUrYrtrxr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrr)r1r6r;r?rCrSr_rarhrjrqrurzr~r�rrrrNrNrs�����/�3�03�0
2�'�
2�A�"E�D�E�
G�3�8�:�*@�L�

&�,�,B,�Hx,�t$�$!�$$�*!�(
!�
!�4�4�&D�D�6�6�M�*3� ?�",�
"@rrNc�V�tjtjt�SrW)�unittest�
findTestCasesr-�modulesrIrrr�
test_suiter�Fs���!�!�#�+�+�h�"7�8�8r�__main__r�)�defaultTest)r�r�r�r-r&r/r1r}rr�supervisor.tests.baserrrrr	r
�supervisor.compatrrL�ImportError�TestCaser
rNr�rIrrrr�<module>r�s�����
�
�	��
�+�.�.�.�3�.�3�1�&���T)�h�'�'�T)�lR@�x�(�(�R@�h9��z���H�M�M�l�+���e���F��s�B�B)�(B)

Youez - 2016 - github.com/yon3zu
LinuXploit