qiHSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK Jr SSKrSSKrSSKrSSKJr SSKJrJrJrJrJrJr SSKJrJrJr SSKJ r J!r!J"r"J#r# SS K$J%r% \=(d \r&\RNSSS :*r(\RRRU\+"\S 5(+S S 9r,\RRRU\SS 9r-\R\"SS9S5r/\R\S5r0\R\S5r1Sr2Sr3\RRRiS\5\6\7\845S5r9Sr:\RRRiS\ \!45S5r;\,S5r<\,S5r=Sr>Sr?"SS \5r@\R\S!5rA\,\-\RRRS"SS#9S$555rC\RRRU\(+S%S 9\,\-S&555rD\RRRU\S'S 9\RRRiS(S)S*S+9\RRRS,5S-555rF\RRRU\+"\S.5(+S/S 9\RRRiS\ \!45S055rG\R\S15rH\R\S25rI\R\S35rJ\RRRiS4S5S6\K"S754S5S8\K"S754S9S:S5\K"S75\K"S754SS6\K"S754SS8\K"S754S;S\K"S75\K"S7544 5S<5rL\RRRiS=S>5S?5rMS@rNSArOSBrPg)CzTests for the HTTP server.N) HTTPStatus) DefaultGc)IS_LINUXIS_MACOS IS_WINDOWS SYS_PLATFORMbtonntob)IS_UID_GID_RESOLVABLEGateway HTTPServer)ANY_INTERFACE_IPV4ANY_INTERFACE_IPV6EPHEMERAL_PORTSUCCESSFUL_SUBPROCESS_EXIT) ThreadPool)AF_UNIXz:UNIX domain sockets are only available under UNIX-based OSreasonz9Peercreds lookup does not work under macOS/BSD currently.)abstractfile)paramsc[(a[R"S5 SR"S0[ 5D6nUR U5$)9Check that bound UNIX socket address is stored in server.z1`requests-unixsocket` is defunct under Python 3.8zunix_{request.param}_sock) PY38_OR_LOWERpytestskipformatlocalsgetfixturevalue)requestnames M/home/kali/flask_env/lib/python3.13/site-packages/cheroot/test/test_server.pyunix_sock_filer(1s>}  GH & - - 9 9D  " "4 ((c [(d[R"[S35 SR S[ [ [R"55545R5$)z'Return an abstract UNIX socket address.z. does not support an abstract socket namespacer)scheroot-test-socket) rr r!r joinr struuiduuid4decoderr)r'unix_abstract_sockr0=sW 8 nJ K  88 & TZZ\" #    fh r)c## [R"5upUv [R"U5 [R"U5 g7f)zYield a UNIX file socket.N)tempfilemkstemposcloseunlink) tmp_sock_fhtmp_sock_fnames r'unix_file_sockr9Ls6#+"2"2"4K HH[IInsA A c[[[4[S9nUR(aeUR R (aeUR5 UR(deUR R (deUR R HnUR(aMe UR5 UR R (aeUR(aeg)zBCheck that prepare() makes the server ready, and stop() clears it. bind_addrgatewayN) rrrr readyrequests_threadspreparestop) httpserverthrs r'test_prepare_makes_server_readyrEWs%~6J  ""+++ +        ' '' '""++yyyy,OO""+++ + r)cp[[[4[S9nUR 5 [ R "URS9nUR5 URS5 UR5(deUR5 URS5 UR5(aeg)0Check that stop() interrupts running of serve().r;target?N) rrrr rA threadingThreadservestartr+is_aliverB)rC serve_threads r'test_stop_interrupts_serverQns%~6J ##:+;+;TR5 g!Ta/n[U5T:XaTRT5 SnAgSnAgSnAff=fN)rMr,put)erRrC interrupt_msgraise_marker_sentinelresult_qs r'rP+test_server_interrupt..serve_threadsE 4     41v& 233' 4sA  AA rHrJN)r-r.objectrrrr queueQueuerArKrLrNr+rO interrupt get_nowait)rRrPrCrXrYrZs` @@@@r'test_server_interruptras$DJJL#34M"H%~6J {{}H44##<8Lc  " "" "#=1Jc$$&&& &    $9 99 9r)c[[[4[S9nUR 5 SnXR R l[R"URS9nUR5 URUR[(aSOS-5 UR5(aeUR R (aeUR#5 g)rGr;c[erU)KeyboardInterrupt)argskwargss r'raise_keyboard_interruptTtest_serving_is_false_and_stop_returns_after_ctrlc..raise_keyboard_interruptsr)rHrN)rrrr rA _connections _selectorselectrKrLrMrNr+expiration_interval IS_SLOW_ENVrO_servingrB)rCrgrPs r'2test_serving_is_false_and_stop_returns_after_ctrlcrps%~6J  0H%%,##:+;+; 11 1r)cJURU5nURU:Xdeg)zBCheck that bound UNIX abstract socket address is stored in server.Nrx)rur0rCs r'test_bind_addr_unix_abstractr|s*!!"45J   #5 55 5r)z/peer_creds/idsz/peer_creds/textsc.^\rSrSrU4SjrSrSrU=r$) _TestGatewayc>URnURn[UR5nU[:XaRUR UR UR4nURSR[[U555 gU[:Xa7URSRURUR455 g[[ U]G5$)N|!)reqconnr uriPEERCRED_IDS_URIpeer_pidpeer_uidpeer_gid send_payloadr+mapr,PEERCRED_TEXTS_URI peer_user peer_groupsuperr~respond)selfrrreq_uri peer_creds __class__s r'r_TestGateway.respondshhxxsww- & & t}}DJ   chhs3 ';< = ( (   chh'HI J\4022r)c~URnSUlUR5 UR[ U55 g)Ns200 OK)rstatusensure_headers_sentwriter )rpayloadrs r'r_TestGateway.send_payloads.hh  ! $w- r)r)__name__ __module__ __qualname____firstlineno__rr__static_attributes__ __classcell__)rs@r'r~r~s 3!!r)r~cLURU5n[UlSUlU$)z3Construct a test server with ``peercreds_enabled``.T)rtr~r=peercreds_enabledrys r'peercreds_enabled_serverrs*!!.1J%J#'J r)r)reruns reruns_delaycUnURn[U[5(aUR5n[R R USS9nSR"S0[5D6n[R"5[R"5[R"54nSR[[U55n[ R""5 [$R&"U[(-US9nUR+5 UR,U:Xde[$R&"U[.-US9nUR0S:XdeSSS5 g!,(df  g=f) z2Check that ``PEERCRED`` lookup works when enabled.safehttp+unix://{quoted}rtimeoutiNr)r< isinstancebytesr/urllibparsequoter"r#r4getpidgetuidgetgidr+rr,requests_unixsocket monkeypatchr?getrraise_for_statustextr status_code) http_request_timeoutrrCr<quoted unix_base_uriexpected_peercredspeercreds_resppeercreds_text_resps r'test_peercreds_unix_sockr s *J$$I)U##$$& \\     3F*11=FH=Mbiik299;>#c+=">?  ( ( *! , ,(  '')""&8888&ll . .( #..#555 + * *s A-E E#zDModules `grp` and `pwd` are not available under the current platformcUnSUlURn[U[5(aUR 5n[ R RUSS9nSR"S 0[5D6nSSK nSSK nUR[R"55RUR![R""55R$4nSR'[)[*U55n[,R."5 [0R2"U[4-US9n U R75 U R8U:XdeSSS5 g!,(df  g=f) z6Check that ``PEERCRED`` resolution works when enabled.TrrrrNrrr)peercreds_resolve_enabledr<rrr/rrrr"r#grppwdgetpwuidr4rpw_namegetgrgidrgr_namer+rr,rrr?rrrr) rrrCr<rrrrexpected_textcredsrs r'$test_peercreds_unix_sock_with_lookupr-s*J+/J($$I)U##$$& \\     3F*11=FH=M RYY[!)) RYY[!))#c+=">?  ( ( *&ll . .(  ,,."''+==== + * *s ?E E"z\This regression test is for a Linux bug, and the resource module is not available on Windowsresource_limit)ii)r)indirectmany_open_socketsc(^^^URRmUU4Sjm[5TlTURlUR S5 [ TR5S:de[ U4SjTR55(deg)a*Test the server does not crash with a high file-descriptor value. This test shouldn't cause a server crash when trying to access file-descriptor higher than 1024. The earlier implementation used to rely on ``select()`` syscall that doesn't support file descriptors with numbers higher than 1024. cz>TRRURR55 T"U5$rU)filenosaddsocketfileno)r_old_process_connnative_process_conns r'rAtest_high_number_of_file_descriptors..native_process_connss/##'' (:(:(<= &&r)/rc3,># UH oT:v M g7frUr).0fnrs r' 7test_high_number_of_file_descriptors..sJ.I^#.IsN)server_instance process_connsetrconnectlenany)native_server_clientrrrs `@@r'$test_high_number_of_file_descriptorsrVs6-<<II'#&%8K((5  % "** +a // / J.A.I.IJ J JJ Jr) SO_REUSEPORTz5socket.SO_REUSEPORT is not supported on this platformc[R"U[5SSn[R"U5nUR[R[R S5 UR U[45 [UR5SS[SS9nURUS5nUR5 UR5 UR5 URbeg)z5Check that port initialized externally can be reused.rrsNrT)r<r= reuse_portrA)r getaddrinfor setsockopt SOL_SOCKETrbindr getsocknamer spyrArBr5 spy_exception)rurqmockerfamilysserverrs r'test_reuse_portrs   8 ;A >F fALL""F$7$7;FFG^ $% --/"1%F **VY 'C NN KKMGGI    $$ $r)c#x# [5R5 Sv SSS5 g!,(df  g=f7f)z7Disable garbage collection when this fixture is in use.N)rnogcrr)r' _garbage_binrs#        s:) : 7:c#b# [R"SSS9nURUR5up#UR URUR S-U45 UR v UR URX#45 g!UR URX#45 f=f7f)z7Set the resource limit two times bigger then requested.resourcez&The "resource" module is Unix-specificrrN)r importorskip getrlimit RLIMIT_NOFILE setrlimitparam)r%r soft_limit hard_limits r'rrs""7H &//0F0FGJ    J' Mmm 811J3KL811J3KLsAB/!B /B/ B,,B/c#z# URS5 /n[U5H?n[R"5nURU5 UR 5U:dM? O USR 5nXQ:deUv UHnUR 5 M g!UHnUR 5 M f=f7f)z4    B 66Z   66& && &r)r r error) )rrmin=-1 must be > 0)rrr)rrsr)rrr)rrmin=0 must be > 0)rrr)rrsr)rrr)rsrKExpected an integer or the infinity value for the `max` argument but got 0.)rsrJzMExpected an integer or the infinity value for the `max` argument but got 0.5.)rrr)r1zMExpected an integer or the infinity value for the `max` argument but got '1'.)rrszmax=1 must be > min=2c[R"[[4US9 [ SUUS9 SSS5 g!,(df  g=f)zTest that a ThreadPool rejects invalid min/max values. The ThreadPool should raise an error with the proper message when initialized with an invalid min+max number of threads. matchNr)r raises ValueError TypeErrorrrs r'#test_threadpool_invalid_threadranger"s5P  I.e <  = < )typesSimpleNamespace)rs r'7test_threadpool_multistart_validation..>s%''d3r)N)rz%Threadpools can only be started once.r)setattrrrNr r RuntimeError)rrs r'%test_threadpool_multistart_validationr,3s]3 4 BHHJ 5      s A%% A3cSn[U[4[S9n[SSSSUS9UlUR 5 [ R"URS9nUR5 URUR5 URR5 URupEURRRS5 [R"SUS U3S S 9nUR ["R$:Xdeg) zCA server that can't keep up with requests returns a 503 HTTP error.z 127.0.0.1r;rsr)rraccepted_queue_sizeaccepted_queue_timeoutrrHNzhttp://:r)rrr rr?rArKrLrMrN addfinalizerrBr<_queuerVrrrSERVICE_UNAVAILABLE)r% localhostrCrP_hostportresponses r',test_overload_results_in_suitable_http_errorr9JsIn-J %   J##:+;+;r\sZ      )NN?? ,$*   !$. kk(( "" G) kk(( F) +,)-)   .'(  !:!:H8 552266%(!7!*!!,6-6< ! > >D : ! ,-K. KB'' B % %$ MM2  85   %L   Be  E%L%,' Be  Be  E%L%,'( ')( ')!D  E!D  .BB