403Webshell
Server IP : 46.62.235.243  /  Your IP : 216.73.216.217
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__/base.cpython-312.pyc
�

�1�c����dZdZddlZddlmZddlmZ	ddlmZmZm	Z		ddlmZGd�d�ZGd	�d
�Z
Gd�d�ZGd
�d�ZGd�d�ZGd�d�Zej$Gd�de��ZGd�d�Zd?d�Zd@d�ZGd�d�ZGd�d�ZGd�d�ZGd�d e�ZGd!�d"�ZGd#�d$�ZGd%�d&�ZGd'�d(�ZGd)�d*�Z Gd+�d,e �Z!ej$Gd-�d.e��Z"Gd/�d0e"�Z#Gd1�d2e�Z$Gd3�d4�Z%Gd5�d6�Z&Gd7�d8�Z'Gd9�d:�Z(d;�Z)d<�Z*d=�Z+d>�Z,y#e
$rddlmZmZm	Z	Y��LwxYw#e
$rddlZY��UwxYw)Ai�p�Dz%b %d %I:%M %p�N��Fault)�as_bytes)�Mock�patch�sentinelc�2�eZdZdZdZdZdZdZdZdZ	dZ
dZd�Zd�Z
d�Zd.d�Zd�Zd	�Zd
�Zd�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Z d�Z!d�Z"d.d�Z#d�Z$d�Z%d�Z&d�Z'd �Z(d!�Z)d"�Z*d#�Z+d$�Z,d%�Z-d&�Z.d'�Z/d(�Z0d)�Z1d*�Z2d/d+�Z3d,�Z4d-�Z5y)0�DummyOptions��Nc�B�d|_d|_d|_|j�|_d|_d|_d|_d|_i|_	g|_
d|_i|_d|_
d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_i|_d|_d|_d|_d	|_ d|_!i|_"i|_#g|_$d|_%d|_&d|_'d|_(d|_)d|_*d|_+d
|_,g|_-g|_.d|_/d|_0g|_1g|_2g|_3d|_4d|_5d|_6to|�|_8d|_9y)
N�
supervisorz/tmp���
z/tmp/logfileF��NNrz/foo/bar�zhttp://localhost:9001):�
identifier�childlogdir�uid�	getLogger�logger�backofflimit�logfile�	nocleanup�
strip_ansi�
pidhistory�process_group_configs�nodaemon�
socket_map�mood�
mustreopen�realizeargs�fds_cleaned_up�
rlimit_set�
setuid_called�httpservers_opened�signals_set�
daemonized�make_logger_messages�autochildlogdir_cleared�
cleaned_up�pidfile_written�	directory�waitpid_return�kills�_signal�parent_pipes_closed�child_pipes_closed�forkpid�pgrp_set�duped�written�
fds_closed�	_exitcode�
execve_called�
execv_args�
setuid_msg�privsdropped�
logs_reopened�write_accept�
tempfile_name�removed�existing�
openreturn�
readfd_result�parse_criticals�parse_warnings�parse_infos�	serverurl�changed_directory�umaskset�DummyPoller�poller�silent��selfs �7/usr/lib/python3/dist-packages/supervisor/tests/base.py�__init__zDummyOptions.__init__#s���&���!�������n�n�&������%������������%'��"���
������	�������#������"���"'��� ������$(��!�',��$����$������(�����
����#'�� �"&��������
���
����������"��������� ���"��� ���'��������
�������!��� ������0���!&�����
�!�$�'������c�L�t�}t�g|_||f|_|S�N)�DummyLogger�handlers�args)rOrW�kwrs    rPrzDummyOptions.getLogger]s$�����&�=�/����B�h����
rRc� �||_||_yrT)r#�	realizekw)rOrWrXs   rP�realizezDummyOptions.realizecs�������rRc��yrT�)rO�do_usages  rP�process_configzDummyOptions.process_configg���rRc��d|_y�NT)r$rNs rP�cleanup_fdszDummyOptions.cleanup_fdsjs
��"��rRc�H�d|_|jjd�y)NT�rlimits_set)rerG�appendrNs rP�set_rlimits_or_exitz DummyOptions.set_rlimits_or_exitms����������
�.rRc�H�d|_|jjd�y)NTr&)r&rErfrNs rP�set_uid_or_exitzDummyOptions.set_uid_or_exitqs��!������#�#�O�4rRc��d|_yrb)r')rO�supervisords  rP�openhttpserverszDummyOptions.openhttpserversu�
��"&��rRc��d|_yrb)r)rNs rP�	daemonizezDummyOptions.daemonizex�	����rRc��d|_yrb)r(rNs rP�
setsignalszDummyOptions.setsignals{�
����rRc��|jSrT)r1rNs rP�
get_signalzDummyOptions.get_signal~����|�|�rRc��|jSrT)r rNs rP�get_socket_mapzDummyOptions.get_socket_map�s�����rRc��yrTr]rNs rP�make_loggerzDummyOptions.make_logger�r`rRc��d|_yrb)r+rNs rP�clear_autochildlogdirz"DummyOptions.clear_autochildlogdir�s
��'+��$rRc��|jSrT�r@)rO�ignoreds  rP�get_autochildlog_namez"DummyOptions.get_autochildlog_name�����!�!�!rRc��d|_yrb)r,rNs rP�cleanupzDummyOptions.cleanup�rprRc��d|_yrb)r-rNs rP�
write_pidfilezDummyOptions.write_pidfile�s
��#��rRc��|jSrT)r/rNs rP�waitpidzDummyOptions.waitpid�s���"�"�"rRc�R�|j�|j�||j|<yrT)�kill_exceptionr0)rO�pid�sigs   rP�killzDummyOptions.kill�s'�����*��%�%�%���
�
�3�rRc�,�ddl}|j|�S�Nr)�os�stat)rO�filenamer�s   rPr�zDummyOptions.stat�s����w�w�x� � rRc�
�gd�S�N)z/binz/usr/binz/usr/local/binr]rNs rP�get_pathzDummyOptions.get_path����5�5rRc�*�ddl}|j�Sr�)r��getpid)rOr�s  rP�get_pidzDummyOptions.get_pid�s����y�y�{�rRc�*�|dk(rddlm}|d��y)Nz
/bad/filenamer)�NotFoundzbad filename)�supervisor.optionsr�)rOr��argv�str�s     rP�check_execv_argszDummyOptions.check_execv_args�s����&�3��>�*�*�'rRc�x�|j�|j�ddddd�}|r
d\|d<|d<|Sd	\|d<|d<|S)
N��r�)�child_stdin�stdin�stdout�child_stdout)���stderr�child_stderrr)�make_pipes_exception)rOr��pipess   rP�
make_pipeszDummyOptions.make_pipes�s`���$�$�0��+�+�+� !�A��A�N���5;�2�E�(�O�U�>�2���6@�2�E�(�O�U�>�2��rRc���|j�|j�|jr||j}|jj|d�}||z
}||j|<t	|�S�Nr)�write_exceptionr?r7�
setdefault�len)rO�fd�chars�datas    rP�writezDummyOptions.write�sj�����+��&�&�&�����$�+�+�,�E��|�|�&�&�r�2�.����
������R���5�z�rRc�J�|j�|j�|jSrT)�fork_exceptionr4rNs rP�forkzDummyOptions.fork�s$�����*��%�%�%��|�|�rRc�:�|jj|�yrT)r8rf�rOr�s  rP�close_fdzDummyOptions.close_fd�s�������r�"rRc��||_yrT)r2�rOr�s  rP�close_parent_pipeszDummyOptions.close_parent_pipes�s
��#(�� rRc��||_yrT)r3r�s  rP�close_child_pipeszDummyOptions.close_child_pipes�s
��"'��rRc��d|_yrb)r5rNs rP�setpgrpzDummyOptions.setpgrp��	����
rRc�"�||j|<yrT)r6)rO�frm�tos   rP�dup2zDummyOptions.dup2�s����
�
�3�rRc��||_yrT)r9�rO�codes  rP�_exitzDummyOptions._exit�s	����rRc�b�d|_|j�|j�||f|_||_yrb)r:�execv_exceptionr;�execv_environment)rOr�r��environments    rP�execvezDummyOptions.execve�s6��!������+��&�&�&�#�T�*���!,��rRc�B�|jr|jS||_yrT)r<r=)rOrs  rP�drop_privilegeszDummyOptions.drop_privileges�s���?�?��?�?�"���rRc��|jSrT)rDr�s  rP�readfdzDummyOptions.readfd�r�rRc��d|_yrb�r>rNs rP�
reopenlogszDummyOptions.reopenlogs��
��!��rRc��|jSrTr~)rO�prefix�suffix�dirs    rP�
mktempfilezDummyOptions.mktempfile�r�rRc�j�|j�|j�|jj|�yrT)�remove_exceptionrArf�rO�paths  rP�removezDummyOptions.remove�s,��� � �,��'�'�'������D�!rRc�"�||jvryy)NTF)rBr�s  rP�existszDummyOptions.exists�s���4�=�=� ��rRc�J�|jr|jSt||�SrT)rC�open)rO�name�modes   rPr�zDummyOptions.open�s ���?�?��?�?�"��D�$��rRc�B�|j�|j�d|_yrb)�chdir_exceptionrI)rOr�s  rP�chdirzDummyOptions.chdir�s"�����+��&�&�&�!%��rRc��||_yrT)rJ)rO�masks  rP�setumaskzDummyOptions.setumask�r�rR)T)�r)6�__name__�
__module__�__qualname__�loglevel�minfdsr�r�r�r�r�r�r�rQrr[r_rcrgrirlrorrrurxrzr|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]rRrPr
r
s���H�
�F��O��N��O��N������O�8�t��
�#�/�5�'�� ���
�,�"��$�#��
!�6��+�
���
#�)�(����-� �
"�"�"�"�
�
 �
