U
|
Z ±dÊ ã @ sl d dl Z d dlZddlmZ ddlmZmZ d dlZe jdkrBe dZ
|
G dd dZ G d d
|
d
|
eed Z dS ) é Né )ÚStream)ÚConflictDetectorÚFinalÚposixi c @ s> e Zd ZedddZedd Zdd Zdd Zd
|
d Z d S ) Ú _FdHolder©Úfdc C s: d| _ t|tstd|| _ t |¡| _t |d¡ d S )Néÿÿÿÿz file descriptor must be an intF)r Ú
|
isinstanceÚintÚ TypeErrorÚosZ get_blockingÚ_original_is_blockingÚ set_blocking©Úselfr © r úGd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_unix_pipes.pyÚ__init__% s
|
z_FdHolder.__init__c C s
|
| j dkS ©Nr
|
r ©r r r r Úclosed0 s z_FdHolder.closedc C s2 | j r
|
d S | j}d| _t || j¡ t |¡ d S r )r r r r r Úcloser r r r Ú
|
_raw_close4 s z_FdHolder._raw_closec C s | ¡ d S ©N)r r r r r Ú__del__C s z_FdHolder.__del__c C s | j s tj | j¡ | ¡ d S r )r ÚtrioÚlowlevelZnotify_closingr r r r r r r F s z_FdHolder.closeN)
|
Ú__name__Ú
|
__module__Ú __qualname__r r Úpropertyr r r r r r r r r s
|
r c @ sb e Zd ZdZedddZedddZdd d
|
d Zded d d Z dd Z
|
dd Z dd Z 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
|
<https://github.com/python-trio/trio/issues/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.
|
r c C s" t || _td| _td| _d S )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_detectorr r r r r m s
|
ÿÿzFdStream.__init__)Údatac à s | j ð | jjrt d¡tj ¡ I d H t|}t|²}d}||k rè||d
}z|t
|
| jj |¡7 }W nl t k
|
r tj | jj ¡I d H Y nD tk
|
rÚ } z&|jtjkrÂt d¡d ntj|W 5 d }~X Y nX W 5 Q R X q@W 5 Q R X W 5 Q R X d S )Núfile was already closedr )r% r$ r r ÚClosedResourceErrorr Ú
|
checkpointÚlenÚ
|
memoryviewr Úwriter ÚBlockingIOErrorÚ wait_writableÚOSErrorÚerrnoÚEBADFÚBrokenResourceError)r r' ÚlengthÚviewÚsentÚ remainingÚer r r Úsend_allv s*
|
|
ÿþzFdStream.send_allN)Úreturnc à sn | j ^ | jjrt d¡ztj | jj¡I d H W n* tk
|
r^ } z tj |W 5 d }~X Y nX W 5 Q R X d S )Nr( )
|
r% r$ r r r) r r/ r ÚBrokenPipeErrorr3 )r r8 r r r Ú wait_send_all_might_not_block s
|
z&FdStream.wait_send_all_might_not_blockc à sè | j Ø |d krt}n"t|ts(td|dk r8tdtj ¡ I d H zt
|
| j j |¡}W qÎ t k
|
r tj | j j ¡I d H Y qH tk
|
rÈ } z&|jtjkr°t d¡d ntj|W 5 d }~X Y qHX qÎqH|W 5 Q R £ S Q R X d S )Nz max_bytes must be integer >= 1r r( )r& ÚDEFAULT_RECEIVE_SIZEr r r Ú
|
ValueErrorr r r* r Úreadr$ r r. Z wait_readabler0 r1 r2 r) r3 )r Z max_bytesr' r8 r r r Ú receive_some s,
|
ÿþzFdStream.receive_somec C s | j ¡ d S r )r$ r r r r r r ¶ s zFdStream.closec à s | ¡ tj ¡ I d H d S r )r r r r* r r r r Úaclose¹ s zFdStream.aclosec C s | j jS r )r$ r r r r r Úfileno½ s zFdStream.fileno)N) r r r! Ú__doc__r r Úbytesr9 r< r@ r rA rB r r r r r# L s r# )Ú metaclass) r r1 Ú_abcr Z_utilr r r ÚnameÚ ImportErrorr= r r# r r r r Ú<module> s
|
9
|
