Current Dir: /snap/core22/2955/usr/lib/python3/dist-packages/requests_unixsocket/__pycache__/
[FILE] adapters.cpython-310.pyc [ edit | delete | rename ]
[FILE] testutils.cpython-310.pyc [ edit | delete | rename ]
[FILE] __init__.cpython-310.pyc [ edit | delete | rename ]
Viewing: /snap/core22/2955/usr/lib/python3/dist-packages/requests_unixsocket/__pycache__/adapters.cpython-310.pyc
o
��V]�
� @ s� d dl Z d dlmZ d dlmZmZ zd dlmZ W n
e y' d dlZY nw zd dl
m Z W n
e y= d dl Z Y nw G dd� dej e
�ZG dd� de jj�ZG d d
� d
e�ZdS ) � N)� HTTPAdapter)�urlparse�unquote)�urllib3c s. e Zd Zd� fdd� Zdd� Zdd� Z� ZS ) �UnixHTTPConnection�< c s* t t| �jd|d� || _|| _d| _dS )a Create an HTTP connection to a unix domain socket
:param unix_socket_url: A URL with a scheme of 'http+unix' and the
netloc is a percent-encoded path to a unix domain socket. E.g.:
'http+unix://%2Ftmp%2Fprofilesvc.sock/status/pid'
� localhost��timeoutN)�superr �__init__�unix_socket_urlr
�sock)�selfr
r
�� __class__� �>/usr/lib/python3/dist-packages/requests_unixsocket/adapters.pyr s
zUnixHTTPConnection.__init__c C s | j r
| j �� d S d S �N)r �close�r r r r �__del__! s �zUnixHTTPConnection.__del__c C s@ t � t jt j�}|�| j� tt| j�j�}|� |� || _
d S r ) �socket�AF_UNIX� SOCK_STREAM�
settimeoutr
r r r
�netloc�connectr )r r � socket_pathr r r r % s
zUnixHTTPConnection.connect�r )�__name__�
__module__� __qualname__r r r �
__classcell__r r r r r s r c s& e Zd Zd� fdd� Zdd� Z� ZS )�UnixHTTPConnectionPoolr c s$ t t| �jd|d� || _|| _d S )Nr r )r r$ r r r
)r r r
r r r r / s
�
z UnixHTTPConnectionPool.__init__c C s t | j| j�S r )r r r
r r r r � _new_conn5 � z UnixHTTPConnectionPool._new_connr )r r! r" r r% r# r r r r r$ - s r$ c s8 e Zd Zd � fdd� Zd
dd�Zdd � Zd
d � Z� ZS )� UnixAdapterr � c s6 t t| �j|i |�� || _tjj|dd� d�| _d S )Nc S s | � � S r )r )�pr r r �<lambda>? s z&UnixAdapter.__init__.<locals>.<lambda>)� dispose_func)r r' r r
r � _collections�RecentlyUsedContainer�pools)r r
�pool_connections�args�kwargsr r r r ; s
�zUnixAdapter.__init__Nc C s� |pi }|� t|�� �j�}|rtd| jj ��| jj�% | j� |�}|r.|W d � S t || j
�}|| j|< W d � |S 1 sDw Y |S )Nz&%s does not support specifying proxies) �getr �lower�scheme�
ValueErrorr r r. �lockr$ r
)r �url�proxies�proxy�poolr r r �get_connectionB s" �
�
��zUnixAdapter.get_connectionc C s |j S r )�path_url)r �requestr8 r r r � request_urlT s zUnixAdapter.request_urlc C s | j �� d S r )r. �clearr r r r r W r& zUnixAdapter.close)r r( r )r r! r" r r; r> r r# r r r r r' 9 s
r' )r �requests.adaptersr �requests.compatr r � http.client�client�httplib� ImportError�requests.packagesr �HTTPConnection�objectr �connectionpool�HTTPConnectionPoolr$ r' r r r r �<module> s � �