File: //lib/python3.9/site-packages/rhn/__pycache__/nonblocking.cpython-39.pyc
a
U��Z{ � @ s� d dl Z d dlZd dlZG dd� d�Zdd� Zedkr�d dlZe�ejej�Z e �
d� e � � Z ee �Z
e�ejej�Ze�
d� e� � Z e
�e gg g de� e
�� Zeee�� dS ) � Nc @ s6 e Zd Zdd� Zdd� Zd
dd�Zdd � Zd
d � Zd S )�NonBlockingFilec C s@ || _ t�| j �� tjtj� g | _g | _g | _d | _ d | _
d S �N) �fd�fcntl�fileno�F_SETFL�os�O_NDELAY� read_fd_set� write_fd_set�
exc_fd_set� user_data�callback)�selfr � r �3/usr/lib/python3.9/site-packages/rhn/nonblocking.py�__init__
s zNonBlockingFile.__init__c C sD || _ | j D ]}t�|�� tjtj� q || _|| _|| _|| _ d S r )
r
r r r r r r r r
r )r r
r r r
r �fr r r � set_callback s
z NonBlockingFile.set_callbackr c C s� d}| j | jg }| j}| j}td|� t�|||�\}}}td|||� | j|v rdd}|�| j� | jr�|sv|sv|r�| �|||| j� |r q�q td� | j� |�S )Nr zCalling selectzSelect returned� Z Returning)
r
r r r �print�select�remover r
�read)r ZamtZstatus_changedZreadfdsZwritefdsZexcfdsr r r r ! s
zNonBlockingFile.readc C s | j �|�S r )r �write)r �datar r r r 7 s zNonBlockingFile.writec C s t | j|�S r )�getattrr )r �namer r r � __getattr__: s zNonBlockingFile.__getattr__N)r )�__name__�
__module__� __qualname__r r r r r r r r r r s
r c C s" t d| ||� t | d �� � d S )NzCallback calledr )r r )�r�w�er
r r r r = s r �__main__)� localhosti� )r& i� )r r r r r r ZsocketZAF_INETZ SOCK_STREAM�sZconnectZmakefiler �ss�s2r r �xxr �lenr r r r �<module> s 4