U g @sUddlmZddlZddlZddlZddlmZddlZddlm Z ddl m Z m Z erfddlm Zerxejdksxtejd kred Zd ed <Gd ddZe Gddde ZdS)) annotationsN) TYPE_CHECKING)Stream)ConflictDetectorfinal)Finalwin32posixi FinalTypeDEFAULT_RECEIVE_SIZEc@sbeZdZUded<dddddZeddd d Zddd d Zddd dZddddZ dS) _FdHolderintfdNonerreturncCs:d|_t|tstd||_t||_t|ddS)Nzfile descriptor must be an intF)r isinstancer TypeErroros get_blocking_original_is_blocking set_blockingselfrr4/tmp/pip-unpacked-wheel-ks04xdmi/trio/_unix_pipes.py__init__0s   z_FdHolder.__init__boolrcCs |jdkSNr)rrrrrclosed;sz_FdHolder.closedcCs2|jr dS|j}d|_t||jt|dSr!)r#rrrrcloserrrr _raw_close?s z_FdHolder._raw_closecCs |dSN)r%r"rrr__del__Nsz_FdHolder.__del__cCs |jstj|j|dSr&)r#triolowlevelZnotify_closingrr%r"rrrr$Qsz_FdHolder.closeN) __name__ __module__ __qualname____annotations__rpropertyr#r%r'r$rrrrr s  r c@szeZdZdZdddddZdddd d Zdd d d ZddddddZdd ddZdd ddZ dd ddZ dS)FdStreama< Represents 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. Args: fd (int): The fd to be wrapped. Returns: A new `FdStream` object. rrrcCs"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_detectorrrrrrys zFdStream.__init__bytes)datarc s|j|jjrtdtjIdHt|}t|}d}||kr||d}z|t |jj |7}Wnlt k rtj |jj IdHYnDtk r}z&|jtjkrtddntj|W5d}~XYnXW5QRXq@W5QRXW5QRXdS)Nfile was already closedr)r1r0r#r(ClosedResourceErrorr) checkpointlen memoryviewrwriterBlockingIOError wait_writableOSErrorerrnoEBADFBrokenResourceError)rr4lengthviewsent remainingerrrsend_alls*   zFdStream.send_allr c sn|j^|jjrtdztj|jjIdHWn*tk r^}z tj |W5d}~XYnXW5QRXdS)Nr5) r1r0r#r(r6r)r<rBrokenPipeErrorr@)rrErrrwait_send_all_might_not_blocks z&FdStream.wait_send_all_might_not_blockNz int | None) max_bytesrc s|j|dkrt}n"t|ts(td|dkr8tdtjIdHzt |j j |}Wqt k rtj|j j IdHYqHtk r}z&|jtjkrtddntj|W5d}~XYqHXqqH|W5QRSQRXdS)Nzmax_bytes must be integer >= 1rr5)r2r rrr ValueErrorr(r)r7rreadr0rr;Z wait_readabler=r>r?r6r@)rrIr4excrrr receive_somes,  zFdStream.receive_somecCs|jdSr&)r0r$r"rrrr$szFdStream.closecs|tjIdHdSr&)r$r(r)r7r"rrracloseszFdStream.aclosecCs|jjSr&)r0rr"rrrfilenoszFdStream.fileno)N) r*r+r,__doc__rrFrHrMr$rNrOrrrrr/Ws   r/) __future__rr>rsystypingrr(_abcrZ_utilrrrr platformAssertionErrorname ImportErrorr r-r r/rrrrs"      ;