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

k��c5A����ddlZddlZddlZddlZddlmZddlmZmZm	Z	ddlm
Z
mZddlmZe
ZGd�dej�ZGd�d	ej�Ze�r
ejZneZGd
�de�Ze
�r
ejZneZGd�d
e�ZGd�de
�ZGd�de
�ZGd�de
�ZGd�de
�Zd�Zedk(rej8d��yy)�N)�Mock)�SelectPoller�
PollPoller�KQueuePoller)�implements_poll�implements_kqueue)�DummyOptionsc�<�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
y	)
�BasePollerTestsc��ddlm}||�S)Nr)�
BasePoller)�supervisor.pollerr
)�self�optionsr
s   �>/usr/lib/python3/dist-packages/supervisor/tests/test_poller.py�_makeOnezBasePollerTests._makeOnes��0��'�"�"�c�h�|jd�}|jt|jd�y�N)r�assertRaises�NotImplementedError�register_readable�r�insts  r�test_register_readablez&BasePollerTests.test_register_readable�)���}�}�T�"�����-�t�/E�/E�t�Lrc�h�|jd�}|jt|jd�yr)rrr�register_writablers  r�test_register_writablez&BasePollerTests.test_register_writablerrc�h�|jd�}|jt|jd�yr)rrr�unregister_readablers  r�test_unregister_readablez(BasePollerTests.test_unregister_readable�)���}�}�T�"�����-�t�/G�/G��Nrc�h�|jd�}|jt|jd�yr)rrr�unregister_writablers  r�test_unregister_writablez(BasePollerTests.test_unregister_writable!r#rc�h�|jd�}|jt|jd�yr)rrr�pollrs  r�	test_pollzBasePollerTests.test_poll%s'���}�}�T�"�����-�t�y�y�$�?rc�f�|jd�}|j|j�d�yr)r�assertEqual�before_daemonizers  r�test_before_daemonizez%BasePollerTests.test_before_daemonize)s)���}�}�T�"������.�.�0�$�7rc�f�|jd�}|j|j�d�yr)rr+�after_daemonizers  r�test_after_daemonizez$BasePollerTests.test_after_daemonize-s)���}�}�T�"������-�-�/��6rN)�__name__�
__module__�__qualname__rrrr"r&r)r-r0�rrrrs/��#�M�M�O�O�@�8�7rrc�B�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zy
)�SelectPollerTestsc��t|�Sr)r�rrs  rrzSelectPollerTests._makeOne3�
���G�$�$rc���|jt��}|jd�|jd�|jt	|j
�ddg�y�N��)rr	rr+�sorted�	readables�r�pollers  rrz(SelectPollerTests.test_register_readable6�M�����|�~�.��� � ��#�� � ��#������ 0� 0�1�A�a�5�9rc���|jt��}|jd�|jd�|jt	|j
�ddg�yr;)rr	rr+r>�	writablesr@s  rrz(SelectPollerTests.test_register_writable<rBrc��|jt��}|jd�|jd�|jd�|jd�|j	d�|j	d�|j	d�|jt
|j�dg�|jt
|j�ddg�y)Nr<r=��	�d)	rr	rrr!r+�listr?rDr@s  rr"z*SelectPollerTests.test_unregister_readableBs������|�~�.��� � ��#�� � ��#�� � ��#�� � ��#��"�"�1�%��"�"�1�%��"�"�3�'�����f�.�.�/�!��5�����f�.�.�/�!�Q��8rc��|jt��}|jd�|jd�|jd�|jd�|j	d�|j	d�|j	d�|jt
|j�ddg�|jt
|j�dg�y)Nr<r=rFrH)	rr	rrr%r+rIr?rDr@s  rr&z*SelectPollerTests.test_unregister_writableNs������|�~�.��� � ��#�� � ��#�� � ��#�� � ��#��"�"�1�%��"�"�1�%��"�"�3�'�����f�.�.�/�!�Q��8�����f�.�.�/�!��5rc�@�tdgdgd���}|jt��}||_|j	d�|j	d�|jd�|j
d�\}}|j|dg�|j|dg�y)Nr<rF)r?rD��resultr=�)�DummySelectrr	�_selectrrr(r+)rrPrAr?rDs     r�)test_poll_returns_readables_and_writablesz;SelectPollerTests.test_poll_returns_readables_and_writablesZs����A�3�45�3�&8�9�����|�~�.�� ���� � ��#�� � ��#�� � ��#�%�{�{�1�~��	�9�����Q�C�(�����Q�C�(rc��ttj��}t�}|j	|�}||_|j
d�|jd�|j|jjdd�y)N��errorr<rNr�EINTR encountered in poll)rO�errno�EINTRr	rrPrr(r+�logger�data�rrPrrAs    r�test_poll_ignores_eintrz)SelectPollerTests.test_poll_ignores_eintrfse���E�K�K�0���.�����w�'�� ���� � ��#����A��������,�,�Q�/�1L�Mrc��ttj��}t�}|j	|�}||_|j
d�|jd�|j|jjdd�|jt|j�g�|jt|j�g�y)NrSr<rNrzEBADF encountered in poll)rOrV�EBADFr	rrPrr(r+rXrYrIr?rDrZs    r�test_poll_ignores_ebadfz)SelectPollerTests.test_poll_ignores_ebadfos����E�K�K�0���.�����w�'�� ���� � ��#����A��������,�,�Q�/�1L�M�����f�.�.�/��4�����f�.�.�/��4rc���ttj��}t�}|j	|�}||_|j
d�|jtj|jd�y)NrSr<rN)rOrV�EPERMr	rrPrr�selectrTr(rZs    r�test_poll_uncaught_exceptionz.SelectPollerTests.test_poll_uncaught_exceptionzsT���E�K�K�0���.�����w�'�� ���� � ��#����&�,�,����Q�7rN)r1r2r3rrrr"r&rQr[r^rbr4rrr6r61s0��%�:�:�
9�
6�
)�N�	5�8rr6c�x�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zy)�KQueuePollerTestsc��t|�Sr)rr8s  rrzKQueuePollerTests._makeOne�r9rc�N�t�}|jt��}||_|j	d�|jt
|j�dg�|jt|j�d�|j|jdd�y)Nr<rNr)�DummyKQueuerr	�_kqueuerr+rIr?�len�registered_kevents�assertReadEventAdded�r�kqueuerAs   rrz(KQueuePollerTests.test_register_readable�s���������|�~�.������ � ��#�����f�.�.�/�!��5�����V�6�6�7��;��!�!�&�";�";�A�">��Brc�N�t�}|jt��}||_|j	d�|jt
|j�dg�|jt|j�d�|j|jdd�y)Nr=rNr)rgrr	rhrr+rIrDrirj�assertWriteEventAddedrls   rrz(KQueuePollerTests.test_register_writable�s���������|�~�.������ � ��#�����f�.�.�/�!��5�����V�6�6�7��;��"�"�6�#<�#<�Q�#?��Crc��t�}|jt��}||_|j	d�|jd�|j
d�|j
d�|j
d�|jt|j�dg�|jt|j�g�|j|jdd�|j|jdd�|j|jdd�|j|jdd�y�Nr=rFrHrrN��)rgrr	rhrrr!r+rIrDr?rorjrk�assertReadEventDeletedrls   rr"z*KQueuePollerTests.test_unregister_readable�s
��������|�~�.������ � ��#�� � ��#��"�"�1�%��"�"�1�%��"�"�3�'�����f�.�.�/�!��5�����f�.�.�/��4��"�"�6�#<�#<�Q�#?��C��!�!�&�";�";�A�">��B��#�#�F�$=�$=�a�$@�!�D��#�#�F�$=�$=�a�$@�!�Drc��t�}|jt��}||_|j	d�|jd�|j
d�|j
d�|j
d�|jt|j�g�|jt|j�dg�|j|jdd�|j|jdd�|j|jdd�|j|jdd�yrq)rgrr	rhrrr%r+rIrDr?rorjrk�assertWriteEventDeletedrls   rr&z*KQueuePollerTests.test_unregister_writable�s
��������|�~�.������ � ��#�� � ��#��"�"�1�%��"�"�1�%��"�"�3�'�����f�.�.�/��4�����f�.�.�/�!��5��"�"�6�#<�#<�Q�#?��C��!�!�&�";�";�A�">��B��$�$�V�%>�%>�q�%A�1�E��$�$�V�%>�%>�q�%A�1�Erc��tdtjfdtjfdtjfg��}|j	t��}||_|jd�|jd�|jd�|jd�\}}|j|ddg�|j|dg�y)Nr<r=rFrL��)rgra�KQ_FILTER_READ�KQ_FILTER_WRITErr	rhrrr(r+)rrmrAr?rDs     rrQz;KQueuePollerTests.test_poll_returns_readables_and_writables�s����a��)>�)>�%?�&'��)>�)>�%?�&'��)?�)?�%@�%B�C�����|�~�.������ � ��#�� � ��#�� � ��#�%�{�{�4�0��	�9�����Q�q�E�*�����Q�C�(rc��ttj��}t�}|j	|�}||_|j
d�|jd�|j|jjdd�y)N��raise_errno_pollr<rxrrU)rgrVrWr	rrhrr(r+rXrY�rrmrrAs    rr[z)KQueuePollerTests.test_poll_ignores_eintr�sf���e�k�k�:���.�����w�'������ � ��#����D��������,�,�Q�/�1L�Mrc�d�ttj��}t�}|j	|�}||_|j
d�|jd�|j|jjdd�|j|jjdd�y)N��raise_errno_registerr<r=rz6EBADF encountered in kqueue. Invalid file descriptor 6rNz6EBADF encountered in kqueue. Invalid file descriptor 7)rgrVr]r	rrhrrr+rXrY�rrhrrAs    r�1test_register_readable_and_writable_ignores_ebadfzCKQueuePollerTests.test_register_readable_and_writable_ignores_ebadf�s����5�;�;�?���.�����w�'�� ���� � ��#�� � ��#�������,�,�Q�/�Q�	S�������,�,�Q�/�Q�	Src��ttj��}t�}|j	|�}||_|j
t|jd�y)Nr��)	rgrV�ENOMEMr	rrhr�OSErrorrr�s    r� test_register_uncaught_exceptionz2KQueuePollerTests.test_register_uncaught_exception�sD���5�<�<�@���.�����w�'�� ������'�6�#;�#;�Q�?rc���ttj��}t�}|j	|�}||_|j
d�|jt|jd�y)Nr|r<rx)
rgrV�EINVALr	rrhrrr�r(r~s    rrbz.KQueuePollerTests.test_poll_uncaught_exception�sP���e�l�l�;���.�����w�'������ � ��#����'�6�;�;��5rc���t�}t�}|j|�}||_|j	�|j
j
�|j|jd�yr)rr	rrhr,�close�assert_called_once_withr+�r�mock_kqueuerrAs    r�#test_before_daemonize_closes_kqueuez5KQueuePollerTests.test_before_daemonize_closes_kqueue�sW���f���.�����w�'��$������!����1�1�3��������.rc��t�}|j|�}dg|_dg|_t	�|_t	�|_|j�|jt|jtj��|j
jd�|jjd�y)NrNrs)r	rr?rDrrrr/�
assertTrue�
isinstancerhrarm�assert_called_with)rrrAs   r�$test_after_daemonize_restores_kqueuez6KQueuePollerTests.test_after_daemonize_restores_kqueue�s����.�����w�'���3����3���#'�6�� �#'�6�� ���� ����
�6�>�>�6�=�=�A�B�� � �3�3�A�6�� � �3�3�A�6rc���t�}t�}|j|�}||_|j	�|jj�|j
|jd�yr)rr	rrhr�r�r+r�s    r�test_close_closes_kqueuez*KQueuePollerTests.test_close_closes_kqueuesT���f���.�����w�'��$����������1�1�3��������.rc�d�|j||tjtj�yr)�assertKeventrary�	KQ_EV_ADD�r�kevent�fds   rrkz&KQueuePollerTests.assertReadEventAdded
s"�����&�"�f�&;�&;�V�=M�=M�Nrc�d�|j||tjtj�yr)r�rarzr�r�s   rroz'KQueuePollerTests.assertWriteEventAddeds"�����&�"�f�&<�&<�f�>N�>N�Orc�d�|j||tjtj�yr)r�rary�KQ_EV_DELETEr�s   rrtz(KQueuePollerTests.assertReadEventDeleteds"�����&�"�f�&;�&;�V�=P�=P�Qrc�d�|j||tjtj�yr)r�rarzr�r�s   rrvz)KQueuePollerTests.assertWriteEventDeleteds"�����&�"�f�&<�&<�f�>Q�>Q�Rrc��|j|j|�|j|j|�|j|j|�yr)r+�ident�filter�flags)rr�r�r�r�s     rr�zKQueuePollerTests.assertKevents>��������u�-��������/�������u�-rN)r1r2r3rrrr"r&rQr[r�r�rbr�r�r�rkrortrvr�r4rrrdrd�sg��%�C�D�E� F� )�N�
S�@�6�/�
7�/�O�P�R�S�.rrdc�6�eZdZd�Zd�Zd�Zd�Zd�Zd�Zd�Z	y)	�PollerPollTestsc��t|�Sr)rr8s  rrzPollerPollTests._makeOne%s
���'�"�"rc���t�}|jt��}||_|j	d�|j	d�|j|jddg�yr;)�DummySelectPollrr	�_pollerrr+�registered_as_readable�r�select_pollrAs   rrz&PollerPollTests.test_register_readable(sW��%�'�����|�~�.��$���� � ��#�� � ��#�����;�;�a��U�Crc��t�}|jt��}||_|j	d�|j|jdg�y)Nr<)r�rr	r�rr+�registered_as_writabler�s   rrz&PollerPollTests.test_register_writable0sG��%�'�����|�~�.��$���� � ��#�����;�;�a�S�Arc���tdtjfdtjfdtjfdtj
fg��}|j
t��}||_|jd�|jd�|jd�|jd�|jd�\}}|j|gd��|j|dg�y)Nr<r=rFrGrLrx)r<r=rG)
r�ra�POLLIN�POLLPRI�POLLOUT�POLLHUPrr	r�rrr(r+�rr�rAr?rDs     rrQz9PollerPollTests.test_poll_returns_readables_and_writables7s���%�q�&�-�-�.@�/0�&�.�.�.A�/0�&�.�.�.A�/0�&�.�.�.A�.C�D�����|�~�.��$���� � ��#�� � ��#�� � ��#�� � ��#�%�{�{�4�0��	�9�����G�,�����Q�C�(rc��ttj��}t�}|j	|�}||_|j
d�|jd�|j|jjdd�y)NrSrGrxrrU)r�rVrWr	rr�rr(r+rXrY�rr�rrAs    rr[z'PollerPollTests.test_poll_ignores_eintrFsf��%�E�K�K�8���.�����w�'��$���� � ��#����D��������,�,�Q�/�1L�Mrc���ttj��}t�}|j	|�}||_|j
d�|jtj|jd�y)NrSrGrx)r�rVr]r	rr�rrrarTr(r�s    rrbz,PollerPollTests.test_poll_uncaught_exceptionOsT��%�E�K�K�8���.�����w�'��$���� � ��#����&�,�,����T�:rc�l�tdtjfdtjfg��}|j	t��}||_|jd�|jd�|jd�\}}|j|dg�|j|jdg�y)Nr<r=rLrx)r�ra�POLLNVALr�rr	r�rr(r+�unregisteredr�s     r�+test_poll_ignores_and_unregisters_closed_fdz;PollerPollTests.test_poll_ignores_and_unregisters_closed_fdWs���%�q�&�/�/�.B�/0�&�.�.�.A�.C�D�����|�~�.��$���� � ��#�� � ��#�%�{�{�4�0��	�9�����Q�C�(�����1�1�A�3�7rN)
r1r2r3rrrrQr[rbr�r4rrr�r�#s(��#�D�B�
)�N�;�	8rr�c��eZdZdZdd�Zd�Zy)rOz0
    Fake implementation of select.select()
    Nc�z�|xsi}|jdg�|_|jdg�|_||_y)Nr?rD)�getr?rDrT�rrMrTs   r�__init__zDummySelect.__init__fs6����2�����K��4������K��4�����
