a xd@slddlZddlZddlmZddlmZmZddlZejdkrBe dZ GdddZ Gd d d eed Z dS) N)Stream)ConflictDetectorFinalposixic@s>eZdZedddZeddZddZdd Zd d Z d S) _FdHolderfdcCs:d|_t|tstd||_t||_t|ddS)Nzfile descriptor must be an intF)r isinstanceint TypeErroros get_blocking_original_is_blocking set_blockingselfr rH/var/www/html/Ranjet/env/lib/python3.9/site-packages/trio/_unix_pipes.py__init__%s   z_FdHolder.__init__cCs |jdkSNr rrrrrclosed0sz_FdHolder.closedcCs2|jr dS|j}d|_t||jt|dSr)rr rrrcloserrrr _raw_close4s z_FdHolder._raw_closecCs |dSN)rrrrr__del__Csz_FdHolder.__del__cCs |jstj|j|dSr)rtriolowlevelZnotify_closingr rrrrrrFsz_FdHolder.closeN) __name__ __module__ __qualname__r rpropertyrrrrrrrrrs   rc@sbeZdZdZedddZedddZdd d d Zded d d Z ddZ ddZ 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. rcCs"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_detectorrrrrrms zFdStream.__init__)datac sB|j$|jjrtdtjIdHt|}t|}d}||kr||d}z|t |jj |7}Wnlt ytj |jj IdHYnFty}z.|jtjkrtddntj|WYd}~n d}~00WdqB1s0YqBWdn1s0YWdn1s40YdS)Nfile was already closedr)r&r%rrClosedResourceErrorr checkpointlen memoryviewrwriter BlockingIOError wait_writableOSErrorerrnoEBADFBrokenResourceError)rr(lengthviewsent remainingerrrsend_allvs*     zFdStream.send_allN)returnc s|jj|jjrtdztj|jjIdHWn,ty`}ztj |WYd}~n d}~00Wdn1sv0YdS)Nr)) r&r%rrr*rr0r BrokenPipeErrorr4)rr9rrrwait_send_all_might_not_blocks z&FdStream.wait_send_all_might_not_blockc s|j|durt}n"t|ts(td|dkr8tdtjIdHzt |j j |}Wqt ytj|j j IdHYqHty}z.|jtjkrtddntj|WYd}~qHd}~00qqH|WdS1s0YdS)Nzmax_bytes must be integer >= 1rr))r'DEFAULT_RECEIVE_SIZEr r r ValueErrorrrr+rreadr%r r/Z wait_readabler1r2r3r*r4)rZ max_bytesr(r9rrr receive_somes,   zFdStream.receive_somecCs|jdSr)r%rrrrrrszFdStream.closecs|tjIdHdSr)rrrr+rrrracloseszFdStream.aclosecCs|jjSr)r%r rrrrfilenoszFdStream.fileno)N) r r!r"__doc__r rbytesr:r=rArrBrCrrrrr$Ls   r$) metaclass) rr2_abcrZ_utilrrrname ImportErrorr>rr$rrrrs  9