Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]



��Yf�8�@sdZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZd
dlZd
dl
Z
d
dlZd
dl
mZ
d
dlmZ
d
dlmZmZ
yd
dlZWnek
r



dZYn
XddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
ddl m!Z!
d
dl"m#Z#
e	j$dkr�
ddl%m&Z&
nd
dlm&Z&
dd�Z'dd�Z(ddd�
Z)dd�Z*Gdd�de�Z+Gdd�de�Z,Gdd �d �Z-Gd!d"�d"e-e,�Z.d#d$d%d&�
Z/e0ed'�rGd(d)�d)ej1e�Z2Gd*d+�d+e2e�Z3Gd,d-�d-e3�Z4Gd.d/�d/e-e4�Z5d0d1�Z6ej7d2d3��
Z8ej7d#d$d4d5�
�
Z9ej7d6d7d8d
d#d$d9d:��
Z:d;d<�Z;Gd=d>�d>ej<�Z=Gd?d@�d@ej>�Z?dAdB�Z@GdCdD�dDeA�ZBdEdF�ZCGdGdH�dHe
jD�ZDej7dIdJ��
ZEejFejGejHdKdL�ZIdMdN�ZJdS)OzUtilities shared by tests.�N)
�mock)
�
HTTPServer)�WSGIRequestHandler�
WSGIServer�
)
�base_events)
�compat)
�events)
�futures)
�	selectors)
�tasks)
�	coroutine)
�logger)
�support�win32)
�
socketpaircCs$tdkrdStj
tj�
SdS)
N)�sslZ
SSLContextZPROTOCOL_SSLv23�rr�7/opt/alt/python35/lib64/python3.5/asyncio/test_utils.py�dummy_ssl_context-s

rc

CsVtd
d��
}
|
�}|j
|�
}d|_z|j|�

Wd|j�
XdS)Nc
SsdS)
Nrrrrr�once5szrun_briefly.<locals>.onceF)r
Zcreate_taskZ_log_destroy_pending�run_until_complete�close)�loopr�gen�
trrr�run_briefly4s
	
	

r�cCsttj�|}x]|
�so|dk	rP|tj�}|d
k
rPt
j��
|jtjdd|�

�

qWdS)Nr
g����MbP?r)�timer
�TimeoutErrorrrZsleep)rZpred�timeoutZdeadlinerrr�	run_untilCs






r!c

Cs|j|j
�

|j�
d
S)z�Legacy API to run once through the event loop.

    This is the recommended pattern for test code.  It will poll the
    selector once and run all callbacks scheduled in response to I/O
    events.
    N)Z	call_soon�stopZrun_forever)
rrrr�run_onceMs
r#c@s(eZ
dZd
d�Zdd�ZdS)�SilentWSGIRequestHandlerc


Cs
tj
�S)
N)�io�StringIO)
�selfrrr�
get_stderrZs
z#SilentWSGIRequestHandler.get_stderrc
GsdS)
Nr)r'�format�argsrrr�log_message]s
z$SilentWSGIRequestHandler.log_messageN)�__name__�
__module__�__qualname__r(r+rrrrr$Xsr$cs4eZ
dZd
Z�f
dd�Zdd�Z�S)�SilentWSGIServer�c
s/t�j
�\}
}|
j|j�

|
|fS)
N)�super�get_request�
settimeout�request_timeout)r'�request�client_addr)
�	__class__rrr2es


zSilentWSGIServer.get_requestc
CsdS)
Nr)r'r5�client_addressrrr�handle_errorjs
zSilentWSGIServer.handle_error)r,r-r.r4r2r9rr)
r7rr/asr/c@seZ
dZd
d�ZdS)�SSLWSGIServerMixincCs�tj
jtj
jt�
d
d�}tj
j|�
s]tj
jtj
jtj�
dd�}tj
j|d�}tj
j|d�}tj|
d|d|d	d
�
}y!|j|||�
|j	�
Wnt
k
r�


Yn
XdS)Nz..Ztests�testZtest_asynciozssl_key.pemzssl_cert.pem�keyfile�certfileZserver_sideT)�os�path�join�dirname�__file__�isdirrZwrap_socketZRequestHandlerClassr�OSError)r'r5r8�herer<r=Zssockrrr�finish_requestps$








	




