§ F2jþ®ãóR—UdZddlmZddlZddlZddlZddlZddlZddlm Z ddl Z ddlmZm Z dZejd¦«Zd ed <ejd¦«Zd ed<d Zd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<ejdkZd ed<ejdvZd ed<eedd ¦«Zd ed!<eed"d¦«Zd ed#<eed$d¦«Z d ed%<e!ed&¦«rej"ej#¦«Z$d ed'<ndZ$dpd,„Z%dpd-„Z&dqd3„Z'drd5„Z(dsd8„Z)dtd<„Z* dudvdA„Z+GdB„dCe,¦«Z-e.dD„eedEd¦«eedFd¦«eedGd¦«eedHd¦«fD¦«¦«Z/d edI<e.dJ„eedKd¦«eedLd¦«fD¦«¦«Z0d edM<dNZ1d edO<dwdR„Z2dxdU„Z3dydV„Z4GdW„dXej5¦«Z6ddej7dYd=ddZœdzdf„Z8Gdg„dh¦«Z9Gdi„dj¦«Z:Gdk„dlej;¦«Z< d{dej7dd=dmœd|do„Z=dS)}a( High-performance asyncio DatagramTransport with Linux-specific UDP receive/send coalescing: - GRO (receive): ``setsockopt(SOL_UDP, UDP_GRO)`` + ``recvmsg`` cmsg - GSO (send): ``sendmsg`` with ``UDP_SEGMENT`` cmsg All other platforms fall back to the standard asyncio DatagramTransport. é)ÚannotationsN)Údequeé)Ú UDP_LINUX_GROÚUDP_LINUX_SEGMENT)Úcreate_udp_endpointÚopen_dgram_connectionÚ sync_recv_groÚsync_sendmsg_gsoÚsync_send_dgramÚ GenericSegmentOffloadUnsupportedÚDatagramReaderÚDatagramWriterz=Hztyping.FinalÚ_UINT16z@iÚ _GRO_CMSGiÿÿÚ_DEFAULT_GRO_BUFiÚ_MAX_GRO_BUFiÚ_HIGH_WATERMARKi@Ú_LOW_WATERMARKé@Ú_GSO_MAX_SEGMENTSièýÚ_GSO_MAX_PAYLOADé Ú_RECV_BURST_LIMITÚlinuxÚ _IS_LINUX>ÚiosÚdarwinÚ _IS_DARWINÚSOL_UDPéÚ_SOL_UDPÚ MSG_TRUNCÚ _MSG_TRUNCÚ MSG_CTRUNCÚ_MSG_CTRUNCÚ CMSG_SPACEÚ_ANCBUFSIZEÚsockú socket.socketÚreturnÚboolcó€—tsdS | tt¦«dkS#t$rYdSwxYw)aaReturn True if UDP_GRO is enabled on *sock* (Linux only). The caller is responsible for having previously enabled it via ``setsockopt(SOL_UDP, UDP_GRO, 1)``. On non-Linux platforms the SOL_UDP option number 104 may collide with an unrelated option; we guard explicitly so we never mistakenly enable the GRO code path off-Linux. Fé)rÚ getsockoptr"rÚOSError©r)s ú`/home/thesage/.hermes/hermes-agent/venv/lib/python3.11/site-packages/urllib3/contrib/ssa/_gro.pyÚ _sock_has_gror3UsQ€õðØˆuðØŠxÑ7Ô7¸1Ò<Ð<øÝðððØˆuˆuðøøøs‹#/¯ =¼=có’—tsdS t| tt¦«¦«S#t $rYdSwxYw)zz%_split_gro_buffer..ys(ø€ÐIÐIÐI¨!ˆCA˜Ñ$Ð$Ô%ÐIÐIÐIó)ÚlenÚrange)r6r8Úns`` r2Ú_split_gro_bufferrEpsVøø€õ ˆC‰Œ€AØqÒÐ˜A Ò-Ð-ØˆuˆØIÐIÐIÐIÐIu°Q¸¸<Ñ/HÔ/HÐIÑIÔIÐIrAÚsizecóh—|dkrtSt|z}|dkrdS|tkr|ntS)zBReturn how many segments of *size* bytes fit in a single GSO call.rr.)rr)rFÚcaps r2Ú_max_segments_forrI|s?€àˆq‚y€yÝ Ð Ý ˜dÑ "€CØ ˆQ‚w€wØˆqØÕ)Ò)Ð)ˆ3ˆ3Õ/@Ð@rAÚ datagramsúlist[tuple[int, list[bytes]]]có—|sgSg}|d}t|¦«}|g}t|¦«}|dd…D]·}t|¦«}||kr)t|¦«|kr| |¦«Œ@||krDt|¦«|kr1| |¦«| ||f¦«g}d}ŒŠ|r| ||f¦«|}|g}t|¦«}Œ¸|r| ||f¦«|S)aHGroup consecutive same-size datagrams for Linux UDP GSO. GSO requires every segment in a single ``sendmsg`` to be exactly ``segment_size`` bytes, except the very last which may be shorter. The kernel further caps a single call at ``_GSO_MAX_SEGMENTS`` segments and ~64 KiB of payload, whichever is smaller. rr.N)rBrIÚappend)rJÚgroupsÚfirstÚcurrent_sizeÚ current_grouprHÚdgramrFs r2Ú_group_by_segment_sizerS†sH€ððØˆ à,.€FØaŒL€EÝu‘:”:€LØ"' €MÝ ˜LÑ )Ô )€Cà˜1˜2˜2”ð2ð2ˆÝ5‰zŒzˆØ<ÒÐ¥C¨ Ñ$6Ô$6¸Ò$<Ð$<Ø× Ò Ñ'Ô'Ð'Ð'Ø LÒ Ð ¥S¨Ñ%7Ô%7¸#Ò%=Ð%=ð × Ò Ñ'Ô'Ð'ØMŠM˜<¨Ð7Ñ8Ô8Ð8ØˆMØˆLˆLàð =Ø— ’ ˜|¨]Ð;Ñ<Ô<Ð<ØˆLØ"˜GˆMÝ# LÑ1Ô1ˆCˆCàð5Ø Š | ]Ð3Ñ4Ô4Ð4Ø€MrAÚancdataúlist[tuple[int, int, bytes]]ú int | Nonecóh—|D]®\}}}|tkr|tkr’t|¦«}|tjkr0tt |d¦«d¦«cS|tjkr0tt |d¦«d¦«cSdSŒ¯dS)z…Extract the GRO segment size from recvmsg ancillary data. Returns ``None`` if no UDP_GRO cmsg is present (single datagram). rN)r"rrBrrFr9Úunpack_fromr)rTÚ cmsg_levelÚ cmsg_typeÚ cmsg_datarDs r2Ú_parse_gro_segment_sizer\°s³€ð -4ððÑ(ˆ I˜yØÒ!Ð! iµ=Ò&@Ð&@ÝI‘”ˆAØ•I”NÒ"Ð"Ý9×0Ò0°¸AÑ>Ô>¸qÔAÑBÔBÐBÐBÐBØ•G”LÒ Ð å7×.Ò.¨y¸!Ñ<Ô<¸QÔ?Ñ@Ô@Ð@Ð@Ð@Ø11øØˆ4rAéÚbufsizeÚgro_segment_sizeúbytes | list[bytes]có —| |t¦«\}}}}|tzrtd|›d¦«‚|sdS|tzr|St|¦«}|€|S|dkr|n|}t |¦«|kr|St||¦«S)a/Blocking ``recvmsg`` with GRO cmsg parsing. Returns the raw datagram (``bytes``) when no GRO coalescing took place, or a list of segments (``list[bytes]``) when the kernel delivered a coalesced buffer. Raises ``OSError`` on payload truncation so callers can grow their buffer. z#recvmsg payload truncated; bufsize=z' too small for the coalesced GRO bufferrANr)Úrecvmsgr(r$r0r&r\rBrE) r)r^r_ÚdatarTÚflagsÚ_addrÚparsedr8s r2r r ÁsÇ€ð#'§,¢,¨w½Ñ"DÔ"DÑ€Dˆ'5˜%àzÑð Ýð (°'ð (ð (ð (ñ ô ð ððØˆsØ{Ñððˆå $ WÑ -Ô -€FØ €~àˆØ# ašZ˜Z66Ð-=€Lå ˆ4y„yLÒ Ð ØˆÝ˜T <Ñ0Ô0Ð0rAcó—eZdZdZdS)r ahRaised when a UDP GSO send is rejected by the kernel/driver because the NIC does not actually support segmentation offload, even though Kernel support it. Callers should disable GSO on the affected socket for the rest of the connection and re-send the failing batch without GSO. This mirrors the fallback strategy used by ``quic-go``. N)Ú__name__Ú __module__Ú__qualname__Ú__doc__r=rAr2r r æs€€€€€ððððrAr c#óK—|]}|®|V—Œ dS©Nr=©r>Úes r2ú rpós4èè€ð 2ð 2à ð €}ðð€}€}€}ð 2ð 2rAÚEIOÚENOTSUPÚ EOPNOTSUPPÚENOPROTOOPTÚ_GSO_UNSUPPORTED_ERRNOSc#óK—|]}|®|V—Œ dSrmr=rns r2rprps4èè€ð.ð.à ð €}ðð €}€}€}ð .ð.rAÚEMSGSIZEÚWSAEMSGSIZEÚ_MSG_TOO_BIG_ERRNOSi8'Ú_WSAEMSGSIZE_WINERRORÚexcr0cóV—|jtvrdSt|dd¦«tkS)z@Return True when *exc* means the datagram exceeded the path MTU.TÚwinerrorN)ÚerrnoryÚgetattrrz)r{s r2Ú_is_msg_too_bigr€s-€à „yÕ'Ð'Ð'ØˆtÝ3˜ DÑ)Ô)Õ-BÒBÐBrArcÚNonecó‚— | |¦«dS#t$r}t|¦«s‚Yd}~dSd}~wwxYw)aSend a single datagram, dropping it if it is oversized. A datagram the kernel rejects with ``EMSGSIZE`` is silently dropped: it is an over-large qh3 DPLPMTUD probe that is meant to fail, not a fatal connection error (see issue #377). Any other error propagates. ``send`` (not ``sendall``) is used deliberately: a UDP datagram is sent atomically, so the stream-oriented retry loop of ``sendall`` would be meaningless here (and would re-send a leftover tail as a corrupt second datagram if it ever triggered). N)Úsendr0r€)r)rcr{s r2rrsj€ðØ Š $‰ŒˆˆˆøÝðððÝ˜sÑ#Ô#ð Øð ð ð ð ð ð øøøøðøøøs‚™ >£9¹>c óJ—t|¦«D]\}}t|¦«dkrE | |d¦«n'#t$r}t |¦«s‚Yd}~nd}~wwxYwŒ^ | |ttt |¦«fg¦«Œœ#t$rj}|j tvrt¦«|‚|D]?} | |¦«Œ#t$r}t |¦«s‚Yd}~Œ8d}~wwxYwYd}~Œd}~wwxYwdS)aBatch-send datagrams using GSO. Falls back to individual sends. Raises :class:`GenericSegmentOffloadUnsupported` if the kernel/driver rejects the GSO send because the underlying NIC does not actually support UDP segmentation offload (e.g. ``EIO`` from ``sendmsg``). The current group is not sent in that case; callers are expected to disable GSO for the connection and re-send the batch without GSO. Duplicate delivery of any earlier group is harmless for QUIC (the receiver de-duplicates by packet number). r.rN) rSrBrƒr0r€Úsendmsgr"rrÚpackr~rur )r)rJr8Úgroupr{rRÚinners r2rr+s²€õ 6°iÑ@Ô@ðñÑˆeÝˆu‰:Œ:˜Š?ˆ?ð Ø— ’ ˜% œ(Ñ#Ô#Ð#Ð#øÝð ð ð å& sÑ+Ô+ðØðððððøøøøð øøøð ð ð LŠLØÝÕ-w¯|ª|¸LÑ/IÔ/IÐJÐKñ ô ð ð øõð ð ð ØŒyÕ3Ð3Ð3Ý6Ñ8Ô8¸cÐAðð ð ðØ—I’I˜eÑ$Ô$Ð$Ð$øÝðððÝ*¨5Ñ1Ô1ðØðððððøøøøðøøøð ð ð ð ñ øøøøð øøøð#ðsYªAÁ A*ÁA%Á%A*Á/d„Z d>d„Zd?d!„Zd>d"„Z d>d#„Zd>d$„Zd>d%„Zd@d)„Zd8d@d*„ZdAd-„ZdAd.„Zd@d/„Zd>d0„Zd>d1„Zd>d2„Zd>d3„Zd>d4„Zd>d5„Zd>d6„ZˆxZS)BÚ!_NativeOptimizedDatagramTransport)Ú_loopÚ_sockÚ_sock_fdÚ _protocolÚ_addressÚ _connectedÚ_gro_enabledÚ_gso_enabledÚ_gro_segment_sizeÚ_recv_buf_sizeÚ_closingÚ_closedÚ_closed_futÚ_extraÚ_pausedÚ_write_readyÚ_send_queueÚ_buffer_sizeÚ_protocol_pausedÚ_writer_registeredÚ_reader_registeredÚ_protocol_supports_batchÚloopúasyncio.AbstractEventLoopr)r*Úprotocolúasyncio.DatagramProtocolÚaddressútuple[str, int] | NoneÚgro_enabledr,Úgso_enabledr_r9r+rcóð•—t¦« ¦«||_||_| ¦«|_||_||_ | ¦«d|_ n#t$r d|_ YnwxYw||_||_||_ d|_d|_| ¦«|_d|_d|_d|_d|_t-¦«|_d|_d|_|rt4nt7|d¦«|_t;|d¦«|_ | ¦«}n#t$rd}YnwxYw||||j |j!dœ|_"dS)NTFriÜÚdatagrams_received)ÚpeernameÚsocketÚsocknameÚfamilyÚtype)#ÚsuperÚ__init__r‹rŒÚfilenorrŽrÚgetpeernamerr0r‘r’r“r•r–Ú create_futurer—r™ršržrŸrr›rœrrÚmaxr”Úhasattrr Úgetsocknamer®r¯r˜) Úselfr¡r)r£r¥r§r¨r_rÚ __class__s €r2r±z*_NativeOptimizedDatagramTransport.__init__zs¢ø€õ ‰Œ×ÒÑÔÐØˆŒ ØˆŒ ØŸš™ œ ˆŒ Ø!ˆŒØˆŒ ð $Ø×ÒÑÔÐØ"ˆDŒOˆOøÝð $ð $ð $Ø#ˆDŒOˆOˆOð $øøøð(ˆÔØ'ˆÔØ!1ˆÔØˆŒ ØˆŒØ15×1CÒ1CÑ1EÔ1EˆÔØˆŒØ ˆÔØ"'ˆÔØ"'ˆÔõINÉÌˆÔØˆÔØ %ˆÔð !,ÐLÕÐµÐ5EÀtÑ1LÔ1Lð Ôõ)0°Ð:NÑ(OÔ(OˆÔ%ð Ø×'Ò'Ñ)Ô)ˆHˆHøÝð ð ð ØˆHˆHˆHð øøøð ØØ Ø”kØ”Ið ð ˆŒˆˆs$ÁA4Á4BÂBÄ8E Å EÅENÚnameÚstrÚdefaultú typing.Anycó8—|j ||¦«Srm)r˜Úget©r¸rºr¼s r2Úget_extra_infoz0_NativeOptimizedDatagramTransport.get_extra_infoºs€ØŒ{Š˜t WÑ-Ô-Ð-rAcó—|jSrm)r•©r¸s r2Ú is_closingz,_NativeOptimizedDatagramTransport.is_closing½s €ØŒ}ÐrAúasyncio.BaseProtocolcó—|jSrm)rŽrÃs r2Úget_protocolz._NativeOptimizedDatagramTransport.get_protocolÀs €ØŒ~ÐrAcó>—||_t|d¦«|_dS)Nrª)rŽr¶r )r¸r£s r2Úset_protocolz._NativeOptimizedDatagramTransport.set_protocolÃs"€Ø!ˆŒÝ(/°Ð:NÑ(OÔ(OˆÔ%Ð%Ð%rAcó—|jSrm)rœrÃs r2Úget_write_buffer_sizez7_NativeOptimizedDatagramTransport.get_write_buffer_sizeÇs€ØÔ Ð rAcó —|jrdSd|_| ¦«|js"|j |jd¦«dSdS©NT)r•Ú_unregister_readerr›r‹Ú call_soonÚ_call_connection_lostrÃs r2Úclosez'_NativeOptimizedDatagramTransport.closeÊsc€ØŒ=ð ØˆFØˆŒ Ø×ÒÑ!Ô!Ð!àÔð CØŒJ× Ò Ô!;¸TÑBÔBÐBÐBÐBð Cð CrAcó¦—|jrdSd|_|j ¦«d|_|j |jd¦«dS)NTr)r•r›Úclearrœr‹rÏrÐrÃs r2Úabortz'_NativeOptimizedDatagramTransport.abortÓsX€ØŒ=ð ØˆFØˆŒ ð Ô×ÒÑ Ô Ð ØˆÔØŒ ×Ò˜TÔ7¸Ñ>Ô>Ð>Ð>Ð>rAr{úException | Nonecóx—|jrdSd|_| ¦«| ¦« |j |¦«n!#t tf$r‚t$rYnwxYw |j ¦«n#t$rYnwxYw|j ¦«s|j d¦«dSdS# |j ¦«n#t$rYnwxYw|j ¦«s|j d¦«wwxYwrÍ)r–rÎÚ_unregister_writerrŽÚconnection_lostÚKeyboardInterruptÚ SystemExitÚ BaseExceptionrŒrÑr0r—ÚdoneÚ set_result©r¸r{s r2rÐz7_NativeOptimizedDatagramTransport._call_connection_lostÝs„€ØŒ<ð ØˆFØˆŒØ×ÒÑ!Ô!Ð!Ø×ÒÑ!Ô!Ð!ð 2ØŒN×*Ò*¨3Ñ/Ô/Ð/Ð/øÝ!¥:Ð.ð ð ð ØÝð ð ð ØˆDð øøøð Ø” × Ò Ñ"Ô"Ð"Ð"øÝð ð ð Øð øøøàÔ#×(Ò(Ñ*Ô*ð 2ØÔ ×+Ò+¨DÑ1Ô1Ð1Ð1Ð1ð 2ð 2øð Ø” × Ò Ñ"Ô"Ð"Ð"øÝð ð ð Øð øøøàÔ#×(Ò(Ñ*Ô*ð 2ØÔ ×+Ò+¨DÑ1Ô1Ð1Ð1ð 2øøøs_ºAÁCÁA3Á0CÁ2A3Á3CÁ7BÂ BÂBÃD9ÃC4Ã3D9Ã4 DÃ>D9ÄDÄ8D9có°—|js|jrdS |j |j|j¦«d|_dS#ttf$rYdSwxYwrÍ)rŸr–r‹Ú add_readerrÚ_on_readabler0Ú ValueErrorrÃs r2Ú_register_readerz2_NativeOptimizedDatagramTransport._register_readerñsr€ØÔ"ð d¤lð ØˆFð ØŒJ×!Ò! $¤-°Ô1BÑCÔCÐCØ&*ˆDÔ#Ð#Ð#øÝÐ$ð ð ð ØˆDˆDð øøøó’,AÁAÁAcó–—|jsdSd|_ |j |j¦«dS#tt f$rYdSwxYw©NF)rŸr‹Ú remove_readerrr0rârÃs r2rÎz4_NativeOptimizedDatagramTransport._unregister_readerúód€ØÔ&ð ØˆFØ"'ˆÔð ØŒJ×$Ò$ T¤]Ñ3Ô3Ð3Ð3Ð3øÝÐ$ð ð ð ØˆDˆDð øøøó’3³AÁAcó°—|js|jrdS |j |j|j¦«d|_dS#ttf$rYdSwxYwrÍ)ržr–r‹Ú add_writerrÚ_on_write_readyr0rârÃs r2Ú_register_writerz2_NativeOptimizedDatagramTransport._register_writersr€ØÔ"ð d¤lð ØˆFð ØŒJ×!Ò! $¤-°Ô1EÑFÔFÐFØ&*ˆDÔ#Ð#Ð#øÝÐ$ð ð ð ØˆDˆDð øøøräcó–—|jsdSd|_ |j |j¦«dS#tt f$rYdSwxYwræ)ržr‹Ú remove_writerrr0rârÃs r2r×z4_NativeOptimizedDatagramTransport._unregister_writerrèrércr7ÚaddrcóÔ—|jr|j |¦«dS||n|j}|€|j |¦«dS|j ||¦«dS)zîIssue a single send/sendto on the underlying socket. Picks the right syscall based on whether the socket is ``connect()``-ed: a connected UDP socket rejects ``sendto`` with ``EISCONN`` on Linux and macOS. N)rrŒrƒrÚsendto)r¸rcrðÚtargets r2Ú _raw_sendz+_NativeOptimizedDatagramTransport._raw_sendsu€ðŒ?ð 0ØŒJOŠO˜DÑ!Ô!Ð!Ð!Ð!à!Ð-TT°4´=ˆFØˆ~à” —’ Ñ%Ô%Ð%Ð%Ð%à” ×!Ò! $¨Ñ/Ô/Ð/Ð/Ð/rAcó¤—|jrtd¦«‚||n|j}|jr|jr| ||¦«dS | ||¦«dS#t$rYn²t$rj | ||¦«YdS#t$rYnAt$r5}t|¦«s|j |¦«Yd}~YdSd}~wwxYwYn@t$r4}t|¦«s|j |¦«Yd}~dSd}~wwxYwd|_| ¦«| ||¦«dS)NúTransport is closingF) r•r0rršr›Ú_queue_writerôÚBlockingIOErrorÚInterruptedErrorr€rŽÚerror_receivedrí)r¸rcrðrór{s r2ròz(_NativeOptimizedDatagramTransport.sendto&sÂ€ØŒ=ð 2ÝÐ0Ñ1Ô1Ð1àÐ)¨t¬}ˆðÔ ð DÔ$4ð Ø×Ò˜d FÑ+Ô+Ð+ØˆFð ØNŠN˜4 Ñ(Ô(Ð(ØˆFøÝð ð ð ØˆDÝð ð ð ð Ø—’˜t VÑ,Ô,Ð,ØøÝ"ð ð ð ØÝð ð ð Ý& sÑ+Ô+ð7Ø”N×1Ò1°#Ñ6Ô6Ð6Øøøøøð øøøðõ ð ð ð Ý" 3Ñ'Ô'ð 3Ø”×-Ò-¨cÑ2Ô2Ð2ØˆFˆFˆFˆFˆFøøøøð øøøð"ˆÔØ×ÒÑÔÐØ×Ò˜$ Ñ'Ô'Ð'Ð'Ð'sTÁ A!Á! DÁ- DÁ7BÂ CÂDÂ CÂ%)CÃDÃCÃDÃ DÃ()DÄDrJr:có0—|jrtd¦«‚|sdS|jr|jr$|j}|D]}| ||¦«ŒdS|jr| |¦«dS|D](}| |¦«|js|j rdSŒ)dS)a)Send multiple datagrams, using GSO when available. Falls back to individual ``sendto`` calls when GSO is not supported or the socket write buffer is full. Guarantees that *every* input datagram is either transmitted or queued -- none are silently dropped. röN) r•r0ršr›rr÷r’Ú_send_linux_gsoròr–)r¸rJrórRs r2Úsendto_manyz-_NativeOptimizedDatagramTransport.sendto_manyLsä€ðŒ=ð 2ÝÐ0Ñ1Ô1Ð1Øð ØˆFðÔ ð DÔ$4ð Ø”]ˆFØ"ð 1ð 1Ø×!Ò! %¨Ñ0Ô0Ð0Ð0ØˆFàÔð Ø× Ò Ñ+Ô+Ð+Ð+Ð+à"ð ð à—’˜EÑ"Ô"Ð"Ø”=ð D¤LðØFFðð ð rAc óø—t|¦«}|j}|j}t|¦«D]Ë\}\}} t |¦«dkr| |d|¦«n<| |ttt |¦«fg¦«Œw#t$rKd|_| ¦«||d…D] \}} | D]} | | |¦«ŒŒ!YdSt$rK||d…D] \}} | D]} | | |¦«ŒŒ!d|_| ¦«YdSt $r¢}t |¦«dkr?|jt$vrd|_|D]%} | | |¦«Œ#t$r¤d|_| ¦«| | |¦«| | ¦«dz}||d…D]} | | |¦«Œ||dzd…D] \}} | D]}| ||¦«ŒŒ!YYd}~dSt $rS}t+|¦«rYd}~Œå|j |¦«|js|jrYd}~Yd}~dSYd}~Œd}~wwxYwnDt+|¦«rYd}~Œ|j |¦«|js|jrYd}~dSYd}~ŒÅd}~wwxYwdS)a.Send a list of datagrams using UDP_SEGMENT. On EAGAIN at any point, *all* not-yet-sent datagrams (including the failing group's contents) are pushed into the write queue in order, the writer is armed, and the function returns. Nothing is ever silently dropped. r.rFN)rSrrŒÚ enumeraterBrôr…r"rrr†røršrír÷rùr0r~rur’Úindexr€rŽrúr•r–)r¸rJrNrðr)r?r8r‡Ú_szÚgrRr{ÚidxÚtailÚdrˆs r2rüz1_NativeOptimizedDatagramTransport._send_linux_gsojs €õ(¨ Ñ2Ô2ˆØŒ}ˆØŒzˆå(1°&Ñ(9Ô(9ðJ ñJ Ñ$ˆAÑ$˜eðI Ýu‘:”: ’??Ø—N’N 5¨¤8¨TÑ2Ô2Ð2Ð2ð—L’LØõ!)Ý 1Ý '§¢¨\Ñ :Ô :ððñ ô ð øøõ#ð ð ð Ø$)Ô!Ø×%Ò%Ñ'Ô'Ð'ð% Q R Rœjð7ð7‘FC˜Ø!"ð7ð7˜Ø×)Ò)¨%°Ñ6Ô6Ð6Ð6ð7àÝ#ð ð ð ð% Q R Rœjð7ð7‘FC˜Ø!"ð7ð7˜Ø×)Ò)¨%°Ñ6Ô6Ð6Ð6ð7à$)Ô!Ø×%Ò%Ñ'Ô'Ð'ØÝð' ñ' ð' õu‘:”: ’>‘>ð”yÕ$;Ð;Ð;Ø,1˜Ô)Ø!&ð'ñ'˜ð'Ø ŸNšN¨5°$Ñ7Ô7Ð7Ð7øÝ.ð#ð#ð#Ø05˜DÔ-Ø ×1Ò1Ñ3Ô3Ð3Ø ×-Ò-¨e°TÑ:Ô:Ð:à"'§+¢+¨eÑ"4Ô"4°qÑ"8˜CØ(-¨c¨d¨d¬ð>ð> Ø $× 1Ò 1°$¸Ñ =Ô =Ð =Ð =Ø*0°°Q±°°¬/ð?ð?¡ QØ)*ð!?ð!? AØ$(×$5Ò$5°a¸Ñ$>Ô$>Ð$>Ð$>ð!?à"˜F˜F˜F˜F˜F˜F˜F˜FÝ&ð'ð'ð'õ /¨uÑ5Ô5ð)Ø ( Ø œN×9Ò9¸%Ñ@Ô@Ð@Ø#œ}ð'°´ð'Ø & ð'ð'ð'ð'ñ'øøøøð 'øøøð'õ2' sÑ+Ô+ð!Ø ˜˜˜™Ø”N×1Ò1°#Ñ6Ô6Ð6Ø”}ð¨¬ðØ˜˜˜˜˜˜øøøøùøøøøðO' øøøðGJ ðJ su·A,B$Â$AK7Ã8AK7Å K7Å.K2ÆFÆK2ÆB$J$ È?K2É J$ ÉJ É K2É%(J Ê K2ÊK2ÊJ$ Ê$K2Ê=(K2Ë2K7có4—|j ||f¦«|xjt|¦«z c_|jtkrL|jsGd|_ |j ¦«dS#ttf$r‚t$rYdSwxYwdSdSrÍ)r›rMrœrBrrrŽÚ pause_writingrÙrÚrÛ©r¸rcrðs r2r÷z._NativeOptimizedDatagramTransport._queue_writeÂs¾€ØÔ×Ò t Ñ-Ô-Ð-ØÐÔS ™YœYÑ&ÐÔØÔ¥Ò/Ð/¸Ô8MÐ/Ø$(ˆDÔ!ð Ø”×,Ò,Ñ.Ô.Ð.Ð.Ð.øÝ%¥zÐ2ð ð ð ØÝ ð ð ð Øð øøøð 0Ð/Ð/Ð/sÁA4Á4BÂBcóÂ—|jrU|jtkrGd|_ |j ¦«dS#t tf$r‚t$rYdSwxYwdSdSræ)rrœrrŽÚresume_writingrÙrÚrÛrÃs r2Ú_maybe_resume_protocolz8_NativeOptimizedDatagramTransport._maybe_resume_protocolÎs€ØÔ ð TÔ%6½.Ò%HÐ%HØ$)ˆDÔ!ð Ø”×-Ò-Ñ/Ô/Ð/Ð/Ð/øÝ%¥zÐ2ð ð ð ØÝ ð ð ð Øð øøøð ð Ð%HÐ%Hs ;»AÁAcó0—|j}|j}|r3|d\}} |||¦«nÒ#t$rYdSt$rYŒ4t$r®}| ¦«|xjt|¦«zc_| ¦«t|¦«s= |j |¦«n!#ttf$r‚t$rYnwxYw|js|jrYd}~nUYd}~Œæd}~wwxYw| ¦«|xjt|¦«zc_| ¦«|°3|sKd|_| ¦«|jr+|js&|j |jd¦«dSdSdSdS)z9Drain the write backlog when the socket becomes writable.rNT)r›rôrørùr0ÚpopleftrœrBrr€rŽrúrÙrÚrÛr•r–ršr×r‹rÏrÐ)r¸ÚqueueÚraw_sendrcrðr{s r2rìz1_NativeOptimizedDatagramTransport._on_write_readyØs"€àÔ ˆØ”>ˆàñ *Ø˜qœ‰JˆD$ð Ø˜˜tÑ$Ô$Ð$Ð$øÝ"ð ð ð àÝ#ð ð ð ØÝð ð ð ð— ’ ‘”ØÐ!Ô!¥S¨¡Y¤YÑ.Ð!Ô!Ø×+Ò+Ñ-Ô-Ð-õ' sÑ+Ô+ððØœ×5Ò5°cÑ:Ô:Ð:Ð:øÝ-zÐ:ðððØÝ(ðððØ˜ðøøøà”=ð D¤LðØEEEEØøøøøð% øøøð( MŠM‰OŒOˆOØÐÔ¥ T¡¤Ñ*ÐÔØ×'Ò'Ñ)Ô)Ð)ð?ñ *ðFð GØ $ˆDÔØ×#Ò#Ñ%Ô%Ð%àŒ}ð G T¤\ð GØ” ×$Ò$ TÔ%?ÀÑFÔFÐFÐFÐFð Gð Gð Gð Gð Gð GsEž+« C:¸ C:Á C:ÁAC5Â!B<Â;C5Â<CÃC5ÃCÃC5Ã5C:cóN—|jsd|_| ¦«dSdSrÍ)r™rÎrÃs r2Ú pause_readingz/_NativeOptimizedDatagramTransport.pause_readings5€ØŒ|ð &ØˆDŒLØ×#Ò#Ñ%Ô%Ð%Ð%Ð%ð &ð &rAcóN—|jrd|_| ¦«dSdSræ)r™rãrÃs r2Úresume_readingz0_NativeOptimizedDatagramTransport.resume_readings5€ØŒ<ð $Ø ˆDŒLØ×!Ò!Ñ#Ô#Ð#Ð#Ð#ð $ð $rAcóx—|j |jj|¦«| ¦«dSrm)r‹rÏrŽÚconnection_maderãrÃs r2Ú_startz(_NativeOptimizedDatagramTransport._starts7€ØŒ ×Ò˜Tœ^Ô;¸TÑBÔBÐBØ×ÒÑÔÐÐÐrAcó@—|jrdS| ¦«dSrm)r•Ú_recv_linux_grorÃs r2ráz._NativeOptimizedDatagramTransport._on_readables)€ØŒ=ð ØˆFØ×ÒÑÔÐÐÐrAcóD—|jj}|j}|j}|jr|jnd}|j}t}tt¦«D] } ||j |¦«\}} } }ni#t$rYdSt$rYŒ4t$rD} | |¦«n!#tt f$r‚t"$rYnwxYwYd}~dSd}~wwxYw|sdS| t$zrz|j } | td| ›d¦«¦«n!#tt f$r‚t"$rYnwxYw| t&krt)| dzt&¦«|_ Œ | t*zr|||¦«Œ%t-| ¦«}|€|||¦«ŒD|dkr|n|}t/|¦«|kr|||¦«Œot1||¦«}||||¦«Œ|D]}|||¦«ŒŒ¢|js(|jr#|j |j¦«dSdSdS)Nz(recvmsg payload truncated; recv buffer (z+) is too small for the coalesced GRO bufferér)rŒrbrŽÚdatagram_receivedr rªr“r(rCrr”rørùr0rúrÙrÚrÛr$rÚminr&r\rBrEr•rŸr‹rÏrá)r¸Úsock_recvmsgr£rÚbatch_cbÚdefault_segment_sizeÚ ancbufsizeÚ_rcrTrdrðr{r^rfr8ÚsegmentsÚsegs r2rz1_NativeOptimizedDatagramTransport._recv_linux_gros7€à”zÔ)ˆØ”>ˆØ$Ô6ÐðÔ,ð ˆHÔ'Ð'àð ð $Ô5ÐÝ ˆ åÕ(Ñ)Ô)ðA 1ñA 1ˆAð Ø-9¨\ØÔ'¨ñ.ô.Ñ*g˜u d døõ#ð ð ð ØÝ#ð ð ð ØÝð ð ð ðØ×+Ò+¨CÑ0Ô0Ð0Ð0øÝ):Ð6ðððØÝ$ðððØDðøøøàøøøøð øøøðð Øð •zÑ!ð ØÔ-ðØ×+Ò+Ýð*Ø 'ð*ð*ð*ñôñôððøõ*:Ð6ðððØÝ$ðððØDðøøøð\Ò)Ð)Ý*-¨g¸©k½<Ñ*HÔ*HDÔ'Ùà•{Ñ"ð ð"Ð! $¨Ñ-Ô-Ð-Ùå,¨WÑ5Ô5ˆFØˆ~à!Ð! $¨Ñ-Ô-Ð-Ùà%+¨a¢Z Z˜6˜6Ð5IˆLÝ4‰yŒy˜LÒ(Ð(Ø!Ð! $¨Ñ-Ô-Ð-Ùå(¨¨|Ñ<Ô<ˆHØÐ#Ø˜ 4Ñ(Ô(Ð(Ñ(à#ð1ð1CØ%Ð% c¨4Ñ0Ô0Ð0Ð0ñ1ðŒ}ð 4 Ô!8ð 4ØŒJ× Ò Ô!2Ñ3Ô3Ð3Ð3Ð3ð 4ð 4ð 4ð 4sTÁA(Á( CÁ6 CÂ CÂB!Â C Â!B?ÂB?Â?C Ã CÃ(&DÄD-Ä,D-)r¡r¢r)r*r£r¤r¥r¦r§r,r¨r,r_r9r+rrm©rºr»r¼r½r+r½©r+r,)r+rÅ)r£rÅr+r)r+r9©r+r)r{rÕr+r)rcr7rðr¦r+r©rJr:r+r)rhrirjÚ __slots__r±rÁrÄrÇrÉrËrÑrÔrÐrãrÎrír×rôròrýrür÷rrìrrrrárÚ __classcell__)r¹s@r2rŠrŠ`sJø€€€€€ð€Ið2> ð> ð> ð> ð> ð> ð@.ð.ð.ð.ð.ðððððððððPðPðPðPð!ð!ð!ð!ðCðCðCðCð?ð?ð?ð?ð2ð2ð2ð2ð(ðððððððððððððððð0ð0ð0ð0ð"$(ð$(ð$(ð$(ð$(ðLððððˆNˆNˆNð ?øøøõ;ˆàÐÑ!Ô!€HØØ Ø ØØØØØ)ðñô€Ið×ÒÑÔÐØhÐÐsN†œ,«,Â4E Ã+C8Ã7E Ã8DÄ E ÄDÄfeed->probe round-trip overhead. )Ú_bufferÚ_waiterÚ _exceptionÚ_eofr+rcóV—t¦«|_d|_d|_d|_dSræ)rrGrHrIrJrÃs r2r±zDatagramReader.__init__Ös&€Ý38±7´7ˆŒØ48ˆŒØ04ˆŒØˆŒ ˆ ˆ rArcr7rðr½có¸—|jrdS|j |¦«|j}|+| ¦«s| d¦«dSdSdS)z'Feed a single (non-coalesced) datagram.N©rJrGrMrHrÜrÝ©r¸rcrðÚwaiters r2Ú feed_datagramzDatagramReader.feed_datagramÜsi€àŒ9ð ØˆFØŒ×Ò˜DÑ!Ô!Ð!Ø”ˆØÐ f§k¢k¡m¤mÐØ×Ò˜dÑ#Ô#Ð#Ð#Ð#ðÐÐÐrAr:có¼—|js|sdS|j |¦«|j}|+| ¦«s| d¦«dSdSdS)z6Feed a batch of coalesced datagrams as a single entry.NrMrNs r2Úfeed_datagramszDatagramReader.feed_datagramsåsp€àŒ9ð ˜Dð ØˆFØŒ×Ò˜DÑ!Ô!Ð!Ø”ˆØÐ f§k¢k¡m¤mÐØ×Ò˜dÑ#Ô#Ð#Ð#Ð#ðÐÐÐrAr{rÛcó€—||_|j}|+| ¦«s| d¦«dSdSdSrm)rIrHrÜrÝ©r¸r{rOs r2Ú set_exceptionzDatagramReader.set_exceptionîsK€ØˆŒØ”ˆØÐ f§k¢k¡m¤mÐØ×Ò˜dÑ#Ô#Ð#Ð#Ð#ðÐÐÐrAúBaseException | Nonecó —d|_||j€||_|j}|+| ¦«s| d¦«dSdSdSrÍ)rJrIrHrÜrÝrTs r2rØzDatagramReader.connection_lostôs^€ØˆŒ Øˆ?˜tœÐ6Ø!ˆDŒOØ”ˆØÐ f§k¢k¡m¤mÐØ×Ò˜dÑ#Ô#Ð#Ð#Ð#ðÐÐÐrAr,có —|jo|jSrm)rJrGrÃs r2Úat_eofzDatagramReader.at_eofüs€ØŒyÐ- ¤Ð-Ð-rAr`có—g}|jD]B}t|t¦«r| |¦«Œ-| |¦«ŒC|j ¦«t |¦«dkr|dS|S)Nr.r)rGÚ isinstancer7rMÚextendrÓrB)r¸rJÚentrys r2Ú _drain_bufzDatagramReader._drain_bufÿs‘€Ø!#ˆ Ø”\ð (ð (ˆEõ˜%¥Ñ'Ô'ð (Ø× Ò Ñ'Ô'Ð'Ð'à× Ò Ñ'Ô'Ð'Ð'ØŒ×ÒÑÔÐõˆy‰>Œ>˜QÒÐØ˜Q”<ÐØÐrAéÿÿÿÿrDr9cƒó¦K—|jr| ¦«S|j|jdc}|_|‚|jrdS|jtd¦«‚t j¦« ¦«}||_ |ƒd{V—†d|_n#d|_wxYw|jr| ¦«S|j|jdc}|_|‚dS)a€Return the next entry from the buffer. * ``bytes`` -- a single datagram (non-coalesced). * ``list[bytes]`` -- a batch of coalesced datagrams from one GRO syscall. * ``b""`` -- EOF. Buffered data is delivered first, *before* any pending exception is raised, so callers can drain the stream cleanly on shutdown. NrAz=DatagramReader.read() called concurrently from two coroutines) rGr^rIrJrHÚRuntimeErrorÚasyncioÚget_running_loopr´)r¸rDr{rOs r2ÚreadzDatagramReader.readsüèè€ðŒ<ð %Ø—?’?Ñ$Ô$Ð$àŒ?Ð&Ø#'¤?°DÐ ˆC”ØˆIàŒ9ð Ø3àŒ<Ð#ÝØOñôð õÔ)Ñ+Ô+×9Ò9Ñ;Ô;ˆØˆŒð ØˆLˆLˆLˆLˆLˆLˆLàˆDŒLˆLø˜4ˆDŒLÐÐÐÐàŒ<ð %Ø—?’?Ñ$Ô$Ð$àŒ?Ð&Ø#'¤?°DÐ ˆC”ØˆIàˆssÂBÂ BNr&)rcr7rðr½r+r)rcr:rðr½r+r)r{rÛr+r©r{rVr+rr%)r+r`)r_)rDr9r+r`) rhrirjrkr(r±rPrRrUrØrYr^rdr=rAr2rrÈsÊ€€€€€ð ð ð=€Iððððð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð$ð.ð.ð.ð.ððððð (ð(ð(ð(ð(ð(ð(rArcó€—eZdZdZdZdd„Zedd„¦«Zdd„Zdd„Z d d„Z d d„Zd!d„Zd d„Z d"d#d„Zd d„Zd d„ZdS)$rzåAPI-compatible with ``asyncio.StreamWriter`` (duck-typed) so that ``AsyncSocket`` can assign an instance to ``self._writer`` and the existing ``sendall()``, ``close()``, ``wait_for_close()`` code works unchanged. )Ú _transportrÚ _closed_eventr™Ú_drain_waitersÚ_supports_batchrEúasyncio.DatagramTransportr+rcó¾—||_| d¦«|_tj¦«|_d|_g|_t|d¦«|_ dS)Nr«Frý) rgrÁrrbÚEventrhr™rir¶rj©r¸rEs r2r±zDatagramWriter.__init__JsU€Ø#ˆŒØ09×0HÒ0HÈÑ0TÔ0TˆŒ Ý$œ]™_œ_ˆÔØˆŒð;=ˆÔÝ& y°-Ñ@Ô@ˆÔÐÐrAcó—|jSrm)rgrÃs r2rEzDatagramWriter.transportTs €àŒÐrArcú,bytes | bytearray | memoryview | list[bytes]cól—|j}| ¦«rdSt|t¦«rB|jr| |¦«dS|j}|D]}| ||¦«ŒdSt|t¦«st|¦«}| ||j¦«dSrm) rgrÄr[Úlistrjrýrròr7)r¸rcrErðrRs r2ÚwritezDatagramWriter.writeXsÑ€Ø”Oˆ Ø×ÒÑ!Ô!ð ØˆFÝdDÑ!Ô!ð 2ØÔ#ð 2Ø×%Ò% dÑ+Ô+Ð+Ð+Ð+ð”}Ø!ð2ð2EØ×$Ò$ U¨DÑ1Ô1Ð1Ð1ð2ð2õ˜d¥EÑ*Ô*ð #Ý˜T‘{”{Ø×Ò˜T 4¤=Ñ1Ô1Ð1Ð1Ð1rArJr:có0—| |¦«dS)z=Send a batch of datagrams. ``StreamWriter``-compatible alias.N)rs)r¸rJs r2Ú writelineszDatagramWriter.writelinesis€à Š 9ÑÔÐÐÐrAcƒóhK—|jsdStj¦«}| ¦«}|j |¦« |ƒd{V—† |j |¦«dS#t$rYdSwxYw# |j |¦«w#t$rYwwxYwxYwrm)r™rbrcr´rirMÚremoverâ)r¸r¡rOs r2ÚdrainzDatagramWriter.drainmsèèè€ØŒ|ð ØˆFÝÔ'Ñ)Ô)ˆØ'+×'9Ò'9Ñ';Ô';ˆØÔ×"Ò" 6Ñ*Ô*Ð*ð ØˆLˆLˆLˆLˆLˆLˆLð ØÔ#×*Ò*¨6Ñ2Ô2Ð2Ð2Ð2øÝð ð ð Øð øøøøð ØÔ#×*Ò*¨6Ñ2Ô2Ð2Ð2øÝð ð ð Øð øøøøøøsBÁBÁA3Á3 BÂBÂB1ÂB!Â B1Â! B.Â+B1Â-B.Â.B1có8—|j ¦«dSrm)rgrÑrÃs r2rÑzDatagramWriter.close{s€ØŒ×ÒÑÔÐÐÐrAr,có4—|j ¦«Srm)rgrÄrÃs r2rÄzDatagramWriter.is_closing~s€ØŒ×)Ò)Ñ+Ô+Ð+rAcƒóHK—|j ¦«ƒd{V—†dSrm)rhÚwaitrÃs r2Úwait_closedzDatagramWriter.wait_closeds3èè€ØÔ ×%Ò%Ñ'Ô'Ð'Ð'Ð'Ð'Ð'Ð'Ð'Ð'Ð'rANrºr»r¼r½có8—|j ||¦«Srm)rgrÁrÀs r2rÁzDatagramWriter.get_extra_info„s€ØŒ×-Ò-¨d°GÑ<Ô<Ðz'open_dgram_connection..Ðsø€€rA)r*r+r®r_r))rbrcrr‡rrrŠ)r+r*r®r)r_r¡r‹rEr!r–r£s @r2r r Ás¤øèè€õÔ#Ñ%Ô%€Då Ñ Ô €FÝ& vÑ.Ô.€Hå,ØØÐÐÐØØØØ)Ø ðñôððððððL€Iˆqõ˜IÑ &Ô &€FØ€HÔà6ˆ>ÐrA)r)r*r+r,)r6r7r8r9r+r:)rFr9r+r9)rJr:r+rK)rTrUr+rV)r])r)r*r^r9r_r9r+r`)r{r0r+r,)r)r*rcr7r+r)r)r*rJr:r+r)r¡r¢r-r.r*r¦r+r¦r®r9r,r,r_r9r)r/r+r0rm)r+r¦r*r¦r®r9r)r/r_r9r+r™)>rkÚ __future__rrbr~r¬ÚstructÚsysÚcollectionsrÚtypingÚ _constantrrÚ__all__ÚStructrÚ__annotations__rrrrrrrrÚplatformrrrr"r$r&r¶r'rFr(r3r5rErIrSr\r r’r Ú frozensetruryrzr€rrÚDatagramTransportrŠr3rrrÚDatagramProtocolr‡r r=rAr2úrªs€ððððð#Ð"Ð"Ð"Ð"Ð"à€€€Ø€€€Ø € € € Ø € € € Ø € € € ØÐÐÐÐÐØ € € € ð:Ð9Ð9Ð9Ð9Ð9Ð9Ð9ð €ð&˜œ dÑ+Ô+€Ð+Ð+Ð+Ñ+ð(˜&œ-¨Ñ-Ô-€ Ð-Ð-Ð-Ñ-ð"'ÐÐ&Ð&Ð&Ñ&ð $€Ð#Ð#Ð#Ñ#ð!*€Ð)Ð)Ð)Ñ)Ø(€Ð(Ð(Ð(Ñ(ð #%ÐÐ$Ð$Ð$Ñ$Ø!&ÐÐ&Ð&Ð&Ñ&ð#%ÐÐ$Ð$Ð$Ñ$àœ,¨'Ò1€ Ð1Ð1Ð1Ñ1Øœ<Ð+<Ð<€ Ð<Ð<Ð<Ñ<ð!˜ ¨°BÑ7Ô7€Ð7Ð7Ð7Ñ7Ø"˜7 6¨;¸Ñ:Ô:€ Ð:Ð:Ð:Ñ:Ø#˜G F¨L¸!Ñ<Ô<€Ð<Ð<Ð<Ñ<ð€7ˆ6<Ñ Ô ðØ 1 Ô 1°)´.Ñ AÔ A€KÐAÐAÐAÑAÐAð€Kððððð"ðððð Jð Jð Jð JðAðAðAðAð'ð'ð'ð'ðTðððð$@Dð"1ð"1ð"1ð"1ð"1ðJðððð yñôðð)2¨ ð 2ð 2ð ˆu˜dÑ#Ô#Øˆy $Ñ'Ô'Øˆ| TÑ*Ô*Øˆ} dÑ+Ô+ð ð 2ñ 2ô 2ñ )ô )Ðð ð ð ñ ð %. Ið.ð.ð ˆz 4Ñ(Ô(Øˆ} dÑ+Ô+ðð.ñ.ô.ñ%ô%Ððððñð',ÐÐ+Ð+Ð+Ñ+ðCðCðCðCððððð&*ð*ð*ð*ðjL4ðL4ðL4ðL4ðL4¨Ô(AñL4ôL4ðL4ðf*.Ø*.ØÔ"ØØ Ø!%ðVðVðVðVðVðVðroðoðoðoðoñoôoðoðdX#ðX#ðX#ðX#ðX#ñX#ôX#ðX#ðv)+ð)+ð)+ð)+ð)+˜gÔ6ñ)+ô)+ð)+ðZ+/ðð*.ØÔ"Ø!%Ø ð ðððððððrA