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) 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)selfaddressZfamilyZbacklog 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 s zListener.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
)Zduplexabr
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_emptywait)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 Zfamiliesobjectr r r r
r
r
r
r
s