z!SSLWSGIServerMixin.finish_requestN)r,r-r.rFrrrrr:nsr:c
@seZ
dZd
S)�
SSLWSGIServerN)r,r-r.rrrrrG�s
rG�use_sslFc
#s�d
d�}|
r|n|}||t���j
|�

�j�_tjd�f
dd��
}|j�
z	�V
Wd�j�
�j�
|j	�
XdS)NcSs#d
}dg
}|
||�
dg
S)Nz200 OK�Content-type�
text/plainsTest message)rIrJr)�environZstart_responseZstatusZheadersrrr�app�s

	


z_run_test_server.<locals>.app�targetcs�jd
d�
S)NZ
poll_intervalg�������?)
Z
serve_foreverr)
�httpdrr�<lambda>�sz"_run_test_server.<locals>.<lambda>)
r$Zset_appZserver_address�address�	threadingZThread�startZshutdownZserver_closer@)rPrH�
server_cls�server_ssl_clsrLZserver_classZ
server_threadr)
rNr�_run_test_server�s




	




	



rUZAF_UNIXc@seZ
dZd
d�ZdS)�UnixHTTPServerc

Cs&tj
j|�

d
|_d|_dS)Nz	127.0.0.1�P)�socketserver�UnixStreamServer�server_bindZserver_nameZserver_port)
r'rrrrZ�s

	
zUnixHTTPServer.server_bindN)r,r-r.rZrrrrrV�srVcs4eZ
dZd
Zdd�Z�f
dd�Z�S)�UnixWSGIServerr0c

Cstj
|�

|j�
dS)
N)rVrZZ
setup_environ)
r'rrrrZ�s


zUnixWSGIServer.server_bindc
s/t�j
�\}
}|
j|j�

|
dfS)N�	127.0.0.1�)r\r])r1r2r3r4)r'r5r6)
r7rrr2�s

zUnixWSGIServer.get_request)r,r-r.r4rZr2rr)
r7rr[�sr[c@seZ
dZd
d�ZdS)�SilentUnixWSGIServerc
CsdS)
Nr)r'r5r8rrrr9�s
z!SilentUnixWSGIServer.handle_errorN)r,r-r.r9rrrrr^�sr^c
@seZ
dZd
S)�UnixSSLWSGIServerN)r,r-r.rrrrr_�s
r_c
	Cs!tj
��}|jSWdQRXdS)
N)�tempfileZNamedTemporaryFile�name)
�filerrr�gen_unix_socket_path�s

rcc
cs@t�}z	|V
Wdyt
j|�

Wntk
r:


Yn
XXdS)
N)rcr>�unlinkrD)
r?rrr�unix_socket_path�s	

	



rec
cs;t��+}
t
d
|
d|dtdt�EdH
WdQRXdS)NrPrHrSrT)rerUr^r_)rHr?rrr�run_test_unix_server�s


rf�hostz	127.0.0.1�portc	cs.td
||
fd|dt
dt�EdH
dS)NrPrHrSrT)rUr/rG)rgrhrHrrr�run_test_server�s

ric
Csni}
xHt|�
D]:}|j
d
�
r:|jd
�
r:qtdd�
|
|<qWtd|f
|j|
��S)N�__�return_valueZTestProtocol)�dir�
startswith�endswith�MockCallback�type�	__bases__)�baseZdctrarrr�make_test_protocol�s




rsc@sOeZ
dZd
d�Zddd�
Zdd�Zdd	�Zd
d�ZdS)�TestSelectorc

Cs
i|_dS)
N)
�keys)
r'rrr�__init__�s
zTestSelector.__init__NcCs)tj
|
d
||�}||j|
<|S)Nr
)rZSelectorKeyru)r'�fileobjr	�data�keyrrr�register�s



zTestSelector.registercCs|jj
|
�
S)
N)ru�pop)r'rwrrr�
unregister
s
zTestSelector.unregisterc
CsgS)
Nr)r'r rrr�select
s
zTestSelector.selectc


Cs|jS)
N)
ru)
r'rrr�get_map
s
zTestSelector.get_map)r,r-r.rvrzr|r}r~rrrrrt�s
rtcs!
eZ
dZd
Zd�f
dd�
Zdd�Zdd�Z�f
d	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Z�f
d#d$�Z�f
d%d&�Zd'd(�Zd)d*�Z�S)+�TestLoopa�
Loop for unittests.

    It manages self time directly.
    If something scheduled to be executed later then
    on next loop iteration after all ready handlers done
    generator passed to __init__ is calling.

    Generator should be like this:

        def gen():
            ...
            when = yield ...
            ... = yield time_advance

    Value returned by yield is absolute time of next scheduled handler.
    Value passed to yield is time advance to move loop's time forward.
    Ncs�t�j
