i, UddlmZddlZddlZddlZddlmZmZddl Z ddl m Z ddl m Z mZer ejdksJdZd ed <Gd d ZeGd de ZdS)) annotationsN) TYPE_CHECKINGFinal)Stream)ConflictDetectorfinalwin32i FinalTypeDEFAULT_RECEIVE_SIZEcReZdZUded<d dZed dZddZdd Zdd Z d S) _FdHolderintfdreturnNonecd|_t|tstd||_t j||_t j|ddS)Nzfile descriptor must be an intF)r isinstancer TypeErroros get_blocking_original_is_blocking set_blockingselfrs \/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_unix_pipes.py__init__z_FdHolder.__init__(s]"c"" ><== =%'_R%8%8" E"""""boolc|jdkSNr)rrs rclosedz_FdHolder.closed3sw"}rc|jrdS|j}d|_tj||jtj|dSr")r$rrrrclosers r _raw_closez_FdHolder._raw_close7sG ;  F W D6777  rc.|dSN)r'r#s r__del__z_FdHolder.__del__Fs rc|js:tj|j|dSdSr))r$triolowlevelnotify_closingrr'r#s rr&z_FdHolder.closeIsD{  M ( ( 1 1 1 OO       rNrrrr)rr rr) __name__ __module__ __qualname____annotations__rpropertyr$r'r*r&rrrrs$ GGG # # # #X    rrcLeZdZdZddZdd Zdd ZdddZddZddZ ddZ d S)FdStreamaRepresents a stream given the file descriptor to a pipe, TTY, etc. *fd* must refer to a file that is open for reading and/or writing and supports non-blocking I/O (pipes and TTYs will work, on-disk files probably not). The returned stream takes ownership of the fd, so closing the stream will close the fd too. As with `os.fdopen`, you should not directly use an fd after you have wrapped it in a stream using this function. To be used as a Trio stream, an open file must be placed in non-blocking mode. Unfortunately, this impacts all I/O that goes through the underlying open file, including I/O that uses a different file descriptor than the one that was passed to Trio. If other threads or processes are using file descriptors that are related through `os.dup` or inheritance across `os.fork` to the one that Trio is using, they are unlikely to be prepared to have non-blocking I/O semantics suddenly thrust upon them. For example, you can use ``FdStream(os.dup(sys.stdin.fileno()))`` to obtain a stream for reading from standard input, but it is only safe to do so with heavy caveats: your stdin must not be shared by any other processes, and you must not make any calls to synchronous methods of `sys.stdin` until the stream returned by `FdStream` is closed. See `issue #174 `__ for a discussion of the challenges involved in relaxing this restriction. .. warning:: one specific consequence of non-blocking mode applying to the entire open file description is that when your program is run with multiple standard streams connected to a TTY (as in a terminal emulator), all of the streams become non-blocking when you construct an `FdStream` for any of them. For example, if you construct an `FdStream` for standard input, you might observe Python loggers begin to fail with `BlockingIOError`. Args: fd (int): The fd to be wrapped. Returns: A new `FdStream` object. rrrrc~t||_td|_td|_dS)Nz*another task is using this stream for sendz-another task is using this stream for receive)r _fd_holderr_send_conflict_detector_receive_conflict_detectorrs rrzFdStream.__init__ysA#B--'7 8( ( $+; ;+ + '''rdatabytescK|j5|jjrtjdtjd{Vt|}t|5}d}||kr||d5} |tj |jj |z }n#t$r2tj |jj d{VYnHt$r<}|jtjkrtjddtj|d}~wwxYwdddn #1swxYwY||kdddn #1swxYwYddddS#1swxYwYdS)Nfile was already closedr)r;r:r$r,ClosedResourceErrorr- checkpointlen memoryviewrwriterBlockingIOError wait_writableOSErrorerrnoEBADFBrokenResourceError)rr=lengthviewsent remaininges rsend_allzFdStream.send_alls  ) F F% J./HIII-**,, , , , , , , ,YYFD!! FTVmmdee F  F BHT_-?$K$KKDD.RRR"&-"="=do>P"Q"QQQQQQQQQQ&FFF w%+55&*&>$='"'"'+!,'+&>A E F F F F F F F F F F F F F F F FVmm F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F FsA#E)-ED4"B%$D4%9D% D4 D% )7D D% %D4( E4D8 8E;D8 < E E)E E)E E))E-0E-cK|j5|jjrtjdtj|jjd{VddddS#1swxYwYdS)Nr@)r;r:r$r,rAr-rGrr#s rwait_send_all_might_not_blockz&FdStream.wait_send_all_might_not_blocks  ) B B% J./HIII---do.@AA A A A A A A A B B B B B B B B B B B B B B B B B BsAA''A+.A+N max_bytes int | NonecfK|j5|t}n9t|tst d|dkrt dt jd{V tj |j j |}n#t$r2t j|j j d{VYnHt$r<}|jt jkrt jddt j|d}~wwxYw|cdddS#1swxYwYdS)Nzmax_bytes must be integer >= 1rTr@)r<r rrr ValueErrorr,r-rBrreadr:rrF wait_readablerHrIrJrArK)rrTr=excs r receive_somezFdStream.receive_somes  ,   0 !)S11F#$DEEEq==$%EFFF-**,, , , , , , , ,  74?#5yAAD'JJJ-55do6HIIIIIIIIIII@@@yEK//"65#$#6C? @ 3                  sBA)D&4BD&9D D& D7DDD&&D*-D*c8|jdSr))r:r&r#s rr&zFdStream.closes rczK|tjd{VdSr))r&r,r-rBr#s raclosezFdStream.acloses? m&&(((((((((((rc|jjSr))r:rr#s rfilenozFdStream.filenos !!rr/)r=r>rrr0r))rTrUrr>)rr) r1r2r3__doc__rrQrSr[r&r^r`r6rrr8r8Os&&P    FFFF2BBBB 8    ))))""""""rr8) __future__rrIrsystypingrrr r,_abcr_utilrr platformr r4rr8r6rrrhs""""""" 44444444 ******** 3CLG3333#(''''88888888vu"u"u"u"u"vu"u"u"u"u"r