rc��|jrtj|j��|j|jgfSr)rTrar?rD)r�r�w�x�timeouts     rrazDummySelect.selectls1���:�:��,�,�t�z�z�*�*��~�~�t�~�~�r�1�1r�NN)r1r2r3�__doc__r�rar4rrrOrObs����2rrOc�*�eZdZdZdd�Zd�Zd�Zd�Zy)r�z.
    Fake implementation of select.poll()
    Nc�R�|xsg|_||_g|_g|_g|_yr)rMrTr�r�r�r�s   rr�zDummySelectPoll.__init__us,���l������
�&(��#�&(��#���rc�6�|tjtjztjzk(r|jj|�y|tjk(r|jj|�ytdj|���)Nz+Registered a fd on unknown eventmask: '{0}')
rar�r�r�r��appendr�r��
ValueError�format)rr��	eventmasks   r�registerzDummySelectPoll.register|sl����
�
����6����G�G��'�'�.�.�r�2�
�&�.�.�
(��'�'�.�.�r�2��J�Q�Q�R[�\�]�]rc�:�|jj|�yr)r�r�)rr�s  r�
unregisterzDummySelectPoll.unregister�s����� � ��$rc�p�|jrtj|j��|jSr)rTrarM)rr�s  rr(zDummySelectPoll.poll�s&���:�:��,�,�t�z�z�*�*��{�{�rr�)r1r2r3r�r�r�r�r(r4rrr�r�qs����^�%�rr�c�8�eZdZdZd	d�Zd
d�Zd�Zd�Zd�Zd�Z	y)rgz0
    Fake implementation of select.kqueue()
    Nc�R�|xsg|_||_||_g|_g|_yr)rM�
errno_poll�errno_registerrj�registered_flags)rrMr}r�s    rr�zDummyKQueue.__init__�s,���l����*���2���"$��� "��rc��|�<|j|�|j|j�|j�S|j	|�|j|j
�|jj|�yr)�assert_max_events_on_poll�raise_errorr��build_result�assert_max_events_on_registerr�rj�extend)r�kevents�
max_eventsr�s    r�controlzDummyKQueue.control�sl���?��*�*�:�6����T�_�_�-��$�$�&�&��*�*�:�6�����,�,�-����&�&�w�/rc�.�|syt�}||_|�r)r�rV)r�err�exs   rr�zDummyKQueue.raise_error�s���F�
�Y������rc�`�|jD��cgc]\}}t||���c}}Scc}}wr)rM�
FakeKEvent�rr�r�s   rr�zDummyKQueue.build_result�s%��>B�k�k�J�l�e�F�
�5�&�)�J�J��Js�*c�Z�|tjk(sJdtjz��y)Nz8`max_events` parameter of `kqueue.control() should be %d)rr��rr�s  rr�z%DummyKQueue.assert_max_events_on_poll�s.���\�4�4�4�	'�F��%�%�
&�	'�4rc��|dk(sJd��y)NrzD`max_events` parameter of `kqueue.control()` should be 0 on registerr4r�s  rr�z)DummyKQueue.assert_max_events_on_register�s���Q��	T�R�	T�r)NNNr)
r1r2r3r�r�r�r�r�r�r�r4rrrgrg�s'���#�0��K�'�
Trrgc��eZdZd�Zy)r�c� �||_||_yr)r�r�r�s   rr�zFakeKEvent.__init__�s����
���rN)r1r2r3r�r4rrr�r��s��rr�c�V�tjtjt�Sr)�unittest�
findTestCases�sys�modulesr1r4rr�
test_suiter��s���!�!�#�+�+�h�"7�8�8r�__main__r�)�defaultTest)r�r�rVra�supervisor.tests.baserrrrrrrr	�object�SkipTestCase�TestCaserr6�KQueuePollerTestsBaserd�PollerPollTestsBaser�rOr�rgr�r�r1�mainr4rr�<module>r�s���
���
�&�D�D�@�.�
��7�h�'�'�7�BO8��)�)�O8�b��$�-�-��(��U.�-�U.�n��"�+�+��&��=8�)�=8�~
2�&�
2��f��8%T�&�%T�N���9��z���H�M�M�l�+�r

Youez - 2016 - github.com/yon3zu
LinuXploit