i>%SSKJr SSKrSSKJrJr SSKJrJr SSK r SSK J r SSK JrJr SSKJrJr \(a SS KJr SS KJr SSKr\R0S :aSS KJr O \(aSS KJr S r\R8\R:1r\SSj5r\"SS\55r /SQr!\""5r#S\$S'\!H,r%\"\&5 \#RO\("\\%55 SSS5 M. \"SS\\ 55r)g!,(df  MS=f)) annotationsN)contextmanagersuppress) TYPE_CHECKINGoverloadsocket)ConflictDetectorfinal)HalfCloseableStreamListener) Generator) SocketType) )Bufferic## Sv g![aJnUR[;a[R"S5Se[R "SU35UeSnAff=f7f)Nzthis socket was already closedzsocket connection broken: )OSErrorerrno_closed_stream_errnostrioClosedResourceErrorBrokenResourceError)excs CC:\des-py\RoboSAPF\venv\Lib\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) SocketStream6u*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__Os&'"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_allms# ;; + +**+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)Nr2)r)r r5rrr wait_writabler.s rwait_send_all_might_not_block*SocketStream.wait_send_all_might_not_block~sn  ) ){{!!#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)rr6r7r r3rshutdownr$SHUT_WRrBs rsend_eofSocketStream.send_eofs}  ) )--**, , ,{{// * ) ;< $$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 gN7frFr closerr6r7rBs racloseSocketStream.acloses+ mm&&(((}a;;))%? ?  6ui?de {{%%eUCCr]cgrFrX)r.rYrZs r getsockoptSocketStream.getsockopts:=r]cgrFrXr.rYrZ buffersizes rrcrdsMPr]c|US:XaURRX5$URRXU5$)zsCheck the current value of an option on the underlying socket. See :meth:`socket.socket.getsockopt` for details. r)r rcrfs rrcrds7 ?;;))%8 8;;))%D Dr])r)r r rreturnNone)r:zbytes | bytearray | memoryviewrjrkrjrkrF)rN int | Nonerjbytes)rYintrZror[z int | Bufferrjrk) rYrorZror[rkr`rorjrk) rYrorZror[zint | Buffer | Noner`rmrjrk)rYrorZrorjro)rYrorZrorgrorjrn)r)rYrorZrorgrorjz int | bytes)__name__ __module__ __qualname____firstlineno____doc__r/r>rCrIrOrTrr*rc__static_attributes__rXr]rrr6s.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) SocketListenerifaA :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(rc SOL_SOCKET SO_ACCEPTCONNrr )r.r listenings rr/SocketListener.__init__xs&'"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.NrRrBs rrTSocketListener.acloses+ mm&&(((rVr Nri)rjrrl) rprqrrrsrtr/rrTrurXr]rrrfs  *8)r]r)rjzGenerator[None, None, None])* __future__rr contextlibrrtypingrrrr r$_utilr r abcr rcollections.abcr_socketrsys version_infortyping_extensionsrLEBADFENOTSOCKrrr_ignorable_accept_errno_namessetr__annotations__nameAttributeErroraddgetattrrrXr]rrs " /* *.)# w'(  KK NN XXWE&WEWEd!.&)U(* )D . ! $$WUD%9: " ! * @)Xl+@)@) " !s C;; D