�
|
dkr1d
d�}
d|_n	d|_|
�|_t|j�

d|_d|_g|_t�|_	i|_
i|_|j�
t
j�|_dS)Nc
ss	dV
dS)
Nrrrrrr!
s
zTestLoop.__init__.<locals>.genFTr
g��&�.>)r1rv�_check_on_close�_gen�next�_timeZ_clock_resolution�_timersrtZ	_selector�readers�writers�reset_counters�weakref�WeakValueDictionary�_transports)r'r)
r7rrrv
s


	


	
	
	
	
	

zTestLoop.__init__c


Cs|jS)
N)
r�)
r'rrrr4
s
z
TestLoop.timecCs|
r|j|
7_d
S)zMove test time forward.N)
r�)r'�advancerrr�advance_time7
s
zTestLoop.advance_timec

sOt�j
�
|jrKy|jjd
�

Wntk
r>


Yn
Xtd�
�
dS)Nr
zTime generator is not finished)r1rr�r��send�
StopIteration�AssertionError)
r')
r7rrr<
s


	




zTestLoop.closecGs tj
|||�|j|
<dS)
N)r	�Handler�)r'�fd�callbackr*rrr�_add_readerF
s
zTestLoop._add_readercCs6|j|
d
7<|
|j
kr.|j
|
=dSdSdS)NrTF)�remove_reader_countr�)r'r�rrr�_remove_readerI
s





zTestLoop._remove_readercGs�|
|jks$t
d
j|
�
�
�
|j|
}|j|ks[t
dj|j|��
�
|j|ks�t
dj|j|��
�
dS)Nzfd {} is not registeredz{!r} != {!r})r�r�r)�	_callback�_args)r'r�r�r*�handlerrr�
assert_readerQ
s
$





zTestLoop.assert_readercGs tj
|||�|j|
<dS)
N)r	r�r�)r'r�r�r*rrr�_add_writerY
s
zTestLoop._add_writercCs6|j|
d
7<|
|j
kr.|j
|
=dSdSdS)NrTF)�remove_writer_countr�)r'r�rrr�_remove_writer\
s





zTestLoop._remove_writercGs�|
|jks$t
d
j|
�
�
�
|j|
}|j|ks[t
dj|j|��
�
|j|ks�t
dj|j|��
�
dS)Nzfd {} is not registeredz{!r} != {!r})r�r�r)r�r�)r'r�r�r*r�rrr�
assert_writerd
s
$





zTestLoop.assert_writercCsBy|j|
}Wnt
k
r%


YnXtd
j|
|��
�
dS)Nz.File descriptor {!r} is used by transport {!r})r��KeyError�RuntimeErrorr))r'r�Z	transportrrr�_ensure_fd_no_transportl
s






z TestLoop._ensure_fd_no_transportcGs |j|
�

|j
|
||�S)
zAdd a reader callback.)r�r�)r'r�r�r*rrr�
add_readerv
s

zTestLoop.add_readercCs|j|
�

|j
|
�
S)
zRemove a reader callback.)r�r�)r'r�rrr�
remove_reader{
s

zTestLoop.remove_readercGs |j|
�

|j
|
||�S)
zAdd a writer callback..)r�r�)r'r�r�r*rrr�
add_writer�
s

zTestLoop.add_writercCs|j|
�

|j
|
�
S)
zRemove a writer callback.)r�r�)r'r�rrr�
remove_writer�
s

zTestLoop.remove_writerc

Cs(tj
t�
|_tj
t�
|_dS)
N)�collections�defaultdict�intr�r�)
r'rrrr��
s

zTestLoop.reset_countersc
sMt�j
�
x0|jD]%}
|jj|
�
}|j|�

qWg|_dS)
N)r1�	_run_oncer�r�r�r�)r'�whenr�)
r7rrr��
s






zTestLoop._run_oncecs&|jj
|
�

t�j|
||�S)
N)r��appendr1�call_at)r'r�r�r*)
r7rrr��
s

zTestLoop.call_atc
CsdS)
Nr)r'Z
event_listrrr�_process_events�
s
zTestLoop._process_eventsc


