3 \/@sRdddgZddlmZdgZGdddeZddZd d dZGd d d eZdS) ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dS)N)r_backlog_queue)selfaddressZfamilyZbacklogr 8/usr/lib64/python3.6/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__)NNr) __name__ __module__ __qualname__r rrpropertyr rrr r r r rs   cCs&tt}}|j||ft||S)N)rputr )r _in_outr r r r&sTcCs"tt}}t||t||fS)N)rr )Zduplexabr r r r,sc@s6eZdZddZd ddZddZdd Zd d Zd S)r cCs,||_||_|j|_|_|j|_|_dS)N)rrrsendZ send_bytesrZrecvZ recv_bytes)rrrr r r r 3szConnection.__init__c CsN|jjdkrdS|dkrdS|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)r!)rrrr r#rrrr r r r r 1s  r )T) __all__ZqueuerZfamiliesobjectrrrr r r r r  s