fr=UddlmZddlZddlmZmZddlmZmZddl Z ddl m Z ddl mZmZddlmZmZerdd lmZdd lmZdd lmZd ZejejhZeddZeGddeZgdZe Z!de"d<eD]DZ#ee$5e!%e&ee#dddn #1swxYwYEeGddeeZ'dS)) annotationsN)contextmanagersuppress) TYPE_CHECKINGoverload)socket)ConflictDetectorfinal)HalfCloseableStreamListener) Generator)Buffer) SocketTypeireturnGenerator[None, None, None]c#K dVdS#t$r@}|jtvrtjddtjd||d}~wwxYw)Nzthis socket was already closedzsocket connection broken: )OSErrorerrno_closed_stream_errnostrioClosedResourceErrorBrokenResourceError)excs Y/var/www/api.educacionweb.es/myenv/lib/python3.11/site-packages/trio/_highlevel_socket.py)_translate_socket_errors_to_stream_errorsr#s|X  XXX 9- - -*+KLLRV V*+M+M+MNNTW W Xs A;AAceZdZdZd"dZd#d Zd$d Zd$d Zd%d&dZd$dZ e d'dZ e d(dZ d%d)dZ e d*dZ e d+dZ d,d-d!Z d S). SocketStreamufAn implementation of the :class:`trio.abc.HalfCloseableStream` interface based on a raw network socket. Args: socket: The Trio socket object to wrap. Must have type ``SOCK_STREAM``, and be connected. By default for TCP sockets, :class:`SocketStream` enables ``TCP_NODELAY``, and (on platforms where it's supported) enables ``TCP_NOTSENT_LOWAT`` with a reasonable buffer size (currently 16 KiB) – see `issue #72 `__ for discussion. You can of course override these defaults by calling :meth:`setsockopt`. Once a :class:`SocketStream` object is constructed, it implements the full :class:`trio.abc.HalfCloseableStream` interface. In addition, it provides a few extra features: .. attribute:: socket The Trio socket object that this stream wraps. r rcbt|tjstd|jtjkrt d||_td|_ tt5| tj tjddddn #1swxYwYttdrZtt5| tj tjdddddS#1swxYwYdSdS)Nz*SocketStream requires a Trio socket objectz*SocketStream requires a SOCK_STREAM socketz;another task is currently sending data on this SocketStreamTTCP_NOTSENT_LOWATi@) isinstancetsocketr TypeErrortype SOCK_STREAM ValueErrorr r _send_conflict_detectorrr setsockopt IPPROTO_TCP TCP_NODELAYhasattrr )selfr s r__init__zSocketStream.__init__Gs&'"455 JHII I ;'- - -IJJ J '7 I( ( $g   L L OOG/1Dd K K K L L L L L L L L L L L L L L L 7/ 0 0 W'"" W W 3W5NPUVVV W W W W W W W W W W W W W W W W W W W Ws$=,B55B9<B9),D""D&)D&databytes | bytearray | memoryviewrNonec K|jjrtjd|j5t 5t |5}|sy|jdkrtjdtj d{V ddddddddddSd}|t|krZ||d5}|j |d{V}dddn #1swxYwY||z }|t|kZdddn #1swxYwYdddn #1swxYwYddddS#1swxYwYdS)Nz!can't send data after sending EOFzsocket was already closedr) r did_shutdown_SHUT_WRrrr'r memoryviewfilenolowlevel checkpointlensend)r,r. total_sent remainingsents rsend_allzSocketStream.send_alles ; + P*+NOO O  ) + +:<< + +%% +;--//255"&":;V"W"WW"m66888888888 + + + + + + + + + + + + + + + + + + + +"#J$s4yy00!*++.E))-)9)9))D)D#D#D#D#D#D#DDEEEEEEEEEEEEEEE"d* %s4yy00 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +sE/E AE" E- E/E$!D  ED ED E4 EE EE E E/E E/E E//E36E3c&K|j5|jdkr tjt 5|jd{Vdddn #1swxYwYddddS#1swxYwYdS)Nr2)r'r r5rrr wait_writabler,s rwait_send_all_might_not_blockz*SocketStream.wait_send_all_might_not_blockvs  ) 2 2{!!##r))..:<< 2 2k//111111111 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2s58B A." B.A2 2B5A2 6BB  B cZK|j5tjd{V|jjr ddddSt 5|jtj dddn #1swxYwYddddS#1swxYwYdSN) r'rr6r7r r3rshutdownr"SHUT_WRr@s rsend_eofzSocketStream.send_eof}sN  ) 6 6-**,, , , , , , , ,{/   6 6 6 6 6 6 6 6 ;<< 6 6 $$W_555 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6  6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6s;2B  B %B< B B B B B  B$'B$N max_bytes int | NonebytescK|t}|dkrtdt5|j|d{VcdddS#1swxYwYdS)Nrzmax_bytes must be >= 1)DEFAULT_RECEIVE_SIZEr&rr recv)r,rGs r receive_somezSocketStream.receive_somes  ,I q==566 6 6 8 8 5 5)))44444444 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5s AA #A cK|jtjd{VdSrCr closerr6r7r@s raclosezSocketStream.aclosesF m&&(((((((((((levelintoptionvalue int | BuffercdSrC)r,rSrUrVs rr(zSocketStream.setsockoptsPSPSrRlengthcdSrCrYr,rSrUrVrZs rr(zSocketStream.setsockoptsUXUXrRint | Buffer | Nonec|-|td|j|||S|td|d|j||||S)zlSet an option on the underlying socket. See :meth:`socket.socket.setsockopt` for details. NzKinvalid value for argument 'value', must not be None when specifying lengthz$invalid value for argument 'value': z%, must be None when specifying optlen)r#r r(r\s rr(zSocketStream.setsockopts >}a;))%?? ?  eueee {%%eVUFCCCrRcdSrCrY)r,rSrUs r getsockoptzSocketStream.getsockopts:=#rR buffersizecdSrCrYr,rSrUras rr`zSocketStream.getsockoptsMPSrRr int | bytesc||dkr|j||S|j|||S)zCheck the current value of an option on the underlying socket. See :meth:`socket.socket.getsockopt` for details. r)r r`rcs rr`zSocketStream.getsockopts? ??;))%88 8;))%DD DrRr r)r.r/rr0rr0rC)rGrHrrI)rSrTrUrTrVrWrr0) rSrTrUrTrVr0rZrTrr0) rSrTrUrTrVr]rZrHrr0)rSrTrUrTrrT)rSrTrUrTrarTrrI)r)rSrTrUrTrarTrrd) __name__ __module__ __qualname____doc__r-r=rArFrMrQrr(r`rYrRrrr.s>.WWWW<++++"2222666655555)))) SSSXS XXXXX" DDDDD0===X= PPPXP E E E E E E ErRr)EPERM ECONNABORTEDEPROTOENETDOWN ENOPROTOOPT EHOSTDOWNENONET EHOSTUNREACH EOPNOTSUPP ENETUNREACHENOSRESOCKTNOSUPPORTEPROTONOSUPPORT ETIMEDOUT ECONNRESETzset[int]_ignorable_accept_errnosc*eZdZdZd dZd dZd d Zd S)SocketListeneraA :class:`~trio.abc.Listener` that uses a listening socket to accept incoming connections as :class:`SocketStream` objects. Args: socket: The Trio socket object to wrap. Must have type ``SOCK_STREAM``, and be listening. Note that the :class:`SocketListener` "takes ownership" of the given socket; closing the :class:`SocketListener` will also close the socket. .. attribute:: socket The Trio socket object that this stream wraps. r rcHt|tjstd|jtjkrt d |tjtj }|st dn#t$rYnwxYw||_ dS)Nz,SocketListener requires a Trio socket objectz,SocketListener requires a SOCK_STREAM socketz*SocketListener requires a listening socket) r!r"rr#r$r%r&r` SOL_SOCKET SO_ACCEPTCONNrr )r,r listenings rr-zSocketListener.__init__os&'"455 LJKK K ;'- - -KLL L O))'*STTI  O !MNNN O     D  s*B BBrrcK |jd{V\}}t|S#t$r4}|jt vr t jd|jtvrYd}~nd}~wwxYwt)a#Accept an incoming connection. Returns: :class:`SocketStream` Raises: OSError: if the underlying call to ``accept`` raises an unexpected error. ClosedResourceError: if you already closed the socket. This method handles routine errors like ``ECONNABORTED``, but passes other errors on to its caller. In particular, it does *not* make any special effort to handle resource exhaustion errors like ``EMFILE``, ``ENFILE``, ``ENOBUFS``, ``ENOMEM``. TN) r acceptrrrrrrr{)r,sock_rs rrzSocketListener.accepts" * * $ 2 2 4 4444444a$D)))    9 5552<9$<<<=<<<<  *s"6 A4*A//A4r0cK|jtjd{VdS)z.Close this listener and its underlying socket.NrOr@s rrQzSocketListener.aclosesF m&&(((((((((((rRNrf)rrrg)rhrirjrkr-rrQrYrRrr}r}]sZ  ****8))))))rRr})rr)( __future__rr contextlibrrtypingrrrr r"_utilr r abcr r collections.abcrtyping_extensionsr_socketrrKEBADFENOTSOCKrrr_ignorable_accept_errno_namessetr{__annotations__nameAttributeErroraddgetattrr}rYrRrrst""""""" ////////******** ********........$))))))((((((######  K N XXXXVEVEVEVEVE&VEVEVEb!!!.&)SUU**** );;D . ! !;; $$WWUD%9%9:::;;;;;;;;;;;;;;;@)@)@)@)@)Xl+@)@)@)@)@)s C  C C