Edit File: nonblocking.cpython-36.pyc
3 U��Z{ � @ s� d dl Z d dlZd dlZG dd� d�Zdd� Zedkr�d dlZejejej�Z e j d � e j � Z ee �Z ejejej�Zej d � ej � Z e je gg g de� e j� Zeee�� dS ) � Nc @ s6 e Zd Zdd� Zdd� Zd dd�Zdd � Zd d � Zd S )�NonBlockingFilec C s@ || _ tj| j 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 �!/usr/lib/python3.6/nonblocking.py�__init__ s zNonBlockingFile.__init__c C sH || _ x$| j D ]}tj|j� tjtj� qW || _|| _|| _|| _ d S )N) 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� x�d}| j | jg }| j}| j}td|� tj|||�\}}}td|||� | j|krfd}|j| j� | jr�|sx|sx|r�| j|||| j� |rP qW td� | jj |�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 j|�S )N)r �write)r �datar r r r 7 s zNonBlockingFile.writec C s t | j|�S )N)�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 j� � d S )NzCallback calledr )r r )�r�w�er r r r r = s r �__main__� localhost� � )r% r& )r% r' )r r r r r r ZsocketZAF_INETZ SOCK_STREAM�sZconnect�makefiler Zss�s2r r Zxxr �lenr r r r �<module> s 4