codekingpro/portable-devtools
114k
1�
2 ��j� � � � S SK r S SKrS SKrS SKJr S SKJr S SKJ r J3r4 S SK J r " S S5 r
" S S \
\ 5 r " S5 S \
\ 5 rg) � N)� validator)�6RuleRouter)�AsyncHTTPTestCase�gen_test)�
WSGIContainerc �8 � \ rS rSrS rS rS rS rS rS r Sr7g )8� WSGIAppMixin� c � � [ 5 e�N)�NotImplementedError��selfs �\D:\code\apps\devtools\python\user_packages\Python313\site-packages\tornado/test/wsgi_test.py� get_executor�WSGIAppMixin.get_executor s � �!�#�#� c �� ^� U R 5 m[ R " SSS9U l U4S jn[ SU" U R9 5 4SU" U R 5 4SU" U R 5 4/5 $ )N� g333333�?)�timeoutc �* >� [ [ U 5 TS9$ )N)�executor)r r )�appr s �r �make_container�,WSGIAppMixin.get_app.<locals>.make_container s �� � ��3� �(�C� Cr �/simple�/barrier�/streaming_barrier)r � threading�Barrier�barrierr �simple_wsgi_app�barrier_wsgi_app�streaming_barrier_wsgi_app)r r r s @r �get_app�WSGIAppMixin.get_app sz �� ��$�$�&�� !�(�(��C�8�� � D� ��N�4�+?�+?� @�A��^�D�,A�,A� B�C�%�~�d�6U�6U�'V�W�
�10� 11r c � � SnS/nU" X#5 g )Nz200 OK)z Content-Typez12text/plain� )r �start_response�status�response_headerss r �
respond_plain�WSGIAppMixin.respond_plain" s � ��� :�;���v�0r c �* � U R U5 S/$ )N� Hello world!)r, )r �environr) s r r" � WSGIAppMixin.simple_wsgi_app' s � � ���>�*� � � r c � � U R U5 U R R 5 nSU- /$ ! [ R a S/s $ f = f)Ns ok %d� broken barrier�r, r! �waitr �BrokenBarrierError�r r0 r) �ns r r# � WSGIAppMixin.barrier_wsgi_app+ sU � � ���>�*� "�� � �!�!�#�A� �q�L�>� !�� �+�+� '�%�&� &� '�s �3 �A
� A
c # � # � U R U5 Sv � U R R 5 nSU- v � g ! [ R a Sv � g f = f7f)Ns ok s %dr3 r4 r7 s r r$ �'WSGIAppMixin.streaming_barrier_wsgi_app4 sV � � � ���>�*�� � �� � �!�!�#�A� �!�)�O�� �+�+� $�#� #� $�s% �A�; �A�A�A�A�A)r! N) �__name__�13__module__� __qualname__�__firstlineno__r r% r, r" r# r$ �__static_attributes__r( r r r r s � �$�14�"1�15!�"� r r c �@ � \ rS rSrS rS r\S 5 r\S 5 rSr g)� WSGIContainerDummyExecutorTest�? c � � g r r( r s r r �+WSGIContainerDummyExecutorTest.get_executor@ s � �r c �^ � U R S5 nU R UR S5 g �Nr r/ ��fetch� assertEqual�body�r �responses r � test_simple�*WSGIContainerDummyExecutorTest.test_simpleC �$ � ��:�:�i�(�� ���� � ��8r c � �l # � U R R 5 [ R " U R R U R
S5 5 U R R U R
S5 5 5 I S h v�N nU H nU R UR S5 M! g N*7f)Nr r3 � r! �reset�asyncio�gather� http_clientrI �get_urlrJ rK �r �resps�resps r �test_concurrent_barrier�6WSGIContainerDummyExecutorTest.test_concurrent_barrierG s� � � � � � ��� � �n�n� � � � "� "�4�<�<�16�#;� <� � � � "� "�4�<�<�17�#;� <�18� 19�� �D� � � �T�Y�Y�(9� :� � 20�� �BB4�B2�+B4c � �l # � U R R 5 [ R " U R R U R
S5 5 U R R U R
S5 5 5 I S h v�N nU H nU R UR S5 M! g N*7f)Nr s ok broken barrierrR rX s r �!test_concurrent_streaming_barrier�@WSGIContainerDummyExecutorTest.test_concurrent_streaming_barrierQ s� � � � � � ��� � �n�n� � � � "� "�4�<�<�0D�#E� F� � � � "� "�4�<�<�0D�#E� F�21� 22�� �D� � � �T�Y�Y�(<� =� � 23�r] r( N�24r< r= r> r? r rN r r[ r_ r@ r( r r rB rB ? s4 � ��9� �;� �;� �>� �>r rB c �@ � \ rS rSrS rS r\S 5 r\S 5 rSr g)�WSGIContainerThreadPoolTest�\ c �> � [ R R 5 $ r )�25concurrent�futures�ThreadPoolExecutorr s r r �(WSGIContainerThreadPoolTest.get_executor] s � ��!�!�4�4�6�6r c �^ � U R S5 nU R UR S5 g rG rH rL s r rN �'WSGIContainerThreadPoolTest.test_simple` rP r c � � # � U R R 5 [ R " U R R U R
S5 5 U R R U R
S5 5 5 I S h v�N nU R SS/[ U Vs/ s H o"R PM sn5 5 g N<s snf 7f)Nr � ok 0� ok 1�26r! rS rT rU rV rI rW rJ �sortedrK rX s r r[ �3WSGIContainerThreadPoolTest.test_concurrent_barrierd s� � � � � � ��� � �n�n� � � � "� "�4�<�<�27�#;� <� � � � "� "�4�<�<�28�#;� <�29� 30��
���'�7�+�V�5�4Q�5�4�Y�Y�5�4Q�-R�S� 31�� 5R��$ �BC �C�C �#C�8
C �C c � � # � U R R 5 [ R " U R R U R
S5 5 U R R U R
S5 5 5 I S h v�N nU R SS/[ U Vs/ s H o"R PM sn5 5 g N<s snf 7f)Nr rm rn ro rX s r r_ �=WSGIContainerThreadPoolTest.test_concurrent_streaming_barrierm s� � � � � � ��� � �n�n� � � � "� "�4�<�<�0D�#E� F� � � � "� "�4�<�<�0D�#E� F�32� 33��
���'�7�+�V�5�4Q�5�4�Y�Y�5�4Q�-R�S� 34�� 5R�rr r( Nra r( r r rc rc \ s8 � �7�9� �T� �T� �T� �Tr rc )rT �concurrent.futuresrf r �wsgiref.validater �tornado.routingr �tornado.testingr r � tornado.wsgir r rB rc r( r r �<module>rz sE �� � � � &� &� 7� &�0 � 0 �f>�\�3D� >�:T�,�0A� Tr