ž ¨ÿfé c@ssdddgZddlmZd gZGdd„deƒZdd„Zd dd„Z Gdd „d eƒZ d S( uClientuListeneruPipei(uQueuecBsk|EeZdZddddd„Zdd„Zdd„Zedd „ƒZd d „Z d d „Z dS(uListenericCst|ƒ|_dS(N(uQueueu_backlog_queue(uselfuaddressufamilyubacklog((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu__init__-suListener.__init__cCst|jjƒŒS(N(u Connectionu_backlog_queueuget(uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuaccept0suListener.acceptcCs d|_dS(N(uNoneu_backlog_queue(uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuclose3suListener.closecCs|jS(N(u_backlog_queue(uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu6suListener.cCs|S(N((uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __enter__8suListener.__enter__cCs|jƒdS(N(uclose(uselfuexc_typeu exc_valueuexc_tb((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu__exit__;suListener.__exit__N( u__name__u __module__u __qualname__uNoneu__init__uacceptucloseupropertyuaddressu __enter__u__exit__(u __locals__((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuListener+s    cCs3tƒtƒ}}|j||fƒt||ƒS(N(uQueueuputu Connection(uaddressu_inu_out((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuClient?scCs/tƒtƒ}}t||ƒt||ƒfS(N(uQueueu Connection(uduplexuaub((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuPipeEscBsS|EeZdZdd„Zddd„Zdd„Zdd „Zd d „Zd S( u ConnectioncCs<||_||_|j|_|_|j|_|_dS(N(u_outu_inuputusendu send_bytesugeturecvu recv_bytes(uselfu_inu_out((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu__init__Ls  uConnection.__init__gcCso|jjƒdkrdS|dkr)dS|jjjƒ|jjj|ƒ|jjjƒ|jjƒdkS(NigTF(u_inuqsizeuTrueuFalseu not_emptyuacquireuwaiturelease(uselfutimeout((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyupollRs uConnection.pollcCsdS(N((uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyuclose\suConnection.closecCs|S(N((uself((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu __enter___suConnection.__enter__cCs|jƒdS(N(uclose(uselfuexc_typeu exc_valueuexc_tb((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu__exit__bsuConnection.__exit__N(u__name__u __module__u __qualname__u__init__upollucloseu __enter__u__exit__(u __locals__((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu ConnectionJs    u ConnectionNT( u__all__uqueueuQueueuNoneufamiliesuobjectuListeneruClientuTrueuPipeu Connection(((uE/opt/alt/python33/lib64/python3.3/multiprocessing/dummy/connection.pyu#s