i>UddlmZddlZddlmZmZddlmZmZddl Z ddl m Z ddl mZmZddlmZmZer dd lmZdd lmZddlZejd krdd lmZnerdd lmZd ZejejhZeddZeGddeZ gdZ!e"Z#de$d<e!D]DZ%ee&5e#'e(ee%dddn #1swxYwYEeGddee Z)dS)) annotationsN)contextmanagersuppress) TYPE_CHECKINGoverload)socket)ConflictDetectorfinal)HalfCloseableStreamListener) Generator) SocketType) )BufferireturnGenerator[None, None, None]c#K dVdS#t$r@}|jtvrtjddtjd||d}~wwxYw)Nzthis socket was already closedzsocket connection broken: )OSErrorerrno_closed_stream_errnostrioClosedResourceErrorBrokenResourceError)excs b/var/www/html/nodeJS/PythonScripts/venv3.11/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 rrNonecbt|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__Os&'"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 | memoryviewc 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/r1 total_sent remainingsents rsend_allzSocketStream.send_allms ; + 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)Nr4)r*r r7rrr wait_writabler/s rwait_send_all_might_not_blockz*SocketStream.wait_send_all_might_not_block~s  ) 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*rr8r9r r5rshutdownr%SHUT_WRrBs rsend_eofzSocketStream.send_eofsN  ) 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/rIs 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{VdSrEr closerr8r9rBs raclosezSocketStream.aclosesF m&&(((((((((((levelintoptionvalue int | BuffercdSrE)r/rUrWrXs rr+zSocketStream.setsockoptsPSPSrTlengthcdSrEr[r/rUrWrXr\s rr+zSocketStream.setsockoptsUXUXrTint | 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 {%%eVUFCCCrTcdSrEr[)r/rUrWs r getsockoptzSocketStream.getsockopts:=#rT buffersizecdSrEr[r/rUrWrcs rrbzSocketStream.getsockoptsMPSrTr 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 rbres rrbzSocketStream.getsockopts? ??;))%88 8;))%DD DrTr rrr!)r1r2rr!rr!rE)rIrJrrK)rUrVrWrVrXrYrr!) rUrVrWrVrXr!r\rVrr!) rUrVrWrVrXr_r\rJrr!)rUrVrWrVrrV)rUrVrWrVrcrVrrK)r)rUrVrWrVrcrVrrf) __name__ __module__ __qualname____doc__r0r?rCrHrOrSrr+rbr[rTrr r 6s>.WWWW<++++"2222666655555)))) SSSXS XXXXX" DDDDD0===X= PPPXP E E E E E E ErTr )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 rrr!cHt|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)rb SOL_SOCKET SO_ACCEPTCONNrr )r/r listenings rr0zSocketListener.__init__xs&'"455 LJKK K ;'- - -KLL L O))'*STTI  O !MNNN O     D  s*B BBr cK |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 acceptr rrrrrr})r/sock_rs rrzSocketListener.accepts" * * $ 2 2 4 4444444a$D)))    9 5552<9$<<<=<<<<  *s"6 A4*A//A4cK|jtjd{VdS)z.Close this listener and its underlying socket.NrQrBs rrSzSocketListener.aclosesF m&&(((((((((((rTNrh)rr ri)rjrkrlrmr0rrSr[rTrrrfsZ  ****8))))))rTr)rr)* __future__rr contextlibrrtypingrrrr r%_utilr r abcr r collections.abcr_socketrsys version_infortyping_extensionsrMEBADFENOTSOCKrrr _ignorable_accept_errno_namessetr}__annotations__nameAttributeErroraddgetattrrr[rTrrs""""""" ////////******** ********........$))))))###### w'&&&&&&)((((((  K N XXXXWEWEWEWEWE&WEWEWEd!!!.&)SUU**** );;D . ! !;; $$WWUD%9%9:::;;;;;;;;;;;;;;;@)@)@)@)@)Xl+@)@)@)@)@)s6 C""C& )C&