î e fTã@ssdddgZddlmZdgZGdd„deƒZdd„Zdd d„ZGd d „d eƒZdS) ÚClientÚListenerÚPipeé)ÚQueueNc@sgeZdZddddd„Zdd„Zdd„Zed d „ƒZd d „Zd d„Z dS)rNécCst|ƒ|_dS)N)rÚ_backlog_queue)ÚselfÚaddressZfamilyZbacklog©r úE/opt/alt/python34/lib64/python3.4/multiprocessing/dummy/connection.pyÚ__init__szListener.__init__cCst|jjƒŒS)N)Ú ConnectionrÚget)rr r r ÚacceptszListener.acceptcCs d|_dS)N)r)rr r r ÚcloseszListener.closecCs|jS)N)r)rr r r ÚszListener.cCs|S)Nr )rr r r Ú __enter__szListener.__enter__cCs|jƒdS)N)r)rÚexc_typeÚ exc_valueÚexc_tbr r r Ú__exit__"szListener.__exit__) Ú__name__Ú __module__Ú __qualname__r rrÚpropertyr rrr r r r rs    cCs3tƒtƒ}}|j||fƒt||ƒS)N)rÚputr )r Ú_inÚ_outr r r r&sTcCs/tƒtƒ}}t||ƒt||ƒfS)N)rr )ZduplexÚaÚbr r r r,sc@sOeZdZdd„Zddd„Zdd„Zdd „Zd d „Zd S) r cCs<||_||_|j|_|_|j|_|_dS)N)rrrÚsendZ send_bytesrZrecvZ recv_bytes)rrrr r r r 3s  zConnection.__init__gcCso|jjƒdkrdS|dkr)dS|jjjƒ|jjj|ƒ|jjjƒ|jjƒdkS)NrTgF)rZqsizeZ not_emptyÚacquireÚwaitÚrelease)rZtimeoutr r r Úpoll9s zConnection.pollcCsdS)Nr )rr r r rCszConnection.closecCs|S)Nr )rr r r rFszConnection.__enter__cCs|jƒdS)N)r)rrrrr r r rIszConnection.__exit__N)rrrr r$rrrr r r r r 1s    r ) Ú__all__ZqueuerZfamiliesÚobjectrrrr r r r r Ú s