Edit file File name : windows_utils.cpython-36.opt-2.pyc Content :3 \� � @ s� d dl Z e jdkred��d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z dddddgZ d Z ej Z ejZej� Zeed�r�ejZnejejd fd d�Zd de d �dd�ZG dd� d�ZG dd� dej�ZdS )� NZwin32z win32 only� socketpair�pipe�Popen�PIPE� PipeHandlei c C s | t jkrd}n| t jkr d}ntd��|t jkr:td��|dkrJtd��t j | ||�}z�|j|df� |jd� |j� d d� \}}t j | ||�}yP|jd � y|j ||f� W n t t fk r� Y nX |jd � |j � \}} W n |j � � Y nX W d |j � X ||fS ) Nz 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� � FT)�socket�AF_INETZAF_INET6� ValueError� SOCK_STREAMZbindZlistenZ getsocknameZ setblockingZconnect�BlockingIOError�InterruptedErrorZaccept�close) Zfamily�type�proto�hostZlsockZaddrZportZcsockZssock�_� r �-/usr/lib64/python3.6/asyncio/windows_utils.pyr % s8 FT)�duplex� overlapped�bufsizec C s" t jdtj� tt�f d�}| r>tj}tjtj B }|| }}ntj }tj }d| }}|tj O }|d rp|tj O }|d r�tj }nd}d } } yZtj ||tjd||tjtj�} tj||dtjtj|tj�} tj| dd�} | jd� | | fS | d k �rtj| � | d k �rtj| � � Y nX d S )Nz\\.\pipe\python-pipe-%d-%d-)�prefixr r T)r )�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 @ sX e Zd Zdd� Zdd� Zedd� �Zdd� Zej d �d d �Z d d � Z dd� Z dd� Z dS )r c C s || _ d S )N)�_handle)�self�handler r r �__init__� s zPipeHandle.__init__c C s* | j d k rd| j }nd}d| jj|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 krtd��| j S )Nz I/O operatioon on closed pipe)r" r )r# r r r �fileno� s zPipeHandle.fileno)r c C s | j d k r|| j � d | _ d S )N)r" )r# r r r r r � s zPipeHandle.closec C s* | j d k r&tjd| t| d� | j� d S )Nz unclosed %r)�source)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__r% r) �propertyr$ r* r r r r/ r0 r4 r r r r r � s c s e Zd Zd� fdd� Z� ZS )r Nc s| d } }}d } } } |t kr@tddd�\} } tj| tj�}n|}|t krhtdd�\} } tj| d�}n|}|t kr�td d�\} }tj|d�}n|tkr�|}n|}z�y t� j|f|||d�|�� W n4 x$| | | fD ]}|d k r�t j |� q�W � Y n>X | d k �rt | �| _ | d k �r"t | �| _ | d k �r6t | �| _W d |t k�rNtj|� |t k�rbtj|� |t k�rvtj|� X d S ) NFT)r r )r r )�stdin�stdout�stderr)FT)TF)TF)r r �msvcrtZopen_osfhandler �O_RDONLY�STDOUT�superr% r r r r8 r9 r: r )r# �argsr8 r9 r: �kwdsZ stdin_rfdZ stdout_wfdZ stderr_wfdZstdin_whZ stdout_rhZ stderr_rhZstdin_rhZ stdout_whZ stderr_wh�h)r' r r r% � sH zPopen.__init__)NNN)r( r5 r6 r% � __classcell__r r )r' r r � s )TT)�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-Save