File: //lib/python3/dist-packages/supervisor/__pycache__/socket_manager.cpython-310.pyc
o
�a,_ � @ s6 d dl Z G dd� d�ZG dd� d�ZG dd� d�ZdS )� Nc @ �0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �Proxyz` Class for wrapping a shared resource object and getting
notified when it's deleted
c K s || _ |�dd �| _d S )N� on_delete)�object�getr )�selfr �kwargs� r �;/usr/lib/python3/dist-packages/supervisor/socket_manager.py�__init__ s zProxy.__init__c C s | j r | � � d S d S �N�r �r r r r
�__del__ s �z
Proxy.__del__c C s t | j|�S r )�getattrr )r �namer r r
� __getattr__ s zProxy.__getattr__c C � | j S r )r r r r r
�_get � z
Proxy._getN)�__name__�
__module__� __qualname__�__doc__r r r r r r r r
r s r c @ r ) �ReferenceCounterz8 Class for tracking references to a shared resource
c K s |d | _ |d | _d| _d S )N� on_non_zero�on_zeror )r r � ref_count)r r r r r
r s
zReferenceCounter.__init__c C r r )r r r r r
� get_count r zReferenceCounter.get_countc C s$ | j dkr | �� | j d7 _ d S )Nr � )r r r r r r
� increment" �
zReferenceCounter.incrementc C s: | j dkr td��| j d8 _ | j dkr| �� d S d S )Nr z.Illegal operation: cannot decrement below zeror )r � Exceptionr r r r r
� decrement' s
�zReferenceCounter.decrementN)r r r r r r r r# r r r r
r s r c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )�
SocketManagera Class for managing sockets in servers that create/bind/listen
before forking multiple child processes to accept()
Sockets are managed at the process group level and referenced counted
at the process level b/c that's really the only place to hook in
c K s6 |� dd �| _d | _d| _|| _t| j| jd�| _d S )N�loggerF)r r ) r r% �socket�prepared�
socket_configr �_close�_prepare_socket�ref_ctr)r r( r r r r
r 5 s �zSocketManager.__init__c C s d| j t| �| jjf S )Nz<%s at %s for %s>)� __class__�idr( �urlr r r r
�__repr__> s �zSocketManager.__repr__c C r r )r( r r r r
�configC r zSocketManager.configc C r r )r' r r r r
� is_preparedF r zSocketManager.is_preparedc C s$ | j �� | �� t| j| j jd�S )Nr
)r+ r �_require_preparedr r& r# r r r r
�
get_socketI r! zSocketManager.get_socketc C s | � � | j�� S r )r2 r+ r r r r r
�get_socket_ref_countN s
z"SocketManager.get_socket_ref_countc C s | j std��d S )Nz Socket has not been prepared)r' r" r r r r
r2 R s �z SocketManager._require_preparedc C sd | j s0| jr| j�d| j � | j�� | _| j�� r$| j�| j�� � n| j�tj� d| _ d S d S )NzCreating socket %sT) r' r% �infor( �create_and_bindr& � get_backlog�listen� SOMAXCONNr r r r
r* V s
�z SocketManager._prepare_socketc C s4 | � � | jr| j�d| j � | j�� d| _d S )NzClosing socket %sF)r2 r% r5 r( r& �closer' r r r r
r) a s
zSocketManager._closeN)
r r r r r r/ r0 r1 r3 r4 r2 r* r) r r r r
r$ . s r$ )r& r r r$ r r r r
�<module> s