File: //usr/lib/python3/dist-packages/docker/transport/__pycache__/npipesocket.cpython-310.pyc
o
�2.a[ � @ sd d dl Z d dlZd dlZd dlZd dlZdZdZd ZdZdd� Z G dd� d�Z
G d d
� d
ej �Z dS ) � N�� i �
c s t �� �� fdd��}|S )Nc s$ | j rtd��� | g|�R i |��S )Nz1Can not reuse socket after connection was closed.)�_closed� RuntimeError)�self�args�kwargs��f� �>/usr/lib/python3/dist-packages/docker/transport/npipesocket.py�wrapped s
�z check_closed.<locals>.wrapped)� functools�wraps)r
r
r r r � check_closed s r c @ s, e Zd ZdZd:dd�Zdd� Zdd� Zd d
� Zed;d d
��Z edd� �Z
edd� �Z edd� �Z dd� Z
dd� Zd:dd�Zdd� Zd d � Zd<d d �Zed;d d!��Zed;d"d#��Zed=d$d%��Zed;d&d'��Zd(d)� Zed;d*d+��Zed;d,d-��Zed.d/� �Zd0d1� Zd2d3� Z d4d5� Z d6d7� Z ed8d9� �Z dS )>� NpipeSocketz� Partial implementation of the socket API over windows named pipes.
This implementation is only designed to be used as a client socket,
and server-specific methods (bind, listen, accept...) are not
implemented.
Nc C s t j| _|| _d| _d S �NF)� win32pipe�NMPWAIT_USE_DEFAULT_WAIT�_timeout�_handler )r �handler r r �__init__! s
zNpipeSocket.__init__c C � t � ��N��NotImplementedError�r r r r �accept& � zNpipeSocket.acceptc C r r r �r �addressr r r �bind) r zNpipeSocket.bindc C s | j �� d| _d S �NT)r �Closer r r r r �close, �
zNpipeSocket.closer c
C s� zt �|t jt jB dd t jttB d�}W n- tjyA } z |j t
kr;|d }|t k r;t �
d� | �||�W Y d }~S |�d }~ww t�|�d | _|| _|| _d S )Nr � )� win32file�
CreateFile� GENERIC_READ�
GENERIC_WRITE�
OPEN_EXISTING�cSECURITY_ANONYMOUS�cSECURITY_SQOS_PRESENTr �error�winerror�cERROR_PIPE_BUSY�MAXIMUM_RETRY_COUNT�time�sleep�connect�GetNamedPipeInfo�flagsr �_address)r r! � retry_countr �er r r r5 0 s,
�
��
zNpipeSocket.connectc C s
| � |�S r )r5 r r r r �
connect_exN �
zNpipeSocket.connect_exc C s d| _ | jS r# )r r r r r r �detachR s zNpipeSocket.detachc C s
t | j�S r )r r r r r r �dupW r< zNpipeSocket.dupc C � | j S r �r8 r r r r � getpeername[ r zNpipeSocket.getpeernamec C r? r r@ r r r r � getsockname^ r zNpipeSocket.getsocknamec C r r r )r �level�optname�buflenr r r �
getsockopta r zNpipeSocket.getsockoptc C r r r )r �control�optionr r r �ioctld r zNpipeSocket.ioctlc C r r r )r �backlogr r r �listeng r zNpipeSocket.listenc C s@ |� d�dkr
t� �t| �}|d u s|dkrtj}tj||d�S )N�b�rr )� buffer_size)�stripr �NpipeFileIOBase�io�DEFAULT_BUFFER_SIZE�BufferedReader)r �mode�bufsize�rawior r r �makefilej s zNpipeSocket.makefilec C � t �| j|�\}}|S r )r( �ReadFiler )r rU r7 �err�datar r r �recvr � zNpipeSocket.recvc C s | � ||�}|| jfS r )r\ r8 )r rU r7 r[ r r r �recvfromw s
zNpipeSocket.recvfromc C s | � |||�| jfS r )� recv_intor8 )r �buf�nbytesr7 r r r �
recvfrom_into| s zNpipeSocket.recvfrom_intoc C s@ |}t |t�s t|�}t�| j|r|d |� n|�\}}t|�S r )�
isinstance�
memoryviewr( rY r �len)r r` ra �readbufrZ r[ r r r r_ � s
�zNpipeSocket.recv_intoc C s2 t �| j|p t|��\}}t|�}||d |�< |S r )r( rY r re )r r` ra rZ r[ �nr r r �_recv_into_py2� s zNpipeSocket._recv_into_py2c C rX r )r( � WriteFiler )r �stringr7 rZ ra r r r �send� r] zNpipeSocket.sendc C s | � ||�S r )rk )r rj r7 r r r �sendall� s zNpipeSocket.sendallc C s | � |� | �|�S r )r5 rk )r rj r! r r r �sendto� s
zNpipeSocket.sendtoc C s |r| � d �S | � d�S )Nr )�
settimeout)r �flagr r r � setblocking� s
zNpipeSocket.setblockingc C sT |d u r
t j| _d S t|ttf�r|dk rtd��|dkr#t j| _d S |d | _d S )Nr zTimeout value out of rangei� )r �NMPWAIT_WAIT_FOREVERr rc �float�int�
ValueError�NMPWAIT_NO_WAIT)r �valuer r r rn � s zNpipeSocket.settimeoutc C r? r )r r r r r �
gettimeout� r zNpipeSocket.gettimeoutc C r r r )r rC rD rv r r r �
setsockopt� r zNpipeSocket.setsockoptc C s | � � S r )r% )r �howr r r �shutdown� s zNpipeSocket.shutdownr )r )NN)r r ) �__name__�
__module__� __qualname__�__doc__r r r" r% r r5 r; r= r> rA rB rF rI rK rW r\ r^ rb r_ rh rk rl rm rp rn rw rx rz r r r r r sR
r c sT e Zd Zdd� Z� fdd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
� Z S )rP c C s
|| _ d S r )�sock)r � npipe_socketr r r r � �
zNpipeFileIOBase.__init__c s t � �� d | _d S r )�superr% r r �� __class__r r r% � r& zNpipeFileIOBase.closec C s
| j �� S r )r �filenor r r r r� � r� zNpipeFileIOBase.filenoc C � dS r r r r r r �isatty� � zNpipeFileIOBase.isattyc C r� r# r r r r r �readable� r� zNpipeFileIOBase.readablec C s | j �|�S r )r r_ )r r` r r r �readinto� s zNpipeFileIOBase.readintoc C r� r r r r r r �seekable� r� zNpipeFileIOBase.seekablec C r� r r r r r r �writable� r� zNpipeFileIOBase.writable) r{ r| r} r r% r� r� r� r� r� r� �
__classcell__r r r� r rP � s rP )
r r3 rQ r( r r1 r. r- r2 r r � RawIOBaserP r r r r �<module> s $