ó è¾bc@smdddgZddlmZd gZdefd„ƒYZd„Zed„Zdefd „ƒYZ d S( tClienttListenertPipeiÿÿÿÿ(tQueuecBs;eZdddd„Zd„Zd„Zed„ƒZRS(icCst|ƒ|_dS(N(Rt_backlog_queue(tselftaddresstfamilytbacklog((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyt__init__-scCst|jjƒŒS(N(t ConnectionRtget(R((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pytaccept0scCs d|_dS(N(tNoneR(R((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pytclose3scCs|jS(N(R(R((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyt6tN(t__name__t __module__R R R RtpropertyR(((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyR+s  cCs3tƒtƒ}}|j||fƒt||ƒS(N(RtputR (Rt_int_out((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyR9scCs/tƒtƒ}}t||ƒt||ƒfS(N(RR (tduplextatb((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyR?sR cBs&eZd„Zdd„Zd„ZRS(cCs<||_||_|j|_|_|j|_|_dS(N(RRRtsendt send_bytesR trecvt recv_bytes(RRR((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyR Fs  gcCso|jjƒdkrtS|dkr)tS|jjjƒ|jjj|ƒ|jjjƒ|jjƒdkS(Nig(RtqsizetTruetFalset not_emptytacquiretwaittrelease(Rttimeout((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pytpollLs cCsdS(N((R((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyRVs(RRR R&R(((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyR Ds  N( t__all__RR tfamiliestobjectRRRRR (((s6/usr/lib/python2.7/multiprocessing/dummy/connection.pyt#s