ilG%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r J r SSKrSSKrSSKJrJr \ (a&SSKrSSKJr SSKJrJr SSKJr SSKJrJr SS KJr \R>\R@-r!S \"S 'S S jr#S!S jr$S!Sjr%S"Sjr&S#Sjr'\RP"SS55r)\RP"SS55r*\RP"SS55r+\RP"SS\RXRZ55r.\RP"SS\RXR^55r0\"SS55r1\"SS\R Rd\S95r3g)$) annotationsN) TYPE_CHECKINGAnyNoReturn TypeAliasoverload)NoPublicConstructorfinal)Iterable) AddressFamily SocketKind) TracebackType)BufferSelf) AddressFormatr IPAddressc[U[R5(a[RR $[U[R 5(a[RR$[S5e)Nz!Unhandled IPAddress instance type) isinstance ipaddress IPv4AddresstriosocketAF_INET IPv6AddressAF_INET6NotImplementedError)ips CC:\des-py\RoboSAPF\venv\Lib\site-packages\trio/testing/_fake_net.py _family_forr%sT"i++,,{{""" B -- . .{{### A BBcU[RR:Xa[R"S5$U[RR :Xa[R"S5$[ S5e)N0.0.0.0::Unhandled ip address familyrrrr ip_addressrrfamilys r_wildcard_ip_forr)-sT $$$##I.. 4;;'' '##D)) ; <s $ D) **r cSnUH^nXU[U5R-n[U5nXES[U5&SSS5 U[U5- nU[U5:XdM] U$ U$!,(df  N4=f)Nr) memoryviewnbyteslen)databufferswrittenbuf next_piecembufs r_scatterr?BsxGGjo.D.D$DE _&0"3z? #3z?" c$i   N N _s A)) A7 cP\rSrSr%S\S'S\S'S Sjr\S Sj5rSrg ) UDPEndpointNrrintportcURRUR4n[UR[R 5(aUS- nU$)Nrr)r compressedrDrrr)selfsockaddrs ras_python_sockaddrUDPEndpoint.as_python_sockaddrSsF GG   IIA  dggy44 5 5  Hr cFUSSup#U"[R"U5US9$)N)rrD)rr&)clsrIrrDs rfrom_python_sockaddr UDPEndpoint.from_python_sockaddr\s) BQ<i**2.T::r Nreturn+tuple[str, int] | tuple[str, int, int, int])rIrTrSrA) __name__ __module__ __qualname____firstlineno____annotations__rJ classmethodrO__static_attributes__rQr rrArANs7M I;=; ;;r rAc \rSrSr%S\S'Srg) UDPBindingerAlocalrQN)rUrVrWrXrYr[rQr rr]r]es r r]c`\rSrSr%S\S'S\S'\R "SS9rS\S'S S jrS r g ) UDPPacketkrAsource destinationc"UR5$r/)hex)ps rUDPPacket.os r )reprbytespayloadc@[URURUS9$)Nrcrdrl)rardrc)rHrls rreplyUDPPacket.replyrs"##   r rQN)rlrkrSra) rUrVrWrXrYattrsfieldrlror[rQr rraraks' [[&78GU8 r rac*\rSrSr%S\S'SSjrSrg)FakeSocketFactoryzFakeNetfake_netcD[RURXU5$r/) FakeSocket_createrw)rHr(type_protos rrFakeSocketFactory.socket~s!!$--FFr rQN)r(rCr{rCr|rCrSry)rUrVrWrXrYrr[rQr rrtrtzsGr rtcf\rSrSr%S\S'SS SjjrS SjrSrg) FakeHostnameResolverrvrwc # [S5e7fNzFakeNet doesn't do fake DNS yetr)rHhostrDr(typer|flagss r getaddrinfo FakeHostnameResolver.getaddrinfos"""CDD c # [S5e7frr)rHrIrs r getnameinfo FakeHostnameResolver.getnameinfos ""CDDrrQN)rrrr)rz bytes | NonerDzbytes | str | int | Noner(rCrrCr|rCrrCrSzqlist[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]])rIrTrrCrSztuple[str, str])rUrVrWrXrYrrr[rQr rrrs EE'E E  E  EE E&E=EE  Er rcF\rSrSrS SjrS SjrS SjrS SjrS SjrSr g) rvc[R"S5R5Ul[R"S5R5Ul[ [SS55Ul0Ul SUl g)Nz 1.0.0.0/8z1::/16iPi) r IPv4Networkhosts_auto_ipv4_iter IPv6Network_auto_ipv6_iteriterrange_auto_port_iter_bound route_packetrHs r__init__FakeNet.__init__s](44[AGGI(44X>DDF#E%$7846  r cpXR;a[[R5 X RU'gr/)rr4errno EADDRINUSE)rHbindingrs r_bind FakeNet._binds& kk ! e&& '% Gr c[RR[U55 [RR [ U55 gr/)rrset_custom_socket_factoryrtset_custom_hostname_resolverrrs renableFakeNet.enables2 --.?.EF 001Ed1KLr cdURcURU5 gURU5 gr/)rdeliver_packetrHpackets r send_packetFakeNet.send_packets*    $    '   f %r c[URS9nX R;aURURU5 gg)Nr_)r]rdr_deliver_packet)rHrrs rrFakeNet.deliver_packets86#5#56 kk ! KK 0 0 8 r )rrrrrNrSNone)rr]rryrSrrrarSr) rUrVrWrXrrrrrr[rQr rrvrvs!& M& r rvct\rSrSrS+Sjr\S,Sj5r\S-Sj5r\S.Sj5rS/Sjr S/Sjr S0Sjr S1S jr S2S jr S3S jrS4S5S jjr\R"S:wd\(d\"\R(S5(a\rS6S7Sjjr\R"S:wd\(d\"\R(S5(a\rS8SjrS8Sjr\S9Sj5r\S:Sj5rS;SSj5rS;S?SjjrS@SjrSASjrSBSCSjjr\SDSj5r \SESj5r SFSjr SBSGSjjr!S6SHS jjr"SBSIS!jjr#S6SJS"jjr$S6SKS#jjr%\R"S:wd\(d\"\R(S5(a\%r&S.S$jr'S.S%jr(SLS&jr)SMS'jr*\R"S:Xd\(d#\"\R(S(5(aSNS)jr+S*r,g S*r,g S*r,g )OrycXlU(d[RRnU(d[RRnU[RR[RR 4;a[ SU35eU[RR:wa[ SU35eX lX0l X@l SUl [R["[S55uUlUlSUlg)Nz%FakeNet doesn't (yet) support family=z#FakeNet doesn't (yet) support type=Finf) _fake_netrrr SOCK_STREAMrr SOCK_DGRAM_family_type_proto_closedopen_memory_channelrafloat_packet_sender_packet_receiver_binding)rHrwr(rr|s rrFakeSocket.__init__s"[[((F;;**D $++--t{{/C/CD D%(MfX&VW W 4;;)) )%(KD6&RS S    595M5M 6 ,62T2 ,0 r cUR$r/)rrs rrFakeSocket.types zzr cUR$r/)rrs rr(FakeSocket.familys ||r cUR$r/)rrs rr|FakeSocket.protos {{r cZUR(a[[R5 ggr/)rr4rEBADFrs r _check_closedFakeSocket._check_closeds << ekk " r cUR(agSUlURb!URRUR URR 5 g)NT)rrrrrclosers rrFakeSocket.closesE <<  == $%%dmm4 ##%r c # [RRURURUR USUS9IShvN $N7f)NF)address ipv6_v6onlyr_)r_socket_resolve_address_nocprr(r|)rHrr_s rr FakeSocket._resolve_address_nocpsK \\77 II KK JJ 8    sAA A A c[R"[R5 URR U5 SSS5 g!,(df  g=fr/) contextlibsuppressrBrokenResourceErrorr send_nowaitrs rrFakeSocket._deliver_packets6  !9!9 :    + +F 3; : :s A  Ac# UR5 URb[[R5 [ R R5IShvN URUSS9IShvN tp#nU/:XdS5e[R"U5n[U5UR:XdeU[R"S5:Xa[R"S5nO0U[R"S5:Xa[R"S5nUS:Xa[URR5n[![#XS5S9nURR%X`5 X`lgGNGN7f) NTrzTODO: handle other values?r"r+r#r,r)rrr4rEINVALrlowlevel checkpointrrr&rr(nextrrr]rAr)rHaddrip_strrD_rrs rbindFakeSocket.binds!  == $ ell #mm&&(((!%!;!;D!;!MMqBw444w  ! !& )2$++--- %%i0 0%%k2B 9''- -%%e,B 19667D;r#89 W+  )Ms%AE7E1E72E43C?E74E7c # [S5e7f)Nz0FakeNet does not (yet) support connected socketsr)rHpeers rconnectFakeSocket.connect,s!"TUUrNc# UR5 [RR5IShvN UbUR USS9IShvN nU(a [ S5eU(a[ SU35eUc[ [R5 [RU5nURc8UR[UR5RS45IShvN SR!U5nURce[#URR$UUS9nUR&R)U5 [+U5$GN"GN No7f)NFr&FakeNet doesn't support ancillary dataz"FakeNet send flags must be 0, not rr rn)rrrrrrr4rENOTCONNrArOrrr)r(rGjoinrar_rrr8)rHr:ancdatarrrdrlrs r_sendmsgFakeSocket._sendmsg/s( mm&&(((   66we6LLG %&NO O %(J5'&RS S ? enn %!66w? == ))-dkk:EEqIJ J J((7#}}(((==&&#  ""6*7|9 )M Ks52EEEEBE,E-A*EEEwin32sendmsgc# US:wa [S5eUS:wa [S5eURc [S5eUR5 /nSnURR 5IShvN nUR R 5n[URU5nU[UR5:aU[RR-nXXW4$Nn7f)Nrrz&FakeNet doesn't support any recv flagszThe code will most likely hang if you try to receive on a fakesocket without a binding. If that is not the case, or you explicitly want to test that, remove this warning.) rrrrreceivercrJr?rlr8rr MSG_TRUNC) rHr: ancbufsizerr msg_flagsrrr;s r _recvmsg_intoFakeSocket._recvmsg_into[s ?%&NO O A:%&NO O == &2  02 ,,4466--2246>>73 S( ( .. .I33 7sA,C.C/A/Cc,UR5 URb$URRR5$UR[ R R:XagUR[ R R:Xdeg)N)r"r)r#r) rrr_rJr(rrrrrs r getsocknameFakeSocket.getsocknamesi  == $==&&99; ; [[DKK// /!;;$++"6"66 66r cUR5 URb[URS5(dS5eURRbT[ URR[ 5(dS5eURRR 5$[[R5 g)NremotezGThis method seems to assume that self._binding has a remote UDPEndpointz,Self._binding.remote should be a UDPEndpoint) rrhasattrrrrArJr4rrrs r getpeernameFakeSocket.getpeernames  == $  YY Y}}##/!MM((BBB}}++>>@@%..!r cgr/rQ)rHleveloptnames r getsockoptFakeSocket.getsockopts>Ar cgr/rQrHrrbuflens rrr sMPr cFUR5 [SUSUS35e)Nz%FakeNet doesn't implement getsockopt(, ))rr0r s rrr s+ =eWBwiqQRRr cgr/rQ)rHrrvalues r setsockoptFakeSocket.setsockoptsTWr cgr/rQrHrrroptlens rrrsr cUR5 X4[RR[RR4:XaU(d [ S5e[ SUSUS35e)Nz#FakeNet always has IPV6_V6ONLY=Truez%FakeNet doesn't implement setsockopt(rz, ...))rrr IPPROTO_IPV6 IPV6_V6ONLYrr0rs rrrsf    KK $ $ KK # #  %&KL L=eWBwivVWWr cU$r/rQrs r __enter__FakeSocket.__enter__s r c$UR5 gr/)r)rHexc_type exc_value tracebacks r__exit__FakeSocket.__exit__s r cB# URXS5IShvN $N7fr/)sendto)rHr9rs rsendFakeSocket.sends[[d3333s c # g7fr/rQ)rH_FakeSocket__data_FakeSocket__addresss rr$FakeSocket.sendtos c # g7fr/rQ)rHr(_FakeSocket__flagsr)s rr$r*s r+c# [U5S:XaUup#SnO [U5S:XaUup$nO [S5eURU//XC5IShvN $N7f)NrMrzwrong number of arguments)r8 TypeErrorr)rHargsr9rrs rr$r*sZ t9> MDE Y!^#' D78 8]]D62u>>>>sAAAAcH# URX5IShvN up4U$N7fr/)recvfrom)rHbufsizerr9_addresss rrecvFakeSocket.recvs"#}}W<< =s "  "cJ# URXU5IShvN upEU$N7fr/) recvfrom_into)rHr<r7r got_bytesr5s r recv_intoFakeSocket.recv_intos)$($6$6sE$JJ Ks #! #cL# URX5IShvN up4pVX64$N 7fr/)_recvmsg)rHr4rr9_ancdata _msg_flagsrs rr3FakeSocket.recvfrom s+ 59MM'4Q.Q+ }/Rs $" $c# US:wa$U[U5R:wa [S5eURU/SU5IShvN upEpgXG4$N 7f)Nrzpartial recvfrom_into)r6r7rr)rHr<r7r got_nbytesr?r@rs rr9FakeSocket.recvfrom_intos` Q;6Z_%;%;;%&=> >:>:L:L E ; 5 1 j "" 5 sAAA Ac# [U5nURU/UU5IShvN upVpx[USU5XgU4$N7fr/) bytearrayrrk) rHr4rrr<rCrrrs rr>FakeSocket._recvmsg#sV  8<8J8J E  9 3 / Y c+:&'WEE 3 s#A>Ac[S5e)Nz&can't get fileno() for FakeNet socketsrrs rfilenoFakeSocket.fileno6s!"JKKr c[S5e)Nzcan't detach() a FakeNet socketrrs rdetachFakeSocket.detach9s!"CDDr cg)NFrQrs rget_inheritableFakeSocket.get_inheritable<sr c(U(a [S5eg)Nz&FakeNet can't make inheritable socketsr)rH inheritables rset_inheritableFakeSocket.set_inheritable?s %&NO O r sharec[S5e)NzFakeNet can't share socketsr)rH process_ids rrUFakeSocket.shareGs%&CD Dr )rrrrrrrr) rwrvr(r rr r|rCrSr)rSr )rSr )rSrCr)robjectr_boolrSztuple[str, int]r)rrYrSr)rrYrSr)rQrN) r:Iterable[Buffer]rz!Iterable[tuple[int, int, Buffer]]rrCrzAddressFormat | NonerSrCrF)r:r[rrCrrCrSzZtuple[int, list[tuple[int, int, bytes]], int, tuple[str, int] | tuple[str, int, int, int]]rR)rrCrrCrSrC)rrCrrCr rCrSrkr/)rrCrrCr  int | NonerSz int | bytes)rrCrrCrz int | BufferrSr) rrCrrCrrrrCrSr) rrCrrCrzint | Buffer | Nonerr\rSr)rSr)rz#builtins.type[BaseException] | NonerzBaseException | Noner zTracebackType | NonerSr)r)r9rrrCrSrC)r(rr)z!tuple[object, ...] | str | BufferrSrC)r(rr-rCr)z(tuple[object, ...] | str | Buffer | NonerSrC)r1rrSrC)r4rCrrCrSrk)r<rr7rCrrCrSrC)r4rCrrCrSztuple[bytes, AddressFormat])r<rr7rCrrCrSztuple[int, AddressFormat])r4rCrrCrrCrSz>tuple[bytes, list[tuple[int, int, bytes]], int, AddressFormat])rSrZ)rRrZrSr)rWrCrSrk)-rUrVrWrXrpropertyrr(r|rrrrrrrsysplatformrrrrr recvmsg_intorrrrrrr!r%r$r6r;r3r9r>recvmsgrIrLrOrSrUr[rQr rryrys"000 0  0  0@#&        4 *V 68(, %!%3% % & % %N ||w gfmmY??  "4!"4"4 "4   "4H ||w gfmmY??$  "AA PP" SS S  S  SWW       " XX X # X  X X,5((   45 <  ?? ?  %  #  # # # # #$ F F F F H F ||w gfmmY??LEP ||w gfmmW== E>Mr ry) metaclass)rrrSrC)r(rCrSr)r3rCrSr)r9rkr:r[rSrC)4 __future__rrrrr1rr^typingrrrrrrqr trio._utilr r builtinscollections.abcr r r typesrtyping_extensionsrr trio._socketrrrrrYrr)r-r4r?frozenrAr]raabc SocketFactoryrtHostnameResolverrrv SocketTyperyrQr rrpsl#  DD 1(0#.* ,,y/D/DD 9DC==+ ;;;,      G..GGE48844EE<   FBE''3FBEBEr