vKgu=%SSKJr SSKrSSKJrJr SSKJrJr SSK r SSK J r SSK JrJr SSKJrJr \(aSS KJr SS KJr SS KJr S r\R4\R61r\SS j5r\"SS\55r/SQr\ "5r!S\"S'\H,r#\"\$5 \!RK\&"\\#55 SSS5 M. \"SS\\55r'g!,(df  MS=f)) annotationsN)contextmanagersuppress) TYPE_CHECKINGoverloadsocket)ConflictDetectorfinal)HalfCloseableStreamListener) Generator)Buffer) SocketTypeic## Sv g![aJnUR[;a[R"S5Se[R "SU35UeSnAff=f7f)Nzthis socket was already closedzsocket connection broken: )OSErrorerrno_closed_stream_errnostrioClosedResourceErrorBrokenResourceError)excs V/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/trio/_highlevel_socket.py)_translate_socket_errors_to_stream_errorsr#s]X X 99- -**+KLRV V**-Gu+MNTW W Xs%A  A  AAAAA c\rSrSrSrSSjrSSjrSSjrSSjrSSSjjr SS jr \ SS j5r \ SS j5r SSS jjr \ SS j5r \ SSj5r SSSjjr Srg) SocketStream.u*An 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. cb[U[R5(d [S5eUR[R :wa [ S5eXl[S5Ul [[5 UR[R[RS5 SSS5 [[S5(aH[[5 UR[R[R S5 SSS5 gg!,(df  Nl=f!,(df  g=f)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__SocketStream.__init__Gs&'"4"455HI I ;;'-- -IJ J '7 I( $g  OOG//1D1Dd K 7/ 0 0'" 3 3W5N5NPUV#" 1 #"s90D0D  D D.c # URR(a[R"S5eUR [ 5 [ U5nU(dtURR5S:Xa[R"S5e[RR5IShvN SSS5 SSS5 SSS5 gSnU[U5:aFXSnURRU5IShvN nSSS5 UW- nU[U5:aMFSSS5 SSS5 SSS5 gNN=!,(df  NA=f!,(df  N4=f!,(df  N==f!,(df  g=f7f)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_allSocketStream.send_alles# ;; + +**+NO O  ) ):<%;;--/25"&":":;V"WW"mm66888 &=* )"#J$s4y0!+.))-)9)9))D#DD/"d* %s4y0&=* ) 9 $E/.&%=<* )s>F  E: E)AE4E 5E:E)E: F E(E E E E*E)2E:: F EE  E E E& "E)) E7 3E:: FF cD# UR URR5S:Xa[Re[ 5 URR 5IShvN SSS5 SSS5 gN!,(df  N=f!,(df  g=f7f)Nr0)r'r r3rrr wait_writabler,s rwait_send_all_might_not_block*SocketStream.wait_send_all_might_not_blockvsn  ) ){{!!#r)...:<kk//111=* )2=<* )sF B 9BA>&A<'A>+B3 B <A>> B B BB c# UR [RR5IShvN URR (a SSS5 g[ 5 URR[R5 SSS5 SSS5 gNn!,(df  N=f!,(df  g=f7fN) r'rr4r5r r1rshutdownr"SHUT_WRr@s rsend_eofSocketStream.send_eof}s}  ) )--**, , ,{{// * ) ;< $$W__5= * ) , =< * )sP C"B3B  B3 C B3%*B"B3 C B3" B0 ,B33 C=CNc# Uc[nUS:a [S5e[5 URR U5IShvN sSSS5 $N !,(df  g=f7f)Nrzmax_bytes must be >= 1)DEFAULT_RECEIVE_SIZEr&rr recv)r, max_bytess r receive_someSocketStream.receive_somesQ  ,I q=56 6 6 8)))449 849 8s.%A'AAA A'A A$ A'c# URR5 [RR 5IShvN gN7frDr closerr4r5r@s racloseSocketStream.acloses+ mm&&(((}a;;))%? ?  6ui?de {{%%eUCCr[cgrDrV)r,rWrXs r getsockoptSocketStream.getsockopts:=r[cgrDrVr,rWrX buffersizes rrarbsMPr[c|US:XaURRX5$URRXU5$)zsCheck the current value of an option on the underlying socket. See :meth:`socket.socket.getsockopt` for details. r)r rards rrarbs7 ?;;))%8 8;;))%D Dr[)r'r r r)r8zbytes | bytearray | memoryviewreturnNonerhrirD)rL int | Nonerhbytes)rWintrXrmrYz int | Bufferrhri) rWrmrXrmrYrir^rmrhri) rWrmrXrmrYzint | Buffer | Noner^rkrhri)rWrmrXrmrhrm)rWrmrXrmrermrhrl)r)rWrmrXrmrermrhz int | bytes)__name__ __module__ __qualname____firstlineno____doc__r-r<rArGrMrRrr(ra__static_attributes__rVr[rrr.s.W<+"265) SS XX" DDD# D  D  D0== PP E Er[r)EPERM ECONNABORTEDEPROTOENETDOWN ENOPROTOOPT EHOSTDOWNENONET EHOSTUNREACH EOPNOTSUPP ENETUNREACHENOSRESOCKTNOSUPPORTEPROTONOSUPPORT ETIMEDOUT ECONNRESETzset[int]_ignorable_accept_errnosc6\rSrSrSrSSjrS SjrS SjrSrg) SocketListeneri]aA :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. cZ[U[R5(d [S5eUR[R :wa [ S5eUR[R[R5nU(d [ S5eXl g![a Nf=f)Nz,SocketListener requires a Trio socket objectz,SocketListener requires a SOCK_STREAM socketz*SocketListener requires a listening socket) r!r"rr#r$r%r&ra SOL_SOCKET SO_ACCEPTCONNrr )r,r listenings rr-SocketListener.__init__os&'"4"455JK K ;;'-- -KL L O))'*<*S>STI  !MNN    s.B B*)B*c# URR5IShvN up[U5$N![aDnUR[ ;a[ RSeUR[;aeSnAOSnAff=fM7f)aAccept 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 acceptrrrrrrr)r,sock_rs rrSocketListener.accepts}" * $ 2 2 44$D))5 99 5522<99$<<= s7B 646 B 6 B:A?:B ?BB c# URR5 [RR 5IShvN gN7f)z.Close this listener and its underlying socket.NrPr@s rrRSocketListener.acloses+ mm&&(((rTr Nrg)rhrrj) rnrorprqrrr-rrRrsrVr[rrr]s  *8)r[r)rhzGenerator[None, None, None])( __future__rr contextlibrrtypingrrrr r"_utilr r abcr rcollections.abcrtyping_extensionsr_socketrrJEBADFENOTSOCKrrr_ignorable_accept_errno_namessetr__annotations__nameAttributeErroraddgetattrrrVr[rrs" /* *.)(#  KK NN XXVE&VEVEb!.&)U(* )D . ! $$WUD%9: " ! * @)Xl+@)@) " !s C C(