Yf/@ssdddgZddlmZdgZGdddeZddZdd dZGd d d eZdS) ClientListenerPipe)QueueNc@sgeZdZdddddZddZddZed d Zd d Zd dZ dS)rNcCst||_dS)N)r_backlog_queue)selfaddressZfamilyZbacklogr E/opt/alt/python35/lib64/python3.5/multiprocessing/dummy/connection.py__init__szListener.__init__cCst|jjS)N) Connectionrget)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|jdS)N)r)rexc_type exc_valueexc_tbr r r __exit__"szListener.__exit__) __name__ __module__ __qualname__r rrpropertyr rrr r r r rs    cCs3tt}}|j||ft||S)N)rputr )r _in_outr r r r&sTcCs/tt}}t||t||fS)N)rr )Zduplexabr r r r,sc@sOeZdZddZdddZddZdd Zd d Zd S) r cCs<||_||_|j|_|_|j|_|_dS)N)rrrsendZ send_bytesrZrecvZ recv_bytes)rrrr r r r 3s  zConnection.__init__gc Csc|jjdkrdS|dkr)dS|jj|jjj|WdQRX|jjdkS)NrTgF)rZqsizeZ not_emptywait)rZtimeoutr r r poll9s  zConnection.pollcCsdS)Nr )rr r r rBszConnection.closecCs|S)Nr )rr r r rEszConnection.__enter__cCs|jdS)N)r)rrrrr r r rHszConnection.__exit__N)rrrr r"rrrr r r r r 1s    r ) __all__ZqueuerZfamiliesobjectrrrr r r r r  s