Edit File: 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
Back to File Manager