&�
rRr
c�^�eZdZdZd�Zd�ZexZxZxZxZ	xZ
Zd�Zd�Z
d�Zd�Zd�Zd	�Zd
�Zy)rUNc�<�d|_d|_d|_g|_y�NF)�reopenedrA�closedr�rNs rPrQzDummyLogger.__init__s����
���������	rRc�H�|r||z}|jj|�yrT�r�rf)rO�msgrXs   rP�infozDummyLogger.info� ��
���(�C��	�	����rRc�H�|r||z}|jj|�yrTr�)rO�levelr�rXs    rP�logzDummyLogger.logr�rRc�$�|j�yrT)�close)rO�handlers  rP�
addHandlerzDummyLogger.addHandlers���
�
�rRc��d|_yrb)r�rNs rP�reopenzDummyLogger.reopenr�rRc��d|_yrb�r�rNs rPrzDummyLogger.close�	����rRc��d|_yrb)rArNs rPr�zDummyLogger.remove�	����rRc��d|_yrb)�flushedrNs rP�flushzDummyLogger.flushr
rRc�8�dj|j�Sr�)�joinr�rNs rP�getvaluezDummyLogger.getvalue!s���w�w�t�y�y�!�!rR)r�r�r�rrQr��warn�debug�critical�trace�error�blatherrrrrr�rrr]rRrPrUrUsT���E���9=�<�D�<�5�<�8�<�e�<�e�g��
�����"rRrUc��eZdZdd�Zd�Zy)�DummySupervisorNc���|�t�|_n||_|�"ddlm}|j|j_n||j_|�i|_y||_y)Nr)�SupervisorStates)r
�options�supervisor.supervisordr�RUNNINGr!�process_groups)rOr�stater!rs     rPrQzDummySupervisor.__init__%sS���?�'�>�D�L�"�D�L��=�?� 0� 8� 8�D�L�L�� %�D�L�L���!�"$�D��"0�D�rRc�.�|jjSrT)rr!rNs rP�	get_statezDummySupervisor.get_state4s���|�|� � � rR)NNN)r�r�r�rQr$r]rRrPrr$s��
1�!rRrc�D�eZdZdZdZdZdZdZd�Zd�Z	d�Z
d�Zd�Zd�Z
y)	�DummySocketFNc��||_yrT�r�r�s  rPrQzDummySocket.__init__>s	����rRc��|jSrTr(rNs rP�filenozDummySocket.filenoAs���w�w�rRc� �d|_||_yrb)�bind_called�	bind_addr)rO�addrs  rP�bindzDummySocket.bindDs�������rRc� �d|_||_yrb)�
listen_called�listen_backlog)rO�backlogs  rP�listenzDummySocket.listenHs��!���%��rRc��d|_yrb)�close_calledrNs rPrzDummySocket.closeL�
�� ��rRc��y)Nzdummy socketr]rNs rP�__str__zDummySocket.__str__Os��rR)r�r�r�r,r-r1r2r6rQr*r/r4rr9r]rRrPr&r&7s9���K��I��M��N��L����&�!�rRr&c�2�eZdZdd�Zd�Zd�Zd�Zd�Zd�Zy)	�DummySocketConfigc�.�||_||_d|_y)Nzunix:///sock)r�r3�url)rOr�r3s   rPrQzDummySocketConfig.__init__Ss��������!��rRc��y)Nz
dummy addrr]rNs rPr.zDummySocketConfig.addrXs��rRc�4�|j|jk(SrTr(�rO�others  rP�__eq__zDummySocketConfig.__eq__[s���w�w�%�(�(�"�"rRc�&�|j|�SrT)rBr@s  rP�__ne__zDummySocketConfig.__ne__^s���;�;�u�%�%�%rRc��|jSrT)r3rNs rP�get_backlogzDummySocketConfig.get_backlogarvrRc�,�t|j�SrT)r&r�rNs rP�create_and_bindz!DummySocketConfig.create_and_bindds���4�7�7�#�#rRN)�)	r�r�r�rQr.rBrDrFrHr]rRrPr;r;Rs ��"�
�#�&��$rRr;c��eZdZd�Zd�Zd�Zy)�DummySocketManagerc��||_yrT��_config)rO�config�kwargss   rPrQzDummySocketManager.__init__hs	����rRc��|jSrTrMrNs rPrOzDummySocketManager.configkrvrRc�@�t|jj�SrT)r&rNr�rNs rP�
get_socketzDummySocketManager.get_socketns���4�<�<�?�?�+�+rRN)r�r�r�rQrOrSr]rRrPrKrKgs����,rRrKc���eZdZdZdZdZdZdZdZdZ	dZ
dZdZdZ
dZdZdZdZdZdZdZdZdZdZdZdZdd�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)d�Z*d�Z+d�Z,d�Z-d�Z.y)�DummyProcessNrFrc���||_d|_d|_d|_d|_d|_|�ddlm}|j}||_	d|_
d|_d|_td�|_td�|_td�|_td�|_td�|_i|_i|_i|_d|_d|_d|_d|_d|_d|_y)NFTr��
ProcessStatesr)rO�logsremoved�stop_called�stop_report_called�backoff_secs�spawned�supervisor.processrXr r"�error_at_clear�killed_with�drainedr�
stdout_buffer�
stderr_buffer�
stdout_logged�
stderr_logged�stdin_bufferr��rpipes�dispatchers�finishedr>�execv_arg_exception�input_fd_drained�output_fd_drained�transitioned)rOrOr"rXs    rPrQzDummyProcess.__init__�s������ ��� ���"&��� �������=�8�!�)�)�E���
�#���������%�b�\���%�b�\���%�b�\���%�b�\���$�R�L�����
���������
�"���#'�� � $���!%���!��rRc��d|_yrbr�rNs rPr�zDummyProcess.reopenlogs�r�rRc�@�|jrtd��d|_y)N�whateverT)r_�IOErrorrYrNs rP�
removelogszDummyProcess.removelogs�s������*�%�%���rRc��|jSrT)r"rNs rPr$zDummyProcess.get_state�s���z�z�rRc�N�d|_d|_ddlm}|j|_y)NTFrrW)rZ�killingr^rX�STOPPEDr"�rOrXs  rP�stopzDummyProcess.stop�s!��������4�"�*�*��
rRc��d|_yrb)r[rNs rP�stop_reportzDummyProcess.stop_report�rmrRc��||_yrT)r`�rO�signals  rPr�zDummyProcess.kill��
��!��rRc��||_yrT)�sent_signalr|s  rPr}zDummyProcess.signal�r~rRc�@�d|_ddlm}|j|_y)NTrrW)r]r^rXr r"rws  rP�spawnzDummyProcess.spawn�s�����4�"�*�*��
rRc��d|_yrb)rarNs rP�drainzDummyProcess.drain�r
rRc��gSrTr]rNs rP�readable_fdszDummyProcess.readable_fds�s���	rRc��|xj|jz
c_d|_|xj|jz
c_d|_yr�)rdrbrercrNs rP�
record_outputzDummyProcess.record_output�s@�����d�0�0�0��������d�0�0�0����rRc��||f|_yrT)ri)rOr��stss   rP�finishzDummyProcess.finish�s
���S���
rRc�2�ddlm}|j|_y)NrrW)r^rX�FATALr"rws  rP�give_upzDummyProcess.give_up�s��4�"�(�(��
rRc��|jr|jd��ddl}|j|jj�}|d}||fS)Nrpr)rj�shlex�splitrO�command)rOr��commandargs�programs    rP�get_execv_argszDummyProcess.get_execv_args�sK���#�#��*�*�:�6�6���k�k�$�+�+�"5�"5�6���a�.����#�#rRc��||_yrT)rlr�s  rP�drain_output_fdzDummyProcess.drain_output_fd�s
��!#��rRc��||_yrT)rkr�s  rP�drain_input_fdzDummyProcess.drain_input_fd�s
�� "��rRc�^�|j�|j�|xj|z
c_yrT)r�rf)rOr�s  rPr�zDummyProcess.write�s+�����+��&�&�&����U�"�rRc��d|_yrb�rmrNs rP�
transitionzDummyProcess.transition�r7rRc�\�|jj|jjk(SrT�rO�priorityr@s  rPrBzDummyProcess.__eq__��!���{�{�#�#�u�|�|�'<�'<�<�<rRc�\�|jj|jjkSrTr�r@s  rP�__lt__zDummyProcess.__lt__��!���{�{�#�#�e�l�l�&;�&;�;�;rRrT)/r�r�r�r�r��	laststart�laststop�delay�administrative_stop�system_stopru�backoff�
waitstatus�
exitstatusr�rgrhrdre�spawnerrrbrcrf�listener_state�groupr�rQr�rrr$rxrzr�r}r�r�r�r�r�r�r�r�r�r�r�rBr�r]rRrPrUrUqs����O��C��I��H�
�E����K��G��G��J��J��E�
�F��K��M��M��H��M��M��L��N��E��K�"�:"� �
�+�'�"�"�+�
�� �!�)�$�$�#�#�
!�=�<rRrUc�J�eZdZ														dd�Zd�Zd�Zdd�Zd�Zy)	�DummyPConfigNc ���||_||_||_||_||_||_|	|_|
|_||_||_	|
|_
||_||_||_
||_||_||_||_||_||_||_||_|�ddl} | j.}||_||_||_||_||_||_||_||_d|_ ||_!y)NrF)"rr�r�r��	autostart�autorestart�	startsecs�startretriesr�stdout_logfile�stdout_capture_maxbytes�stdout_events_enabled�stdout_logfile_backups�stdout_logfile_maxbytes�
stdout_syslog�stderr_logfile�stderr_capture_maxbytes�stderr_events_enabled�stderr_logfile_backups�stderr_logfile_maxbytes�
stderr_syslog�redirect_stderrr}�SIGTERM�
stopsignal�stopwaitsecs�stopasgroup�killasgroup�	exitcodesr�r.�umask�autochildlogs_createdrH)!rOrr�r�r.r�r�r�r�r�r�rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rHr}s!                                 rPrQzDummyPConfig.__init__�s
�������	���� ��
�"���&���"���(������,���'>��$�%:��"�&<��#�'>��$�*���,���'>��$�%:��"�&<��#�'>��$�*���.���������J�$���(���&���&���"���&���"�����
�%*��"�"��rRc�
�gd�Sr�r]rNs rPr�zDummyPConfig.get_path-r�rRc��d|_yrb)r�rNs rP�create_autochildlogsz!DummyPConfig.create_autochildlogs0s
��%)��"rRc�*�t|�}||_|SrT)rUr�)rOr��processs   rP�make_processzDummyPConfig.make_process3s���t�$����
��rRc���|j}|jj|�}|d|d|d}}}i}|�td��||<|�td��||<|�td��||<||fS)Nr�r�r�T)�readable)�writable)r�rr��DummyDispatcher)rO�proc�
use_stderrr��	stdout_fd�	stderr_fd�stdin_fdrhs        rP�make_dispatcherszDummyPConfig.make_dispatchers8s����-�-�-�
����'�'�
�3��(-�h���h��(-�g��%�)�	���� �%4�d�%C�K�	�"�� �%4�d�%C�K�	�"���$3�T�$B�K��!��E�!�!rR)NNrTTrrNNrFrrFNrFrrFFNrFF�rNNrT)r�r�r�rQr�r�r�r�r]rRrPr�r��sF��EI�)-�>A�HI�',�CD�$�>?�',�CD�$�!&�RW�=A�0#�d6�*��
"rRr�c���ddl}ddl}ddl}|�i}t|�j	�}|j
j
|�d}|j|d<|j�D](}|jd|j�z||�}�*|j|d��5}|j}	|j|�ddd�|j	d�|	S#1swY�xYw)Nrr�PYTHONz<<%s>>F)r��deletei�)r��sys�tempfiler��readr�r��
executable�keys�replace�upper�NamedTemporaryFiler�r��chmod)
�file�
substitutionsr�r�r�r��last�key�f�tmpnams
          rP�makeExecutabler�Fs���
������
���:�?�?��D�
�7�7�=�=���q�!�D�!�n�n�M�(���!�!�#�H���|�|�H�s�y�y�{�2�M�#�4F�G��H�
�	$�	$�D��	$�	?��1�����	����
���H�H�V�U���M�	��s�%C�C(c���ddl}|jjt�}|s%t	|jj|d��St	|jj|d��S)Nrzfixtures/spew.pyzfixtures/unkillable_spew.py)r�r��dirname�__file__r�r)�
unkillabler��heres   rP�makeSpewr�ZsP��
�
�7�7�?�?�8�$�D���b�g�g�l�l�4�1C�D�E�E��"�'�'�,�,�t�-J�K�L�LrRc��eZdZd�Zd�Zy)�DummyMedusaServerLoggerc��g|_yrT)�loggedrNs rPrQz DummyMedusaServerLogger.__init__bs	����rRc�>�|jj||f�yrT)r�rf)rO�categoryr�s   rPrzDummyMedusaServerLogger.logds�������H�c�?�+rRN)r�r�r�rQrr]rRrPr�r�as���,rRr�c��eZdZd�Zy)�DummyMedusaServerc�"�t�|_yrT)r�rrNs rPrQzDummyMedusaServer.__init__hs��-�/��rRN�r�r�r�rQr]rRrPr�r�gs��0rRr�c�$�eZdZd�Zd�Zd�Zd�Zy)�DummyMedusaChannelc�0�t�|_d|_yrT)r��server�producerrNs rPrQzDummyMedusaChannel.__init__ls��'�)�����
rRc��||_yrT)r�rOrs  rP�push_with_producerz%DummyMedusaChannel.push_with_producerps	�� ��
rRc��yrTr]rNs rP�close_when_donez"DummyMedusaChannel.close_when_donesr`rRc��yrTr])rO�
terminators  rP�set_terminatorz!DummyMedusaChannel.set_terminatorvr`rRN)r�r�r�rQrr	rr]rRrPrrks���!�
�
rRrc�r�eZdZdZdZdZdZdd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zy)�DummyRequest�GETNFz1.0c��||||f|_g|_i|_g|_g|_t�|_|�i|_y||_yrT)rW�	producers�headers�header�outgoingr�channel�env)rOr��params�query�fragmentrs      rPrQzDummyRequest.__init__~sK���&�%��1��	������������
�)�+����;��D�H��D�HrRc��|jSrT)rWrNs rP�	split_urizDummyRequest.split_uri�s���y�y�rRc��||_yrT)�_errorr�s  rPrzDummyRequest.error�rrRc�:�|jj|�yrT)rrfrs  rP�pushzDummyRequest.push�s�������h�'rRc�"�||j|<yrT�r)rOr�values   rP�__setitem__zDummyRequest.__setitem__�s��$����V�rRc� �|j|SrTr!�rOrs  rP�__getitem__zDummyRequest.__getitem__�s���|�|�F�#�#rRc��|j|=yrTr!r%s  rP�__delitem__zDummyRequest.__delitem__�s���L�L�� rRc��||jvSrTr!r%s  rP�has_keyzDummyRequest.has_key�s������%�%rRc��||jvSrTr!)rO�items  rP�__contains__zDummyRequest.__contains__�s���t�|�|�#�#rRc��d|_yrb)�_donerNs rP�donezDummyRequest.done�s	����
rRc��yr�r]rNs rP�build_reply_headerzDummyRequest.build_reply_header����rRc��yrTr])rO�argrXs   rPrzDummyRequest.log�r`rRc��|jSrT)rrNs rP�cgi_environmentzDummyRequest.cgi_environment�s���x�x�rRc��y)Nzhttp://example.comr]rNs rP�get_server_urlzDummyRequest.get_server_url�s��#rRrT)r�r�r�r�rr/�versionrQrrrr#r&r(r*r-r0r2rr7r9r]rRrPrrys\���G�
�F��E��G�
���(�%�$�!�&�$���
��$rRrc��eZdZd�Zy)�DummyRPCInterfaceFactoryc� �||_||_yrT)rkrO)rOrkrOs   rPrQz!DummyRPCInterfaceFactory.__init__�s��&�����rRNr�r]rRrPr<r<�s��rRr<c��eZdZd�Zy)�DummyRPCServerc�@�t�|_t�|_yrT)�DummySupervisorRPCNamespacer�DummySystemRPCNamespace�systemrNs rPrQzDummyRPCServer.__init__�s��5�7���-�/��rRNr�r]rRrPr?r?�s��0rRr?c��eZdZy)rBN)r�r�r�r]rRrPrBrB�s��rRrBc
��eZdZdZdZdZdZddlmZdddejde
dz
dd	e
d
d�
ddd
ejde
dz
e
dz
de
dd�
dddejde
dz
e
dz
d	e
dd�
gZ
d�ZeZd�Zd�Zd�ZeZd�Zd�Zd�Zd�Zd �Zd!�Zd"�Zd#�Zd$�Zd%�Zd&�Zd'�Zd(�Z d)�Z!d*�Z"e"Z#e"Z$e"Z%d+�Z&d,�Z'd-�Z(d.�Z)d/�Z*d0�Z+d1�Z,d2�Z-y3)4rATFrrW�foo�r �drzfoo description)
r�r�r�r"�	statename�startrxr��now�description�bar�r��2�screwedzbar description�baz_01�baz�
rv�zbaz descriptionc��y)Nz3.0r]rNs rP�
getAPIVersionz)DummySupervisorRPCNamespace.getAPIVersion�s��rRc��y)N�*r]rNs rP�getPIDz"DummySupervisorRPCNamespace.getPID�r3rRc��ddlm}|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jjd��|dzdz}||dS)Nr��xmlrpc�BAD_NAME�FAILED�NO_FILEz line
r)rr\r�Faultsr]r^r_)rOrr��offset�lengthr\�as       rP�	_read_logz%DummySupervisorRPCNamespace._read_log�s}��%��:����
�
�.�.�
�;�;�
�X�
���
�
�,�,�h�7�7�
�Y�
���
�
�-�-�y�9�9�
�y�
 �B�&�����z�rRc�*�|jd|||�S)Nr��rd�rOr�rarbs    rP�readProcessStdoutLogz0DummySupervisorRPCNamespace.readProcessStdoutLog����~�~�h��f�f�=�=rRc�*�|jd|||�S)Nr�rfrgs    rP�readProcessStderrLogz0DummySupervisorRPCNamespace.readProcessStderrLogrirRc��|jSrT)�all_process_inforNs rP�getAllProcessInfoz-DummySupervisorRPCNamespace.getAllProcessInfos���$�$�$rRc�,�ddlm}|jD]}|d|k(s�|}|cS|dk(r t|jj
d��|dk(r t|jjd��|dk(r t|jjd��y)Nrr[r�r]r^r_)rr\rmrr`r]r^r_)rOr�r\�ir�s     rP�getProcessInfoz*DummySupervisorRPCNamespace.getProcessInfos���%��&�&�	�A���y�$������	��:����
�
�.�.�
�;�;��8����
�
�,�,�h�7�7��9����
�
�-�-�y�9�9�rRc��ddlm}|dk(r t|jjd��|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jjd��|dk(r t|jjd��|dk(r t|jjd��|d	k(r t|jjd	��y
)Nrr[�BAD_NAME:BAD_NAMEr]r_�NOT_EXECUTABLE�ALREADY_STARTED�SPAWN_ERROR�ABNORMAL_TERMINATIONT)
rr\rr`r]r_rtrurvrw�rOr�r\s   rP�startProcessz(DummySupervisorRPCNamespace.startProcesss���%��&�&���
�
�.�.�0C�D�D��:����
�
�.�.�
�;�;��9����
�
�-�-�y�9�9��#�#���
�
�4�4�6F�G�G��$�$���
�
�5�5�7H�I�I��=� ���
�
�1�1�=�A�A��)�)���
�
�:�:�.�0�
0�rRc���ddlm}ddlm}|dk(r||jj
d��dd|jjdd�d	d|jjdd�gS�
Nrr[rr]�foo_00rF�OK�r�r��statusrL�foo_01�rr\�supervisor.compatrr`r]�SUCCESS�rOr�r\rs    rP�startProcessGroupz-DummySupervisorRPCNamespace.startProcessGroup+�g��%�+��:����
�
�.�.�
�;�;��e��}�}�,�,� �
"��e��m�m�+�+� �
"�	�	rRc��ddlm}dd|jjdd�dd|jjdd�dd|jjd	d�gS)
Nrr[rFr}r~�foo2�failed�failed_grouprv)rr\r`r�rv�rOr\s  rP�startAllProcessesz-DummySupervisorRPCNamespace.startAllProcesses9sa��%��5��}�}�,�,� �
"��F��m�m�+�+� �
"��n��m�m�/�/�(�
*�
�
	rRc���ddlm}ddlm}|dk(r||jj
d��dd|jjdd�d	d|jjdd�gSr{r�r�s    rP�stopProcessGroupz,DummySupervisorRPCNamespace.stopProcessGroupGr�rRc�8�ddlm}|dk(r t|jjd��|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jjd��y)Nrr[rsr]�NOT_RUNNINGr^T)rr\rr`r]r�r^rxs   rP�stopProcessz'DummySupervisorRPCNamespace.stopProcessUs���%��&�&���
�
�.�.�0C�D�D��:����
�
�.�.�
�;�;��=� ���
�
�1�1�=�A�A��8����
�
�,�,�h�7�7�rRc��ddlm}dd|jjdd�dd|jjdd�dd|jjd	d�gS�
Nrr[rFr}r~r�r�r�r^�rr\r`r�r]r�s  rP�stopAllProcessesz,DummySupervisorRPCNamespace.stopAllProcessesbs_��%��%��}�}�,�,� �
"��F��m�m�+�+�4�
A��n��m�m�,�,�#�
%�
	�		rRc�v�|jrd|_yddlm}t	|j
