o US`c@slddlZddlZddlmZddlmZmZddlZejdkr!e dZ GdddZ Gd d d eed Z dS) N)Stream)ConflictDetectorFinalposixic@s>eZdZdefddZeddZddZdd Zd d Z d S) _FdHolderfdcCs:d|_t|ts td||_t||_t|ddS)Nzfile descriptor must be an intF)r isinstanceint TypeErroros get_blocking_original_is_blocking set_blockingselfrr;/usr/local/lib/python3.10/dist-packages/trio/_unix_pipes.py__init__%s   z_FdHolder.__init__cCs |jdkSNr )rrrrrclosed0s z_FdHolder.closedcCs2|jrdS|j}d|_t||jt|dSr)rrr rrcloserrrr _raw_close4s z_FdHolder._raw_closecCs |dSN)rrrrr__del__Cs z_FdHolder.__del__cCs$|jstj|j|dSdSr)rtriolowlevelZnotify_closingrrrrrrrFs z_FdHolder.closeN) __name__ __module__ __qualname__r rpropertyrrrrrrrrrs  rc@s^eZdZdZdefddZdefddZdd d Zddefd d Z ddZ ddZ ddZ d S)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 sH|j|jjrtdtjIdHt|}t|d}d}||kr{||dD}z |t |jj |7}Wn/t yLtj |jj IdHYntyg}z|jtjkr_tddtj|d}~wwWdn1srwY||ks%Wdn1swYWddSWddS1swYdS)Nfile was already closedr)r%r$rrClosedResourceErrorr checkpointlen memoryviewr writerBlockingIOError wait_writableOSErrorerrnoEBADFBrokenResourceError)rr'lengthviewsent remainingerrrsend_allvs@    "zFdStream.send_allreturnNc s||j0|jjrtdz tj|jjIdHWnty+}ztj |d}~wwWddS1s7wYdS)Nr() r%r$rrr)rr/rBrokenPipeErrorr3)rr8rrrwait_send_all_might_not_blocks "z&FdStream.wait_send_all_might_not_blockc s|jg|dur t}nt|tstd|dkrtdtjIdH z t |j j |}Wn/t yDtj|j j IdHYnty_}z|jtjkrWtddtj|d}~wwnq&|WdS1snwYdS)Nzmax_bytes must be integer >= 1rTr()r&DEFAULT_RECEIVE_SIZEr r r ValueErrorrrr*r readr$rr.Z wait_readabler0r1r2r)r3)rZ max_bytesr'r8rrr receive_somes8   $zFdStream.receive_somecCs|jdSr)r$rrrrrrszFdStream.closecs|tjIdHdSr)rrrr*rrrracloseszFdStream.aclosecCs|jjSr)r$rrrrrfilenoszFdStream.fileno)r:Nr) rr r!__doc__r rbytesr9r<r@rrArBrrrrr#Ls    r#) metaclass) r r1_abcrZ_utilrrrname ImportErrorr=rr#rrrrs  9