<|hJddlmZddlZddlmZej ddlZddlZddlZddl Z ddl Z ddl m Z ddlmZddlmZddlmZej&j)ej&j+eZej&j/edZej2Ze j6Ze j8Ze Ze ZeZ e jBZ!ddl m"Z" ddl#Z#Gd d e jJZ&e jNd Gd d e&Z(e jNd Gdde&Z)Gdde*Z+Gdde+Z,e-dk(re j\yy#e$$rdZ#YwxYw))print_functionN)monkey)DEFAULT_BIND_ADDR_TUPLE)DEFAULT_CONNECT) tcp_listenerz2_7_keycert.pem)get_open_filescteZdZdZfdZdZeserejrdZ ndZ dZ dZ dZ d Zd ZxZS) Testc8d|_tt|yNr )extra_allowed_open_statessuperr tearDown)self __class__s ^/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__makefile_ref.pyrz Test.tearDown)s)+& dD"$c |}t d|d|#t$rH}|jdtjk(rYd}~ytr|jddk(rYd}~yd}~wwxYw)Nri6'zNOT RAISED EBADF: z () returned )OSErrorargserrnoEBADFWINAssertionError)rfuncresultexs rassert_raises_EBADFzTest.assert_raises_EBADF-sa VFT6RSS wwqzU[[(rwwqzU*   s  A+ A&A&%A&&A+cyNr )rfilenos r__assert_fd_openzTest.__assert_fd_open:s rcjt|tsJt}||vrt|d|dy)N is not open: data) isinstancefd_typesrrrr" open_filess rr#zTest.__assert_fd_openDs=fh/ //')JZ'$fjQWFX%YZZ(rct|tsJt||dkDsJ|td}||vrt |d|dy)NrF)count_closing_as_openz is not closed: r&)r'r(reprrrr)s rassert_fd_closedzTest.assert_fd_closedJsZ&(+9T&\9+z!6!z$%@ Z  FJvDV!WX X rc(t}|j}|dD]^}t|dd|k(s|jtj tj f|jzvsJ|jyt|d|d)Nr&laddrr%) r getsocknamegetattrstatuspsutil CONN_LISTENCONN_ESTABLISHEDrr)rsockr*socknamexs r_assert_sock_openzTest._assert_sock_openSs#% ##%F# Aq'4(H4xxF$6$68O8O#PSWSqSq#qq{sts{s{{q dJv.connect!!?D"9:rtarget) rYrr1rH running_task threadingThreadrEr"r?rMrF)rr[listenerri client_socketr"rkrls @@rtest_server_simplezTestSocket.test_server_simples Y .&l156H'')!,Dv}}/I ;    0 0 @ A"MM(3M"))+F   ]F 3    !   } - . . .s B?CCct5}|td}|jd|tjfd}|j t j ||j|}|j}||j}|j|||jtr|j||n"|j||j||j|j||dddy#1swYyxYw)Nr<rec4jtfyr!rhrjsrriz1TestSocket.test_server_makefile1..connectrmrrn)rYrr1rHrprqrrrEr"r^r?rMrCrF rr[rsrirtr"r`rkrls @@rtest_server_makefile1z TestSocket.test_server_makefile1s Y 6&l156H'')!,Dv}}/I ;    0 0 @ A#MM(3M"))+F}--/0A   ]F 3    !  7""=1  ( GGI   }f 53 6 6 6s D!D77Ec4t5}|td}|jd|tjfd}|j t j ||j|}|j}||j}|j|||j|j|||j|j||dddy#1swYyxYw)Nr<rec4jtfyr!rhrjsrriz1TestSocket.test_server_makefile2..connectrmrrn) rYrr1rHrprqrrrEr"r^r?rMrFrxs @@rtest_server_makefile2z TestSocket.test_server_makefile2s Y 6&l156H'')!,Dv}}/I ;    0 0 @ A"MM(3M"))+F}--/0A   ]F 3 GGI   ]F 3    !   }f 5' 6 6 6s C8DDN) rPrQrRr\rarcruryr|r rrrWrWs &'& *.$686rrWcTeZdZdZdZdZdZdZdddZd Z d Z d Z d Z d Z y)TestSSLc|jt|f tjj |}|j |j y#tj$rYywxYwr!) rirssl SSLContext wrap_socketwaitrMrHerror)rrkrlaccepted_eventr9s r_ssl_connect_taskzTestSSL._ssl_connect_tasksf?D12  ,,Y7A    ! GGI||    s3AA32A3ctj}tj|j|||f}d|_||_|S)N)rorT)rqEventrrrdaemonr)rrkrlrts r_make_ssl_connect_taskzTestSSL._make_ssl_connect_tasksE"*   D$:$:#,dN"C E)rcht5}||j}|j}|tjj |}|j}|j |||j|j||dddy#1swYyxYwr!) rYrOr"rrrr?rMrFrZs rr\zTestSSL.test_simple_closes Y *&t,,./AXXZFs~~'33A67AXXZF   Q ' GGI   q& ) * * *s BB((B1ct5}||j}|tjj |}|j }|j ||||j}|j |||j|j |||j|j|j||dddy#1swYyxYwr!) rYrOrrrr"r?r^rMrF)rr[raw_srNr"r`s rrazTestSSL.test_makefile1#s Y *&40023Es~~'33E:;AXXZF   Q 'qzz|$A   Q ' GGI   Q ' GGI KKM   q& ) * * * CC22C;ct5}||j}|j}|tjj |}|j}|j ||||j}|j |||j|j |||j|j||dddy#1swYyxYwr!) rYrOr"rrrr?r^rMrFr_s rrczTestSSL.test_makefile22s Y *&t,,./AXXZFs~~'33A67AXXZF   Q 'qzz|$A   Q ' GGI   Q ' GGI   q& ) * * *rF server_sidecvtj}|j|||j||S)N)certfilekeyfiler)rrload_cert_chainr)rr7rrrcontexts r _wrap_socketzTestSSL._wrap_socketBs7.."7C""4["AArc *t5}|td}|jd}|tj}|j ||}|j ||j |}|jj||j|ttd}|j}|j|||j|j||dddy#1swYyxYwNr<reT)rrr)rYrr1rHrrprErsetrCERTFILEr"r?rMrF)rr[rsrlrkrrtr"s rruzTestSSL.test_server_simpleGs Y 6&l156H'')!,Dv}}/I++It.connects{ "!!?D"9:NN$00;##% 56 6++, ! !s B BB0rnTtest_serverssl_makefile2)rr1rrrqrrHrrrrrrr"r?r^rDreadrMrr4CONN_CLOSE_WAITrrF) rrrsrirrtr"r`rrls @@rrz TestSSL.test_serverssl_makefile2s[#A. '')!,$$\8h$W"*$mmo "   G ,   8\ 2 6m    "))+F   ]F 3&&(A   ]F 3   QVVX'A B   QVVXr * GGIv282H2H1J.   ]F 3    !   }f 5! 6 6 6s (C;F,,F5N)rPrQrRrrr\rarcrruryr|rrr rrr~r~sA&* ** DIB 6(60626*%6rr~cPeZdZdZdZdZer erdZdZ ndZ dZeZ dZ d Z y ) rYcPg|_|D]}|j|d|_yr!)_objectsclosingtask)rinitis r__init__zClosing.__init__s*  A LLO  rcJ|j\}}|j|Sr!)rEr)rrsrt_addrs rrEzClosing.accepts"'0 u||M**rcL|j}t|dk(r|dS|S)Nr<r)objectslenros r __enter__zClosing.__enter__s& LLN q6Q;Q4K rcb|jjtj||Sr!)rappendweakrefrefrs rrzClosing.closings! MM Q 0HrcZ|jDcgc]}| |c}Scc}wr!)r)rrs rrzClosing.objectss"!%BA!#/ACB BBs ( (c>tt|jSr!)listreversedrrs rrzClosing.objectss/0 0rc<|jj||Sr!)rrrs rrzClosing.closings MM  #Hrcx|jJ||_|jj|jSr!)rr)rthreads rrpzClosing.running_tasks1yy     yyrcZ |j|jjd|_|jD]} |jd|_y#t$rY)wxYw#d|_|jD]"} |j#t$rY wxYwwxYwr )rjoinrrM Exceptionr)rrvtbrs r__exit__zClosing.__exit__s yy$  DI\\^ GGI   ! DI\\^ GGI  sA&A,A A)(A),B*BB* B% "B*$B% %B*N) rPrQrRrrErPY2CPYTHONrr__call__rprr rrrYrYs> +  w  C 1 H rrYc*eZdZfdZdZdZxZS)rcJtt| |g|||_||_yr!)rrrrrs)rrrs other_socketsrs rrzCleaningUp.__init__s% j$(BMB   rc8|j|jSr!)rErsrs rrzCleaningUp.__enter__s{{4==))rc\ tj||||d|_y#d|_wxYwr!)rYrrs)rrrrs rrzCleaningUp.__exit__s* !   T1a , DMDDMs" +)rPrQrRrrrrTrUs@rrrs! *!rr__main__)/ __future__rosgeventr patch_allrHrrqrrgevent.testingtestingrJgevent.testing.paramsrrgevent.testing.socketsrpathdirnameabspath__file__rrgetpidpidrCrSrrintr(rrr4 ImportErrorTestCaser skipOnAppVeyorrWr~objectrYrrPmainr rrrsq% +6++-  #91/ ''//"''//(3 4 77<<!2 3biikmm~~( g mm)c9  cLLMl6l6Nl6^LMJ6dJ6NJ6ZGfGR!!$ zINNK Fs"E))E32E3