← Back
Editing: connection.cpython-35.pyc
��Yf/ � @ ss d d d g Z d d l m Z d g Z Gd d � d e � Z d d � Z d d d � Z Gd d � d e � Z d S) �Client�Listener�Pipe� )�QueueNc @ sg e Z d Z d d d d d � Z d d � Z d d � Z e d d � � Z d d � Z d d � Z d S)r N� c C s t | � | _ d S)N)r �_backlog_queue)�self�addressZfamilyZbacklog� r �E/opt/alt/python35/lib64/python3.5/multiprocessing/dummy/connection.py�__init__ s zListener.__init__c C s t | j j � � S)N)� Connectionr �get)r r r r �accept s zListener.acceptc C s d | _ d S)N)r )r r r r �close s zListener.closec C s | j S)N)r )r r r r �<lambda> s zListener.<lambda>c C s | S)Nr )r r r r � __enter__ s zListener.__enter__c C s | j � d S)N)r )r �exc_type� exc_value�exc_tbr r r �__exit__" s zListener.__exit__) �__name__� __module__� __qualname__r r r �propertyr r r r r r r r s c C s3 t � t � } } | j | | f � t | | � S)N)r �putr )r �_in�_outr r r r & s Tc C s/ t � t � } } t | | � t | | � f S)N)r r )Zduplex�a�br r r r , s c @ sO e Z d Z d d � Z d d d � Z d d � Z d d � Z d d � Z d S) r c C s< | | _ | | _ | j | _ | _ | j | _ | _ d S)N)r r r �sendZ send_bytesr ZrecvZ recv_bytes)r r r r r r r 3 s zConnection.__init__g c C sc | j j � d k r d S| d k r) d S| j j � | j j j | � Wd QRX| j j � d k S)Nr Tg F)r ZqsizeZ not_empty�wait)r Ztimeoutr r r �poll9 s zConnection.pollc C s d S)Nr )r r r r r B s zConnection.closec C s | S)Nr )r r r r r E s zConnection.__enter__c C s | j � d S)N)r )r r r r r r r r H s zConnection.__exit__N)r r r r r" r r r r r r r r 1 s r ) �__all__Zqueuer Zfamilies�objectr r r r r r r r �<module> s
Save File
Cancel