î
e fT ã @ 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/python34/lib64/python3.4/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_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 so | j j ƒ d k r d S| d k r) d S| j j j ƒ | j j j | ƒ | j j j ƒ | j j ƒ d k S)Nr Tg F)r ZqsizeZ not_emptyÚacquireÚwaitÚrelease)r Ztimeoutr
r
r Úpoll9 s zConnection.pollc C s d S)Nr
)r r
r
r r C s zConnection.closec C s | S)Nr
)r r
r
r r F s zConnection.__enter__c C s | j ƒ d S)N)r )r r r r r
r
r r I 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 Ú
s