File: //proc/self/root/lib/python3.6/site-packages/supervisor/__pycache__/socket_manager.cpython-36.pyc
3
�k�` � @ s6 d dl Z G dd� d�ZG dd� d�ZG dd� d�ZdS )� Nc @ s0 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 || _ |jdd �| _d S )N� on_delete)�object�getr )�selfr �kwargs� r �$/usr/lib/python3.6/socket_manager.py�__init__ s zProxy.__init__c C s | j r| j � d S )N)r )r r r r �__del__ s z
Proxy.__del__c C s t | j|�S )N)�getattrr )r �namer r r � __getattr__ s zProxy.__getattr__c C s | j S )N)r )r r r r �_get s z
Proxy._getN)�__name__�
__module__� __qualname__�__doc__r
r r r r r r r r s
r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �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 s | j S )N)r )r r r r � get_count s zReferenceCounter.get_countc C s$ | j dkr| j� | j d7 _ d S )Nr � )r r )r r r r � increment" s
zReferenceCounter.incrementc C s6 | j dkrtd��| j d8 _ | j dkr2| j� 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 |j 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! Zurl)r r r r �__repr__> s zSocketManager.__repr__c C s | j S )N)r! )r r r r �configC s zSocketManager.configc C s | j S )N)r )r r r r � is_preparedF s zSocketManager.is_preparedc C s$ | j j� | j� t| j| j jd�S )N)r )r$ r �_require_preparedr r r )r r r r �
get_socketI s
zSocketManager.get_socketc C s | j � | jj� S )N)r* 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 r* R s z SocketManager._require_preparedc C s` | j s\| jr | jjd| j � | jj� | _| jj� rH| jj| jj� � n| jjtj� d| _ d S )NzCreating socket %sT) r r �infor! Zcreate_and_bindr Z get_backlogZlistenZ SOMAXCONN)r r r r r# V s
z SocketManager._prepare_socketc C s4 | j � | jr | jjd| j � | jj� d| _d S )NzClosing socket %sF)r* r r- r! r �closer )r r r r r" a s
zSocketManager._closeN)
r r r r r
r' r( r) r+ r, r* r# r" r r r r r . s r )r r r r r r r r �<module> s