<|hBddlmZddlmZddlZddlmZddlmZddlmZddl m Z ddl m Z dZ d Z Gd d ejZGd d ejZej"dGddej$Zedk(rej*yy))print_function)absolute_importN)socket)backdoor)DEFAULT_BIND_ADDR_TUPLE)DEFAULT_CONNECTcd}t|tsJ|j|s;|jd}|st d|d|||z }|j|s;t|t r|S|j dS)NzConnection ended before z . Data read: zutf-8) isinstancebytesendswithrecvAssertionErrorstrdecode)connpostfixreadresults Z/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__backdoor.py read_untilr s{ D gu %% %mmG$1 QXZ^!_` `  mmG$ dC(4Bdkk'.BBr cn|j5}|jcdddS#1swYyxYwN)makefilereadline)rfs rrrs+ Azz|s+4ceZdZdZy)WorkerGreenletN)__name__ __module__ __qualname__spawning_stack_limitr rrrsr rc.eZdZdZfdZdZdZxZS)SocketWithBannerbannerc:d|_tt||i|yr)r)superr'__init__)selfargskwargs __class__s rr,zSocketWithBanner.__init__#s  .??r c@tjj|Sr)r __enter__)r-s rr2zSocketWithBanner.__enter__'s}}&&t,,r cFtjj||||Sr)r__exit__)r-tvtbs rr4zSocketWithBanner.__exit__*s}}%%dAq"55r )r!r"r# __slots__r,r2r4 __classcell__r0s@rr'r' sI@-6r r'aWith the update to libev 4.31 and potentially closing sockets in the background, alternate tests started hanging on appveyor. Something like .E.E.E. See https://ci.appveyor.com/project/denik/gevent/build/job/n9fynkoyt2bvk8b5 It's not clear why, but presumably a socket isn't getting closed and a watcher is tied to the wrong file descriptor. I haven't been able to reproduce. If it were a systemic problem I'd expect to see more failures, so it is probably specific to resource management in this test.ceZdZdZfdZdZdZdZddZe jddZ d Z d Z d Zd Zd ZxZS)Test cRtjtt|yr)geventsleepr+r<tearDown)r-r0s rrAz Test.tearDown;s  dD"$r c`tjtg|i|}|j|Sr)rBackdoorServerrstart)r-r.r/servers r_make_and_start_serverzTest._make_and_start_server?s+(()@R4R6R  r ct}|jt|jf |j |}||_|S#|j xYwr)r'connectr server_port_wait_for_promptcloser))r-rErr)s r_create_connectionzTest._create_connectionDsW! ov'9'9:; **40F     JJL s AAct|dS)N>>> )r)r-rs rrJzTest._wait_for_promptPs$((r c|j|t|}|j|d|jy)N)sendallr assertEqualrK)r-rcmdlines r_closez Test._closeSs0 S~ r" r zcSometimes fails to get the right answers; https://travis-ci.org/github/gevent/gevent/jobs/692184822cj5fd}tdDcgc]}tj|}} t j |d}t j |dj t|t||dddycc}w#t j |dwxYw#1swYyxYw)Ncj5}|jdt|}j|j dt |j |dddy#1swYyxYw)Ns2+2 4)rLrQrrRstripreprrU)rrTr-rEs rrHz Test.test_multi..connect_se,,V4&LL,#D>D$$TZZ\3T CKK% &&&s AA44A=r=T) raise_errorF)rFrangerspawnr?joinallrRlen)r-rH_jobsdonerEs` @r test_multizTest.test_multiYs  ( ( * 9f & :BB c6|j5}|j|5}|jdt|d}|j |dddddd|j t dd|zy#1swY2xYw#1swY6xYw)Nslocals()["__builtins__"] rNi,zlocals() unusable: %s...)msg)rFrLrQrrU assertLessr_)r-rErresponses r test_builtinszTest.test_builtinss  ( ( * "f((0 "D <=%dG4 D! " "  M3*X5  7  " " " "s"B/BBB BBcpddlmmfd}|jd|i5}|j |5}|j d|j |}|j|ddddddjdd}|jd |y#1swY6xYw#1swY:xYw) Nr)QueueEmptyc}td |jddtdtjdtdy#$rtdY>wxYw)Nzswitching out, then throwing inTg?)blocktimeoutz Got Emptyz switching outz switched in)printgetr?r@)qrtrss rbadz!Test.test_switch_exc..bads_A 3 4 #D#. / " LL  -  #k" #sAA'&A'r{)localssbad() z  zHswitching out, then throwing in Got Empty switching out switched in >>> ) gevent.queuersrtrFrLrQrJrUreplacerR)r-r{rErrprtrss @@rtest_switch_exczTest.test_switch_excs- ! ( ( ( = "((0 "D \*006 D! " " ##FD1  Z    " " " "s"B,4B +B, B) %B,,B5)s quit() ))r!r"r# __timeout__rArFrLrJrU greentest skipOnMacOnCIrcrgrirlrqrr9r:s@rr<r<.seK% ) Y D9 9"" B Q 7r r<__main__) __future__rrr?rrgevent.testingtestingrgevent.testing.paramsrrrrGreenletrr'skipOnAppVeyorTestCaser<r!mainr%r rrs%& "91 C V__ 6v}} 6m9  mm` zINNr