��Yf� � @ sJ d Z d d l Z e j d k r- e d � � d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d d d d g Z d
Z
e j Z e j Z e j � Z e e d � r� e j Z n e j e j d d d � Z d d
d d d e
d d � Z Gd d � d � Z Gd d � d e j � Z d S)z*
Various Windows specific bits and pieces
� N�win32z
win32 only�
socketpair�pipe�Popen�PIPE�
PipeHandlei c
C sk | t j k r d } n$ | t j k r0 d } n t d � � | t j k rW t d � � | d k ro t d � � t j | | | � } z� | j | d f � | j d � | j � d d � \ } } t j | | | � } yb | j d
� y | j | | f � Wn t
t f k
rYn X| j d � | j � \ } } Wn | j
� � Yn XWd | j
� X| | f S) z�A socket pair usable as a self-pipe, for Windows.
Origin: https://gist.github.com/4325783, by Geert Jansen.
Public domain.
z 127.0.0.1z::1z?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedr z Only protocol zero is supported� N� FT)�socket�AF_INETZAF_INET6�
ValueError� SOCK_STREAMZbindZlistenZ getsocknameZ setblockingZconnect�BlockingIOError�InterruptedErrorZaccept�close)
Zfamily�type�proto�hostZlsockZaddrZportZcsockZssock�_� r �:/opt/alt/python35/lib64/python3.5/asyncio/windows_utils.pyr % s8
�duplexF�
overlappedT�bufsizec C s� t j d d t j � t t � f � } | rW t j } t j t j B} | | } } n t j
} t j } d | } } | t j O} | d r� | t j O} | d r� t j } n d } d } }
y� t j
| | t j d | | t j t j � } t j | | d t j t j | t j � }
t j | d d �} | j d � | |
f SWn= | d k rft j | � |
d k rt j |
� � Yn Xd S)zELike os.pipe() but with overlapped support and using handles not fds.�prefixz\\.\pipe\python-pipe-%d-%d-r r Nr T)�tempfileZmktemp�os�getpid�next�
_mmap_counter�_winapiZPIPE_ACCESS_DUPLEXZ GENERIC_READZ
GENERIC_WRITEZPIPE_ACCESS_INBOUNDZ FILE_FLAG_FIRST_PIPE_INSTANCEZFILE_FLAG_OVERLAPPEDZCreateNamedPipeZ PIPE_WAITZNMPWAIT_WAIT_FOREVERZNULLZ
CreateFileZ
OPEN_EXISTINGZConnectNamedPipeZGetOverlappedResult� CloseHandle) r r r ZaddressZopenmode�accessZobsizeZibsizeZflags_and_attribsZh1Zh2Zovr r r r S s@
c @ s� e Z d Z d Z d d � Z d d � Z e d d � � Z d d � Z d
e j
d d � Z d
d � Z d d � Z
d d � Z d S)r z�Wrapper for an overlapped pipe handle which is vaguely file-object like.
The IOCP event loop can use these instead of socket objects.
c C s
| | _ d S)N)�_handle)�self�handler r r �__init__� s zPipeHandle.__init__c C s9 | j d k r d | j } n d } d | j j | f S)Nz handle=%r�closedz<%s %s>)r# � __class__�__name__)r$ r% r r r �__repr__� s zPipeHandle.__repr__c C s | j S)N)r# )r$ r r r r% � s zPipeHandle.handlec C s" | j d k r t d � � | j S)Nz I/O operatioon on closed pipe)r# r )r$ r r r �fileno� s zPipeHandle.filenor! c C s) | j d k r% | | j � d | _ d S)N)r# )r$ r! r r r r � s
zPipeHandle.closec C s1 | j d k r- t j d | t � | j � d S)Nz unclosed %r)r# �warnings�warn�ResourceWarningr )r$ r r r �__del__� s zPipeHandle.__del__c C s | S)Nr )r$ r r r � __enter__� s zPipeHandle.__enter__c C s | j � d S)N)r )r$ �t�v�tbr r r �__exit__� s zPipeHandle.__exit__N)r) �
__module__� __qualname__�__doc__r& r* �propertyr% r+ r r! r r/ r0 r4 r r r r r � s c s1 e Z d Z d Z d d d � f d d � Z � S)r z�Replacement for subprocess.Popen using overlapped pipe handles.
The stdin, stdout, stderr are None or instances of PipeHandle.
Nc s4 | j d � s t � | j d d � d k s4 t � d } } } d } }
} | t k r� t d d d d � \ } } t j | t j � } n | } | t k r� t d d � \ }
}
t j |
d � } n | } | t k rt d d
� \ } } t j | d � } n | t k r | } n | } z� y) t � j
| d | d | d
| | �Wn> x0 | |
| f D] } | d k rdt j | � qdW� YnR X| d k r�t
| � | _ |
d k r�t
|
� | _ | d k r�t
| � | _ Wd | t k r�t j | � | t k rt j | � | t k r/t j | � Xd S)NZuniversal_newlinesr r r FTr �stdin�stdout�stderr)FT)TF)TF)�get�AssertionErrorr r �msvcrtZopen_osfhandler �O_RDONLY�STDOUT�superr& r r! r r9 r: r; r )r$ �argsr9 r: r; �kwdsZ stdin_rfdZ
stdout_wfdZ
stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_wh�h)r( r r r& � sL
zPopen.__init__)r) r5 r6 r7 r& r r )r( r r � s )TT)r7 �sys�platform� ImportErrorr � itertoolsr> r r
�
subprocessr r, �__all__ZBUFSIZEr r@ �countr �hasattrr r r
r r r r r r r �<module> s, . 0,