U
|
Z ±d
ã @ s¨ d dl Z d dlmZ ddlmZ ddlmZmZ ddlm Z m
|
Z
|
ddl m Z m Z mZmZ e jdksjerjtd ZG d
|
d d ZG d d d ee
|
dZG dd dee
|
dZdS )é N)Ú TYPE_CHECKINGé )Ú_core)Ú
|
SendStreamÚ ReceiveStream)ÚConflictDetectorÚFinal)Ú_handleÚraise_winerrorÚkernel32ÚffiÚwin32i c @ s8 e Zd ZeddddZedd Zdd Zd d
|
ZdS ) Ú _HandleHolderN©ÚhandleÚreturnc C s. d| _ t|tstd|| _ t | j ¡ d S )Néÿÿÿÿzhandle must be an int)r Ú
|
isinstanceÚintÚ TypeErrorr Zregister_with_iocp©Úselfr © r úJd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_windows_pipes.pyÚ__init__ s
|
|
z_HandleHolder.__init__c C s
|
| j dkS ©Nr )r ©r r r r Úclosed s z_HandleHolder.closedc C s. | j r
|
d S | j}d| _t t|¡s*t d S r )r r r Ú CloseHandler r
|
r r r r Úclose s z_HandleHolder.closec C s | ¡ d S ©N)r r r r r Ú__del__$ s z_HandleHolder.__del__) Ú__name__Ú
|
__module__Ú __qualname__r r Úpropertyr r r! r r r r r s
|
|
r c @ sL e Zd ZdZeddddZedddZdd d
|
d Zd d Z dd Z
|
dS )ÚPipeSendStreamzdRepresents a send stream over a Windows named pipe that has been
|
opened in OVERLAPPED mode.
|
Nr c C s t || _td| _d S ©Nz)another task is currently using this pipe©r Ú_handle_holderr Ú_conflict_detectorr r r r r - s
|
ÿzPipeSendStream.__init__)Údatac à s | j | jjrt d¡|s:t ¡ I d H W 5 Q R £ d S zt | jj|¡I d H }W n* tk
|
r~ } z tj |W 5 d }~X Y nX |t
|
|kst W 5 Q R X d S )Núthis pipe is already closed) r* r) r r ÚClosedResourceErrorÚ
|
checkpointZwrite_overlappedr ÚBrokenPipeErrorZBrokenResourceErrorÚlenÚAssertionError)r r+ ZwrittenÚexr r r Úsend_all3 s
|
zPipeSendStream.send_all©r c à s6 | j & | jjrt d¡t ¡ I d H W 5 Q R X d S )NzThis pipe is already closed)r* r) r r r- r. r r r r Ú wait_send_all_might_not_blockE s
|
z,PipeSendStream.wait_send_all_might_not_blockc C s | j ¡ d S r ©r) r r r r r r M s zPipeSendStream.closec à s | ¡ t ¡ I d H d S r ©r r r. r r r r ÚacloseP s zPipeSendStream.aclose) r" r# r$ Ú__doc__r r Úbytesr3 r5 r r8 r r r r r& ( s r& )Ú metaclassc @ s@ e Zd ZdZeddddZd edddZd d
|
Zd d Z dS )ÚPipeReceiveStreamz3Represents a receive stream over an os.pipe object.Nr c C s t || _td| _d S r' r( r r r r r X s
|
ÿzPipeReceiveStream.__init__r4 c
|
à sØ | j È | jjrt d¡|d kr(t}n"t|ts:td|dk rJt dt
|
|}zt | jj |¡I d H }W nB t k
|
r® | jjrt d¡d t ¡ I d H Y W 5 Q R £ dS X ||d
= |W 5 Q R £ S W 5 Q R X d S )Nr, z max_bytes must be integer >= 1r z another task closed this pipeó )r* r) r r r- ÚDEFAULT_RECEIVE_SIZEr r r Ú
|
ValueErrorÚ bytearrayZreadinto_overlappedr r/ r. )r Z max_bytesÚbufferÚsizer r r Ú receive_some^ s4
|
|
ÿÿþ
|
z PipeReceiveStream.receive_somec C s | j ¡ d S r r6 r r r r r
s zPipeReceiveStream.closec à s | ¡ t ¡ I d H d S r r7 r r r r r8 s zPipeReceiveStream.aclose)N)
|
r" r# r$ r9 r r r: rC r r8 r r r r r< U s
|
'r< )ÚsysÚtypingr Ú r Ú_abcr r Z_utilr r Z_core._windows_cffir r
|
r r Úplatformr1 r> r r& r< r r r r Ú<module> s -
|
