<|h[VddlmZddlmZddlmZej ddlZddlZddlZddl Z ddl Z ddl m Z ddlZddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZeZ Gdde!Z"Gdde"Z#ejHdsGdde"eZ%e%Zne#ZGddejLZ'GddejLZ(GddejLZ)GddejLZ*e+dk(rejXyy) )print_function)absolute_import)monkeyN)wraps)reraise)six) LARGE_TIMEOUT)support)params tcp_listener)skipWithoutExternalNetwork) skipOnMacOnCI)Thread)EventceZdZdZdZy) BaseThreadNc>tfd}|_y)NcT |i|S#tj_xYwN)sysexc_info terminal_exc)argskwargsselftargets X/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__socket.pyerrors_are_fatalz-BaseThread.__init__..errors_are_fatal+s0 t.v.. $'LLN!s ')rr)rrrs`` r__init__zBaseThread.__init__*s" v    ' )__name__ __module__ __qualname__rr r!rrr's L'r!rc eZdZddZdZdZy)GreenletThreadNcztj||tj|jg||_yr)rr geventspawnrglet)rrrs rr zGreenletThread.__init__6s+D&)LL4t4 r!c:|jj|i|Sr)r+join)rrrs rr-zGreenletThread.join:styy~~t.v..r!c8|jj Sr)r+readyrs ris_alivezGreenletThread.is_alive=s99??$$$r!)Nr%)r"r#r$r r-r1r%r!rr'r'4s5/%r!r' threadingceZdZdZy) ThreadThreadc |jd}tj||tj|fd|ji||j y)Nr)poprr _Threadrstart)rrrs rr zThreadThread.__init__BsEZZ)F   f -   T @$++ @ @ JJLr!N)r"r#r$r r%r!rr4r4As r!r4c 2eZdZdZej ZdjedDcgc] }t|c}}}Z e e e se jdZ fdZdZ d#dZd$dZd Zej(rd Zed d Zd ZdZdZdZdZdZdZddzZe jBddZ"dZ#dZ$dZ%dZ&e'ddZ(e'ddZ)dZ*e+jXe-ed d!d"Z.xZ/Scc}}}w)%TestTCPNz, i Nasciicrtt| dtjvr)g ddlmfd|jfd}||_nd|_ |j|j|_ |jjd|_ y#t$r ddlmYwxYw) Nz-vr) perf_counter)timechstjdtdzg|y)Nz -> %0.6f)printappend)rnowprinteds rlogzTestTCP.setUp..logZs+GNN1%mce+3d3r!c8d||ffd }||S)NzRegistering for teardownc<d||jd}y)NzClosing on teardown)close)orEs rcz%TestTCP.setUp..cot..ccs-q1GGIAr!r%)rIrJrEorig_cots rcotzTestTCP.setUp..cotas$.2 r!cy)z Does nothingNr%)_argss rrEzTestTCP.setUp..loglsr!r@)superr:setUprargvr>r= ImportError_close_on_teardownrE_setup_listenerlistener getsocknameport)rrLrErCrKrD __class__s @@@@rrPz TestTCP.setUpRs gt"$ 388 G -4 4 ..H '*D # //0D0D0FG MM--/2 O -, -sB$$B65B6ctSrr r0s rrTzTestTCP._setup_listeners ~r!c|jtj}|j|xstj|xs |j f||j |||j||Sr)rSsocketconnectr DEFAULT_CONNECTrW settimeout setblocking)rhostrWtimeoutblockingsocks rcreate_connectionzTestTCP.create_connectionsh&&v}}7 d4f44d6GdiiHI   OOG $     X & r!c  j  d|g t fd}t|}  djdi|} j  d|dt | t |||} d| dt|d r |j} |jtj d |j |jd |j!rJ|j"rt%|j"| j&} d j)d  |j)d }j+ d |d j+t t |j+ |y#ttf$rYwxYw#t$rYwxYw# dt|d r' |j}n#ttf$rYnwxYw |jtjn#t$rYnwxYw d |jwxYw#|jd |j!rJwxYw)Nztest_sendall using methodc djjj\}} |jd5}d|d|jdj |j d|dt d ddd~|j~y#1swYxYw#|j~wxYw) Nz acceptingrbmodez# accepted on server; client conn iszfile isz readingz done readingz got bytesr)rUacceptmakefilesetrBreadlenrH)conn_raccepted_eventrE read_datars raccept_and_readz.TestTCP._test_sendall..accept_and_reads  t}} -mm**,GD! ]]]-M>iQRS"&&( $$$QVVX.(![#il:KL M  MM s$CAB: C:C?CCrzcreating client connectionz%Client got accepted event from serverz; sending dataz$Client sent data: result from methodzClient will unwrap and shutdownunwrapzClient will close r,r%)rErrrdwaitrngetattrhasattrrv ValueErrorOSErrorshutdownr[ SHUT_RDWRrHr-r1rr long_datasplit assertEqual) rdata match_data client_method client_argsrtserverclientxrrrErss ` @@@r _test_sendallzTestTCP._test_sendallsbhh '7   /8 ) , -+T++:k:F"    ! 7AQSVW[S\ ] 2GFM248:A>5668, !' OOF$4$45'(  KKO( ((    V(( )  JaL&&t, %%d+  1z!}5 YZ9 J/E'0 15668, !'&0 OOF$4$45'(  KKO( (((s>I#:GI#*F6;G I#6G I#G  I# GI#GI#I 1HI HI HI H87I 8 II II  I##%Jc:|j|jyr)rrr0s rtest_sendall_strzTestTCP.test_sendall_strs 4>>*r!c`|jtj|jyr)rr text_typerr0s rtest_sendall_unicodezTestTCP.test_sendall_unicodes   s}}T^^< =r!z3Sometimes fails for no apparent reason (buffering?)cftjd|j}|j|y)NB)arrayrrrrs rtest_sendall_arrayzTestTCP.test_sendall_arrays${{3/ 4 r!c,d}|j||y)Nr!rrs rtest_sendall_emptyzTestTCP.test_sendall_emptys 4&r!c0d}|j||dy)Nr!rwrarrs rtest_sendall_empty_with_timeoutz'TestTCP.test_sendall_empty_with_timeouts 4r2r!c0d}|j||dy)Nshi F)rbrrs rtest_sendall_nonblockingz TestTCP.test_sendall_nonblockings  46r!c0d}|j||dy)Nr!send)rrrs rtest_empty_sendzTestTCP.test_empty_send s 4V.servers}#}}335 M1  # #M 2=#8#8#'!80F &++D1  8  s #BBrur皙?r) rrdrSrkrmr>sleeprrHr-)rr server_threadr client_file client_readerrs` @rtest_fullduplexzTestTCP.test_fullduplexs  f- '')--foo.?@ k&6&6aUC  3~& 3   r!cfd}t|}j} |jdtj}j j 5|j ddddtj|z }j|dd|jy#1swYDxYw#|jwxYw)Ncbjj\}}j|yr)rUrjrSrorprs rrjz)TestTCP.test_recv_timeout..accept1s)mm**,GD!  # #D )r!rur@ig?g?) rrdr^r> assertRaises TIMEOUT_ERRORrassertTimeWithinRanger-)rrjacceptorrr8tooks` rtest_recv_timeoutzTestTCP.test_recv_timeout0s *('')    a IIKE""4#5#56 " D! "99;&D  & &tWg > MMO  " " MMOs$AC$B962C9C>CCTshelloiz2On Windows send() accepts whatever is thrown at itcgtfd}j}tjdsJ|j dtj} j j 5|jjdddjr*tj|z }j|dd|j|jddjy#1swYvxYw#|j|jddjwxYw)NcVjjjSr)rBrUrj) client_sockrsrz.TestTCP.test_sendall_timeout..Rs););DMMrr^rrr_test_sendall_data _test_sendall_timeout_check_timerr-rH)rrrr8rrs` @rtest_sendall_timeoutzTestTCP.test_sendall_timeoutOs  !ST'') 3{#  &""4#5#56 8t667 844yy{U***4t< MMO LLN N1  # # % 8 8 MMO LLN N1  # # %s$$D?D>DDD8Ec|fd}t|} j}|jd}|j|j }j |dj |j d|j|jy#|jwxYw)Ncjj\}}|jd}|jd|j |j |j yNwbrhhello )rUrjrkwriteflushrHrorpfdrs r accept_oncez*TestTCP.test_makefile..accept_oncedsPmm**,GD!D)B HHZ HHJ HHJ JJLr!rurgrhrr!)rrdrkrHreadlinerrmr-)rrrrrlines` r test_makefilezTestTCP.test_makefilecs - ++-F //t/4K LLN'')D   T: .   [--/ 5     MMOHMMOs BB))B;cffd}t|} j}|jd|jd}j j |j |j|j|jy#|jwxYw)Ncjj\}} tjd|j y#|j wxYw)Ng333333?)rUrjr>rrHrs rrz2TestTCP.test_makefile_timeout..accept_once{s<mm**,GD!  3  s AArurrgrh) rrdr^rkrrrrHr-)rrrrrs` rtest_makefile_timeoutzTestTCP.test_makefile_timeoutys - ++-F   c "d+B   d00"++ > LLN HHJ MMOHMMOs A9BB0cPtjtjtjd}|j|jtj|j |j tj|j d|jttdr|jd|j|jtj|jdtjddtjtjd} |jd|j |j |j |j|jy#|jwxYw)Nr SOCK_NONBLOCKr@r[)r[AF_INET SOCK_DGRAMassertIsfamilyrtypeprotor{r^r_r get_originalrH)rs std_sockets rtest_attributeszTestTCP.test_attributess MM&..&*;*;Q ? ahh/ !2!23 AGG$ 6? + LLO MM!((FNN 3 MM! @,,Xx@QWQbQbdefJ #&&q)  !&&9  "    "s ;7FF%chtjtjtj} |jd|j t j tjf}|j|t|jy#|jwxYw)NF) r[r SOCK_STREAMr_ connect_ex greentestDEFAULT_LOCAL_HOST_ADDRr find_unused_portassertIsInstance errno_typesrH)rrrets r*test_connect_ex_nonblocking_bad_connectionz2TestTCP.test_connect_ex_nonblocking_bad_connectionsr MM&..&*<*< =  MM% ,, A A7C[C[C]^_C  ! !#{ 3 GGIAGGIs ABB1Tries to resolve hostnamecftjtjtj} |jtj5|j dt jfddd|jy#1swYxYw#|jwxYwNzfoo.bar.fizzbuzz) r[rrrgaierrorrr rrHrrs rtest_connect_ex_gaierrorz TestTCP.test_connect_ex_gaierrors MM&..&*<*< = ""6??3 O 0'2J2J2LMN O GGI O O GGIs#B&B9BBBB0cfd}tjtjtj}jt5d|_ddd|j Gddtj}|tjtj}||y#1swY`xYw)Nc jtj5|jdt j fddd|j y#1swYxYw#|j wxYwr)rr[rrr rrH)rcrs rdo_itz7TestTCP.test_connect_ex_not_call_connect..do_itse &&v7VOO%79Q9Q9S$TUV VV s"A-&A!A-!A*&A--A?ceZdZdZy)3TestTCP.test_connect_ex_not_call_connect..Sctd)NzShould not be called)AssertionError)rrs rr\z;TestTCP.test_connect_ex_not_call_connect..S.connects$%;<cltjtjtj} |jd|j t 5|j tjdfddd|jy#1swYxYw#|jwxYw)NFi) r[rrr_r OverflowErrorrrrrHrs r$test_connect_ex_nonblocking_overflowz,TestTCP.test_connect_ex_nonblocking_overflows MM&..&*<*< =  MM% ""=1 I i??GH I GGI I I GGIs#&B!"B<B!BB!!B3 SOCK_CLOEXECzRequires SOCK_CLOEXECctj}tjtjtj|z}fd}t |} |j t jjf|jd}j|jd|j|j|jy#|jwxYw)Ncjj\}}|jd}|jd|j |j yr)rUrjrkrrHrs rrzATestTCP.test_connect_with_type_flags_ignored..accept_oncesGmm**,GD!D)B HHZ HHJ JJLr!rurgrhr)r[rrrrr\r r]rWrkrrrHr-)rrrrrrs` r$test_connect_with_type_flags_ignoredz,TestTCP.test_connect_with_type_flags_ignoreds ** MM&..&*<*<|*K L -  IIv--tyy9 :&B   R[[]J 7 HHJ GGI MMOHMMOs A=C''C9)NNNN)Nr)0r"r#r$ __timeout__r[rarr-rangestrr isinstancebytesencoderPrTrdrrrPY2rrrrrrrrrrrr skipOnWindowsrrrrrrrrrunittest skipUnlessr{r __classcell__).0rrrXs000@rr:r:KstKNNM 5<88a3q689I i '$$W- -3^?C#']0~+ ww >HI!J!'3 7= B*(,$"I-YQR&S&&,(( ;<= ;<=0X8022Y 9sD r:cVeZdZeZdZdZeje ddZ y)TestCreateConnectionc tj}|jtjd5tj t j|ffddi|dddy#1swYyxYw)Nz5refused|not known|already in use|assign|not availablera)r rassertRaisesRegexr[errorrdrDEFAULT_BIND_ADDR)r conn_args connect_ports r test_refusesz!TestCreateConnection.test_refusessp//1  # # H     $ $,,l;      s )A''A0cTtj}|jd|fy)N)source_address)r rr)r source_ports rtest_refuses_from_portz+TestCreateConnection.test_refuses_from_ports(..0  "k):;r!rclGddtGfddtd}ddlm}|j |j tj |j}|j } |_||_|j5tj dddd|j dtj|jjdjd _ ||_||_y#1swYlxYw#d _ ||_||_wxYw) Nc eZdZy)3TestCreateConnection.test_base_exception..EN)r"r#r$r%r!rErs r!rc0eZdZdZdZfdZfdZdZy).MockSocketr%Fc2xj|fz c_yr)created)rrp MockSockets rr zETestCreateConnection.test_base_exception..MockSocket.__init__$s""tg-"r!c|rr%)rrprs rr\zDTestCreateConnection.test_base_exception..MockSocket.connect's d r!cd|_y)NT)closedr0s rrHzBTestCreateConnection.test_base_exception..MockSocket.close*s " r!N)r"r#r$r r$r r\rH)rr!srr!rsGF .  #r!r!cdgS)N)r@r'r%)rps rmockgetaddrinfozATestCreateConnection.test_base_exception..mockgetaddrinfo-s #% %r!r)r`rWr@r%) BaseExceptionobject gevent.socketr[rrd getaddrinforrnr  assertTruer$)rr)gsocket orig_socketorig_getaddrinforr!s @@rtest_base_exceptionz(TestCreateConnection.test_base_exceptions      # # & ( 22F4L4LMnn ".. 3'GN"1G ""1% ;(()9: ;   QJ$6$6 7 8 OOJ..q188 9"$J (GN"2G  ; ;"$J (GN"2G s%0DD%ADDDD3N) r"r#r$r rrrrignores_leakcheckrr2r%r!rr r s9K.<   ;<*3=!*3r!r c<eZdZejdZdZdZy) TestFunctionscddlm}Gddt}|j|j5|j |ddddy#1swYyxYw)Nr)r[ceZdZdZdZy)+TestFunctions.test_wait_timeout..ioNc.tjdy)Nrw)r)r)rrNs rr8z1TestFunctions.test_wait_timeout..io.startOs R r!)r"r#r$callbackr8r%r!rior8Ls H !r!r;g{Gz?r)r)r[r+rrary)rr/r;s rtest_wait_timeoutzTestFunctions.test_wait_timeoutGsN - ! !   w / - LLtL , - - -s AAcg}tjr3|jd|jd|jdtjdddkr|jd|j d|y) N gethostbynamegethostbyname_ex gethostbyaddrr&)r' rdr[)exclude)rPYPYrBr version_info!assertMonkeyPatchedFuncSignatures)rrBs rtest_signatureszTestFunctions.test_signaturesVsl >> NN? + NN- . NN? +   BQ ' ) NN. / ..x.Ir!cddlmjjs|j dt jds|j dd}Gfddt }|j|j||y) Nr) _socketcommonz Needs IPv6 inet_ptonzNeeds inet_pton)z2607:f8b0:4000:80e::200ePr c(eZdZWjZy)6TestFunctions.test_resolve_ipv6_scope_id..sockN)r"r#r$AF_INET6r)SCsrrcrMrs [[Fr!rc) r)rH __socket__has_ipv6skipTestr{r+r _resolve_addr)raddrrcrOs @rtest_resolve_ipv6_scope_idz(TestFunctions.test_resolve_ipv6_scope_idhsh.}}%% MM, 'r}}k2 MM+ ,6 !6 ! dB,,T489r!N)r"r#r$rr3r<rFrUr%r!rr5r5Es%   -! -J$ :r!r5ceZdZdZdZdZy) TestSocketctj}|j|jtj5|j tj dddy#1swYyxYwr)r[rHrrr~rrs rtest_shutdown_when_closedz$TestSocket.test_shutdown_when_closedxsQ MMO    v|| , ) JJv'' ( ) ) )s  A--A6cddl}tj} |j|}|j||j y#|j wxYw)Nr)weakrefr[refassertIsNotNonerH)rr[rws rtest_can_be_weak_refzTestSocket.test_can_be_weak_refsC MMO  AA   # GGIAGGIs "A Actj} |jt5t|dddd|j y#1swYxYw#|j wxYw)N__dict__)r[rrrzrHrs rtest_has_no_dictzTestSocket.test_has_no_dictsV MMO "">2 ':& ' GGI ' ' GGIs!A AAAAA/N)r"r#r$rYr_rbr%r!rrWrWvs)r!rW__main__)- __future__rrr)r patch_allrrr[r>r functoolsrgevent._compatrgevent.testingtestingrrr r r gevent.testing.socketsr gevent.testing.skippingrrr2rr7rintrr+rr'is_module_patchedr4TestCaser:r r5rWr"mainr%r!rrps %&  ""("!/>1( ' ' %Z % v ,z7 F Ffi  fR O39--O3b/:I&&/:b##< zINNr!