ó õùPc@smdddgZddlmZd gZdefd„ƒYZd„Zed„Zdefd „ƒYZ d S( tClienttListenertPipeiÿÿÿÿ(tQueuecBs;eZdddd„Zd„Zd„Zed„ƒZRS(icCst|ƒ|_dS(N(Rt_backlog_queue(tselftaddresstfamilytbacklog((s1..\python\lib\multiprocessing\dummy\connection.pyt__init__scCst|jjƒŒS(N(t ConnectionRtget(R((s1..\python\lib\multiprocessing\dummy\connection.pytacceptscCs d|_dS(N(tNoneR(R((s1..\python\lib\multiprocessing\dummy\connection.pytclosescCs|jS(N(R(R((s1..\python\lib\multiprocessing\dummy\connection.pytsN(t__name__t __module__R R R RtpropertyR(((s1..\python\lib\multiprocessing\dummy\connection.pyRs  cCs3tƒtƒ}}|j||fƒt||ƒS(N(RtputR (Rt_int_out((s1..\python\lib\multiprocessing\dummy\connection.pyRscCs/tƒtƒ}}t||ƒt||ƒfS(N(RR (tduplextatb((s1..\python\lib\multiprocessing\dummy\connection.pyR%sR cBs&eZd„Zdd„Zd„ZRS(cCs<||_||_|j|_|_|j|_|_dS(N(RRRtsendt send_bytesR trecvt recv_bytes(RRR((s1..\python\lib\multiprocessing\dummy\connection.pyR ,s  gcCso|jjƒdkrtS|dkr)tS|jjjƒ|jjj|ƒ|jjjƒ|jjƒdkS(Nig(RtqsizetTruetFalset not_emptytacquiretwaittrelease(Rttimeout((s1..\python\lib\multiprocessing\dummy\connection.pytpoll2s cCsdS(N((R((s1..\python\lib\multiprocessing\dummy\connection.pyR<s(RRR R%R(((s1..\python\lib\multiprocessing\dummy\connection.pyR *s  N( t__all__RR tfamiliestobjectRRRRR (((s1..\python\lib\multiprocessing\dummy\connection.pyt s