jd���NTrr[r)�_restartable�
_restartedrr\rr`�SHUTDOWN_STATEr�s  rP�restartz#DummySupervisorRPCNamespace.restartos/�����"�D�O��%��F�M�M�0�0�"�5�5rRc�v�|jrd|_yddlm}t	|j
jd��r�)r��	_shutdownrr\rr`r�r�s  rP�shutdownz$DummySupervisorRPCNamespace.shutdownvs/�����!�D�N��%��F�M�M�0�0�"�5�5rRc��dgdgdgggS)N�added�changedrAr]rNs rP�reloadConfigz(DummySupervisorRPCNamespace.reloadConfig}s����Y�K�)��5�6�6rRc��ddlm}|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jjd��|dk(r t|jjd��t|d�r|jj|�y|g|_	y)	Nrr[�
ALREADY_ADDEDrr]r^r��	processes)rr\rr`r�r]r^r��hasattrr�rfrxs   rP�addProcessGroupz+DummySupervisorRPCNamespace.addProcessGroup�s���%��?�"���
�
�3�3�R�8�8��:����
�
�.�.��3�3��8����
�
�,�,�b�1�1��#�#���
�
�4�4�b�9�9��4��%��N�N�!�!�$�'�"�V�D�NrRc�$�ddlm}|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jjd��|jj|�y)Nrr[�
STILL_RUNNINGrr]r^)	rr\rr`r�r]r^r�r�rxs   rP�removeProcessGroupz.DummySupervisorRPCNamespace.removeProcessGroup�st��%��?�"���
�
�3�3�R�8�8��:����
�
�.�.��3�3��8����
�
�,�,�b�1�1������d�#rRc�Z�ddlm}|dk(r t|jjd��y)Nrr[r]T)rr\rr`r]rxs   rP�clearProcessStdoutLogz1DummySupervisorRPCNamespace.clearProcessStdoutLog�s'��%��:����
�
�.�.�
�;�;�rRc��ddlm}dd|jjdd�dd|jjdd�dd|jjd	d�gSr�)rr\r`r�r^r�s  rP�clearAllProcessLogsz/DummySupervisorRPCNamespace.clearAllProcessLogs�sd��%����m�m�+�+� �
"����m�m�+�+� �
"��#��m�m�*�*�#�
%�
�
	rRc��td��)Nr��
ValueErrorrNs rP�
raiseErrorz&DummySupervisorRPCNamespace.raiseError�s
����!�!rRc�
�ddiS)Nr�r]rNs rP�getXmlRpcUnmarshallablez3DummySupervisorRPCNamespace.getXmlRpcUnmarshallable�s
�� �$�'�'rRc��y)N�3000r]rNs rP�getSupervisorVersionz0DummySupervisorRPCNamespace.getSupervisorVersion�s��rRc�H�|jrt|jd��y)Nr�mainlogdata)�_readlog_errorr)rO�whenceras   rP�readLogz#DummySupervisorRPCNamespace.readLog�s!�������+�+�R�0�0�rRc���ddlm}|dk(r t|jjd��dd|jj
dd�dd|jj
dd�gS)	Nrr[r]r|rFr}r~r�)rr\rr`r]r��rOr�r}r\s    rP�signalProcessGroupz.DummySupervisorRPCNamespace.signalProcessGroup�sf��%��:����
�
�.�.�
�;�;����}�}�,�,� �
"����m�m�+�+� �
"�	�		rRc��ddlm}|dk(r t|jjd��|dk(r t|jj
d��|dk(r t|jj
d��|dk(r t|jjd��|dk(r t|jjd��y)	Nrr[�
BAD_SIGNALrsr]r�r^T)rr\rr`r�r]r�r^r�s    rP�
signalProcessz)DummySupervisorRPCNamespace.signalProcess�s���%��\�!���
�
�0�0�,�?�?��&�&���
�
�.�.�0C�D�D��:����
�
�.�.�
�;�;��=� ���
�
�1�1�=�A�A��8����
�
�,�,�h�7�7�rRc��ddlm}dd|jjdd�dd|jjdd�dd|jjd	d�gSr�r�)rOr}r\s   rP�signalAllProcessesz.DummySupervisorRPCNamespace.signalAllProcesses�sd��%����}�}�,�,� �
"����m�m�+�+� �
"��#��m�m�,�,�#�
%�
�
	rRN).r�r�r�r�r�r�r�r^rXr �_NOWr�rvrmrV�
getVersionrYrdrh�readProcessLogrkrnrqryr�r�r�r�r�r�r�r�r�r�r��clearProcessLog�clearProcessStderrLog�clearProcessLogsr�r�r�r�r�r�r�r�r]rRrPrArA�s_���L��J��I��N�1�����%�%���s�
����'�	
�����#�#���s�
��b�y���'�	
�����%�%���s�
��b�y���'�	
�3%
��N��J��	�>�)�N�>�%�:��&�����6�6�7�
$�$��,�O�1��,���""�(���

�
�rRrAc�&�eZdZdd�Zd�Zd�Zd�Zy)�DummyPGroupConfigNc�n�||_||_||_|�g}||_d|_g|_d|_y)NFr)rr�r��process_configs�after_setuid_called�pool_events�buffer_size)rOrr�r��pconfigss     rPrQzDummyPGroupConfig.__init__�sB�������	� ��
����H�'���#(�� ������rRc��d|_yrb)r�rNs rP�after_setuidzDummyPGroupConfig.after_setuid�s
��#'�� rRc��t|�SrT)�DummyProcessGrouprNs rP�
make_groupzDummyPGroupConfig.make_groups
�� ��&�&rRc�T�d|j�dt|��d|j�d�S)N�<z
 instance at z named �>)�	__class__�idr�rNs rP�__repr__zDummyPGroupConfig.__repr__s ��15����D��15���<�	<rR)rprN)r�r�r�rQr�r�r�r]rRrPr�r��s��	�(�'�<rRr�c�(�eZdZddded�fd�Zy)�DummyFCGIGroupConfigrprNrc�D�tj|||||�||_yrT)r�rQ�
socket_config)rOrr�r�r�r�s      rPrQzDummyFCGIGroupConfig.__init__s ���"�"�4��$��(�K�*��rR)r�r�r�r;rQr]rRrPr�r�s��%/�#��\m�no�\p�+rRr�c�B�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zy
)r�c�X�||_d|_d|_i|_g|_d|_yr�)rOrm�all_stoppedrh�unstopped_processes�before_remove_called�rOrOs  rPrQzDummyProcessGroup.__init__s1�����!��� ������#%�� �$)��!rRc��d|_yrbr�rNs rPr�zDummyProcessGroup.transitionr7rRc��d|_yrb)r�rNs rP�
before_removezDummyProcessGroup.before_removes
��$(��!rRc��d|_yrb)r�rNs rP�stop_allzDummyProcessGroup.stop_allrsrRc��|jSrT)r�rNs rP�get_unstopped_processesz)DummyProcessGroup.get_unstopped_processess���'�'�'rRc��|jSrT)rhrNs rP�get_dispatchersz!DummyProcessGroup.get_dispatchers"s�����rRc�\�|jj|jjkSrTr�r@s  rPr�zDummyProcessGroup.__lt__%r�rRc�\�|jj|jjk(SrTr�r@s  rPrBzDummyProcessGroup.__eq__(r�rRc��d|_yrbr�rNs rPr�zDummyProcessGroup.reopenlogs+r�rRN)r�r�r�rQr�r�r�r�r�r�rBr�r]rRrPr�r�s/��*�!�)� �(� �<�=�"rRr�c��eZdZd�Zy)�DummyFCGIProcessGroupc�d�tj||�t|j�|_yrT)r�rQrKr��socket_managerr�s  rPrQzDummyFCGIProcessGroup.__init__0s%���"�"�4��0�0��1E�1E�F��rRNr�r]rRrPr�r�.s��GrRr�c� �eZdZd�Zdd�Zd�Zy)�PopulatedDummySupervisorc���tj||�i|_i}||_t	|||��}t|�}||j|<|D]}t
|�}|||j<�||_y)N)r�)	rrQr!�
group_namer�r�rUr�r�)	rOrr�r�r��gconfig�pgroup�pconfigr�s	         rPrQz!PopulatedDummySupervisor.__init__5s��� � ��w�/� ����	�$���#�G�Z�(�K��"�7�+��*0����J�'��	.�G�"�7�+�G�&-�I�g�l�l�#�	.�%��rRNc�r�|�|j}|j|j|}t|||�yrT)r�r!r��setattr)rO�process_name�	attr_name�valr�r�s      rP�set_procattrz%PopulatedDummySupervisor.set_procattrBs8�������J��%�%�j�1�;�;�L�I�����C�(rRc��d|_yrb)�reapedrNs rP�reapzPopulatedDummySupervisor.reapHrrRrT)r�r�r�rQrrr]rRrPr�r�4s��%�)�rRr�c�^�eZdZdZdZdZdZdZdZdZ	dZ
dd�Zd�Zd�Z
d�Zd�Zd�Zd	�Zd
�Zy)r�NFc�t��|�_|�_|�_d�_|r�fd�}|�_�fd�}|�_yy)Nrc���d�_yrbr�rNs�rPr�z,DummyDispatcher.__init__.<locals>.reopenlogs]s���%)��"rRc���d�_yrb)�logs_removedrNs�rPrrz,DummyDispatcher.__init__.<locals>.removelogs`s���$(��!rR)�	_readable�	_writabler�input_bufferr�rr)rOr�r�rr�rrs`     rPrQzDummyDispatcher.__init__Vs@���!���!����������
*�(�D�O�
)�(�D�O�rRc��|jSrT)r
rNs rPr�zDummyDispatcher.readabled����~�~�rRc��|jSrT)rrNs rPr�zDummyDispatcher.writablefrrRc�B�|jr|j�d|_yrb)r�write_event_handledrNs rP�handle_write_eventz"DummyDispatcher.handle_write_evenths���;�;��+�+��#'�� rRc�B�|jr|j�d|_yrb)r�read_event_handledrNs rP�handle_read_eventz!DummyDispatcher.handle_read_eventls���;�;��+�+��"&��rRc��d|_yrb)�
error_handledrNs rP�handle_errorzDummyDispatcher.handle_errorpr�rRc��d|_yrbr
rNs rPrzDummyDispatcher.closerrrRc�B�|jr|j�d|_yrb)�flush_exceptionrrNs rPrzDummyDispatcher.flushts������&�&�&���rR)FFF)r�r�r�rrrrr>rr�rrQr�r�rrrrrr]rRrPr�r�KsT���O������M��M��L�
�F��G�)���(�'�"��rRr�c�:�eZdZd	d�Zd�Zd�Zd�Zd
d�Zd�Zd�Z	y)�DummyStreamNc�J�||_d|_d|_d|_||_y)NFrR)rr�rr7�_fileno)rOrr*s   rPrQzDummyStream.__init__zs%����
������������rRc�B�|jr|j�d|_yrb)rr�rNs rPrzDummyStream.close�s���:�:��*�*����rRc�B�|jr|j�d|_yrb)rrrNs rPrzDummyStream.flush�s���:�:��*�*����rRc��|jr|j}d|_|�|xjt|�z
c_yrT)rr7r)rOr�rs   rPr�zDummyStream.write�s0���:�:��J�J�E��D�J��K������
�%�rRc��yrTr])rO�numr�s   rP�seekzDummyStream.seek�r`rRc�,�t|j�SrT)r�r7rNs rP�tellzDummyStream.tell�s���4�<�<� � rRc��|jSrT)r"rNs rPr*zDummyStream.fileno�rvrR)Nrr�)
r�r�r�rQrrr�r(r*r*r]rRrPr r ys%�����&�
�!�rRr c��eZdZdd�Zd�Zy)�
DummyEventc��|�||_yyrT)�serial)rOr/s  rPrQzDummyEvent.__init__�s���� �D�K�rRc��y)Nzdummy eventr]rNs rP�payloadzDummyEvent.payload�s��rRN)�abc)r�r�r�rQr1r]rRrPr-r-�s��!�rRr-c�*�eZdZd�Zd�Zd�Zd�Zd�Zy)rKc�$�ggf|_d|_yr�)�resultr�)rOrs  rPrQzDummyPoller.__init__�s���"�f�����rRc��yrTr]r�s  rP�register_readablezDummyPoller.register_readable�r`rRc��yrTr]r�s  rP�register_writablezDummyPoller.register_writable�r`rRc��|jSrT)r5)rO�timeouts  rP�pollzDummyPoller.poll�s���{�{�rRc��d|_yrbr
rNs rPrzDummyPoller.close�rrRN)r�r�r�rQr7r9r<rr]rRrPrKrK�s���
�
��rRrKc��yrTr]��eventr5s  rP�
dummy_handlerrA�s��rRc��ddlm}||��)Nr)�RejectEvent)�supervisor.dispatchersrC)r@r5rCs   rP�rejecting_handlerrE�s��2�
�f�
�rRc��t|��rTr�r?s  rP�exception_handlerrG�s
��
�V�
�rRc��|jd�D�cgc]}|j���}}dj|�Scc}w)N�
)r��stripr)�s�x�stringss   rP�lstriprN�s7��"#�'�'�$�-�0�Q�q�w�w�y�0�G�0��9�9�W����1s�>rT)F)-r��_TIMEFORMAT�	functoolsr�rr�
unittest.mockrrr�ImportError�mockr
rUrr&r;rK�total_ordering�objectrUr�r�r�r�r�rrr<r?rBrAr�r�r�r�r�r�r r-rKrArErGrNr]rRrP�<module>rVs��������#�&�+�3�3�� �i�i�V "� "�D!�!�&��6$�$�*,�,����F<�6�F<��F<�PJ"�J"�X�(M�,�,�0�0�
�
�6$�6�6$�r��
0�0�
	�	�p�p�d	<�<�,+�,�+�
���"��"��"�BG�-�G����.,�,�\��8����"	�����S%�+�*�*�+��
����s"�
E�E0�E-�,E-�0	E=�<E=

Youez - 2016 - github.com/yon3zu
LinuXploit