UddlmZddlZddlmZmZddlmZmZddl Z ddl m Z ddl mZmZddlmZmZer dd lmZdd lmZddlZej0d k\rdd lmZnerdd lmZd Zej8ej:hZeddZeGddeZ gdZ!e"Z#de$d<e!D]+Z%ee&5e#jOe(ee%ddd-eGddee Z)y#1swYKxYw)) annotationsN)contextmanagersuppress) TYPE_CHECKINGoverload)socket)ConflictDetectorfinal)HalfCloseableStreamListener) Generator) SocketType) )Bufferic#K dy#t$rF}|jtvrtjddtj d||d}~wwxYww)Nzthis socket was already closedzsocket connection broken: )OSErrorerrno_closed_stream_errnostrioClosedResourceErrorBrokenResourceError)excs I/var/www/zara/venv/lib/python3.12/site-packages/trio/_highlevel_socket.py)_translate_socket_errors_to_stream_errorsr+s^X X 99- -**+KLRV V**-Gu+MNTW W Xs%A A AAAAAceZdZdZddZddZddZddZdddZddZ e dd Z e dd Z d dd Z e dd Z e dd Z dddZ y) 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. c:t|tjs td|jtj k7r t d||_td|_ tt5|jtjtjddddttdrHtt5|jtjtj ddddyy#1swYbxYw#1swYyxYw)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&'"4"45HI I ;;'-- -IJ J '7 I( $g  L OOG//1D1Dd K L 7/ 0'" W 3 3W5N5NPUV W W 1 L L W Ws40D 0DDDc K|jjrtjd|j5t 5t |5}|sr|jjdk(rtjdtjjd{ dddddddddyd}|t|krE||d5}|jj|d{}ddd|z }|t|krEdddddddddy77;#1swY:xYw#1swY*xYw#1swY.xYw#1swYyxYww)Nz!can't send data after sending EOFzsocket was already closedr) r did_shutdown_SHUT_WRrrr'r memoryviewfilenolowlevel checkpointlensend)r,data total_sent remainingsents rsend_allzSocketStream.send_allmsL ;; + +**+NO O  ) ) +:< +% +;;--/25"&":":;V"WW"mm66888 + + + +"#J$s4y0!*+.E))-)9)9))D#DDE"d* %s4y0 + + + + 9 $EEE + + + + + +s8E( E EAE'D4 (E-E5E= E(ED8 :D6 ;D8 ?EE#E+ E(4E6D8 8E =EE EE EE%!E(c.K|j5|jjdk(rtjt 5|jj d{ddddddy7#1swYxYw#1swYyxYww)Nr/)r'r r2rrr wait_writabler,s rwait_send_all_might_not_blockz*SocketStream.wait_send_all_might_not_block~s  ) ) 2{{!!#r)...:< 2kk//111 2 2 22 2 2 2 2sF B8B A=%A;&A=*B 2 B;A==B B  BBcnK|j5tjjd{|jj r dddyt 5|jjtjddddddy7i#1swYxYw#1swYyxYwwN) r'rr3r4r r0rshutdownr"SHUT_WRr>s rsend_eofzSocketStream.send_eofs  ) ) 6--**, , ,{{//  6 6 ;< 6 $$W__5 6  6 6 ,  6 6  6 6sP B5"B)BB) B5 B) *B B) B5B)B& "B))B2.B5NcK|t}|dkr tdt5|jj |d{cdddS7 #1swYyxYww)Nrzmax_bytes must be >= 1)DEFAULT_RECEIVE_SIZEr&rr recv)r, max_bytess r receive_somezSocketStream.receive_somes\  ,I q=56 6 6 8 5)))44 5 54 5 5s.#A AAA A AAA cK|jjtjj d{y7wrAr closerr3r4r>s raclosezSocketStream.acloses, mm&&(((}a;;))%? ?  6ui?de {{%%eVUFCCrTcyrArP)r,rQrRs r getsockoptzSocketStream.getsockopts:=rTcyrArPr,rQrR buffersizes rrZzSocketStream.getsockoptsMPrTc~|dk(r|jj||S|jj|||S)zCheck the current value of an option on the underlying socket. See :meth:`socket.socket.getsockopt` for details. r)r rZr\s rrZzSocketStream.getsockopts; ?;;))%8 8;;))%D DrTr rreturnNone)r7zbytes | bytearray | memoryviewr`rar`rarA)rH int | Noner`bytes)rQintrRrerSz int | Bufferr`ra) rQrerRrerSrarWrer`ra) rQrerRrerSzint | Buffer | NonerWrcr`ra)rQrerRrer`re)rQrerRrer]rer`rd)r)rQrerRrer]rer`z int | bytes) __name__ __module__ __qualname____doc__r-r;r?rDrIrMrr(rZrPrTrrr6s.W<+"265) SS XX" DDD# D  D  D0== PP ErTr)EPERM ECONNABORTEDEPROTOENETDOWN ENOPROTOOPT EHOSTDOWNENONET EHOSTUNREACH EOPNOTSUPP ENETUNREACHENOSRESOCKTNOSUPPORTEPROTONOSUPPORT ETIMEDOUT ECONNRESETzset[int]_ignorable_accept_errnosc(eZdZdZddZddZddZy) 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. cPt|tjs td|jtj k7r t d |jtjtj}|s t d||_ y#t$r Y||_ ywxYw)Nz,SocketListener requires a Trio socket objectz,SocketListener requires a SOCK_STREAM socketz*SocketListener requires a listening socket) r!r"rr#r$r%r&rZ SOL_SOCKET SO_ACCEPTCONNrr )r,r listenings rr-zSocketListener.__init__xs&'"4"45JK K ;;'-- -KL L O))'*<*S>STI  !MNN      s.B B%$B%c K |jjd{\}}t|S7#t$r@}|jt vrt jd|jtvrYd}~nd}~wwxYww)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``. N) r acceptrrrrrrry)r,sock_rs rrzSocketListener.accepts" * $ 2 2 44a$D))5 99 5522<99$<<= s7B757 B7 B6A;6B;BBcK|jjtjj d{y7w)z.Close this listener and its underlying socket.NrKr>s rrMzSocketListener.acloses, mm&&(((rNNr_)r`rrb)rfrgrhrir-rrMrPrTrr{r{fs  *8)rTr{)r`zGenerator[None, None, None])* __future__rr contextlibrrtypingrrrr r"_utilr r abcr r collections.abcr_socketrsys version_infortyping_extensionsrFEBADFENOTSOCKrrr_ignorable_accept_errno_namessetry__annotations__nameAttributeErroraddgetattrr{rPrTrrs" /* *.)# w'(  KK NN XXWE&WEWEd!.&)U(* );D . !; $$WUD%9:;;; @)Xl+@)@) ;;s 6C--C6