]/ @ 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) ClientListenerPipe )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)selfaddressfamilybacklog r //opt/alt/python35/lib64/python3.5/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_valueexc_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 )duplexabr 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 send
send_bytesr recv
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 qsize not_emptywait)r timeoutr 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__queuer familiesobjectr r r r r r r r
<module>
s