CsdS)
Nr)
r'rrr�_write_to_self�
s
zTestLoop._write_to_self)r,r-r.�__doc__rvrr�rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rr)
r7rr

s*

rc
Kstj
d
dg
|�
S)N�spec�__call__)rZMock)
�kwargsrrrro�
s
roc@s"eZ
dZd
Zdd�ZdS)�MockPatternz�A regex based str with a fuzzy __eq__.

    Use this helper with 'mock.assert_called_with', or anywhere
    where a regex comparison between strings is needed.

    For instance:
       mock_call.assert_called_with(MockPattern('spam.*ham'))
    cCs"tt
jt|�
|
t
j��
S)
N)�bool�re�search�str�
S)r'�otherrrr�__eq__�
s
zMockPattern.__eq__N)r,r-r.r�r�rrrrr��
s
r�c
Cs2tj
|�
}
|
dkr.td
|f
�
�
|
S)Nzunable to get the source of %r)r	Z_get_function_source�
ValueError)�func�sourcerrr�get_function_source�
s



r�c@sjeZ
dZd
ddd�
Zddd�
Zdd	�Zd
d�Zdd
�Zej	sfdd�Z
dS)�TestCase�cleanupTc
Cs9|
dk	st�
t
jd�

|r5|j|
j�

dS)
N)r�r	�set_event_loopZ
addCleanupr)r'rr�rrrr��
s



zTestCase.set_event_loopNcCst|
�
}|j
|�

|S)
N)rr�)r'rrrrr�
new_test_loop�
s



zTestCase.new_test_loopc

Cs|jt
_dS)
N)�_get_running_loopr	)
r'rrr�unpatch_get_running_loop�
s
z!TestCase.unpatch_get_running_loopc

Cs.tj
|_
d
d�t_
tj�|_dS)Nc
SsdS)
NrrrrrrO�
sz TestCase.setUp.<locals>.<lambda>)r	r�rZthreading_setup�_thread_cleanup)
r'rrr�setUp�
s


zTestCase.setUpc

CsU|j�
t
jd�

|jtj�d
�
|j�
tj|j	�
tj
�
dS)N)NNN)r�r	r�ZassertEqual�sys�exc_infoZ
doCleanupsrZthreading_cleanupr�Z
reap_children)
r'rrr�tearDown�
s





zTestCase.tearDownc
OsGd
d�d�}|�S)Nc@s(eZ
dZd
d�Zdd�ZdS)z!TestCase.subTest.<locals>.EmptyCMc


SsdS)
Nr)
r'rrr�	__enter__�
s
z+TestCase.subTest.<locals>.EmptyCM.__enter__c

WsdS)
Nr)r'�excrrr�__exit__�
s
z*TestCase.subTest.<locals>.EmptyCM.__exit__N)r,r-r.r�r�rrrr�EmptyCM�
s
r�r)r'r*r�r�rrr�subTest�
s
zTestCase.subTest)r,r-r.r�r�r�r�r�rZPY34r�rrrrr��
s

	r�c
cs;tj
}ztjtjd
�

dV
Wdtj|�

XdS)zrContext manager to disable asyncio logger.

    For example, it can be used to ignore warnings in debug mode.
    rN)r�levelZsetLevel�loggingZCRITICAL)
Z	old_levelrrr�disable_logger�
s
	


	r�cCs=tj
tj�
}||_|
|_||_d
|j_|S)z'Create a mock of a non-blocking socket.g)rZ	MagicMock�socket�protorp�familyZ
gettimeoutrk)r�rpr�Zsockrrr�mock_nonblocking_socket�
s
	
	
	

r�cCstj
d
dd�

S)Nz'asyncio.sslproto._is_sslproto_availablerkF)rZpatchrrrr�force_legacy_ssl_support�
s

r�)Kr�r��
contextlibr%r�r>r�r�rXr�r`rQrZunittestr�rZhttp.serverrZwsgiref.simple_serverrrr�ImportErrorr]rrr	r
rrZ
coroutinesr
�logrr;r�platformZ
windows_utilsrrrr!r#r$r/r:rGrU�hasattrrYrVr[r^r_rc�contextmanagerrerfrirsZBaseSelectorrtZ
BaseEventLooprror�r�r�r�r�ZIPPROTO_TCPZSOCK_STREAMZAF_INETr�r�rrrr�<module>
s�



























	
	
	

�
-