B `L@sRdddgZddlmZdgZGdddeZddZd d dZGd d d eZdS) ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dS)N)r_backlog_queue)selfaddressZfamilyZbacklogr E/opt/alt/python37/lib64/python3.7/multiprocessing/dummy/connection.py__init__szListener.__init__cCst|jS)N) Connectionrget)rr r r acceptszListener.acceptcCs d|_dS)N)r)rr r r closeszListener.closecCs|jS)N)r)rr r r r szListener.addresscCs|S)Nr )rr r r __enter__!szListener.__enter__cCs |dS)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}}|||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 5szConnection.__init__c CsN|jdkrdS|dkrdS|jj|jj|WdQRX|jdkS)NrTgF)rZqsizeZ not_emptywait)rZtimeoutr r r poll;s zConnection.pollcCsdS)Nr )rr r r rDszConnection.closecCs|S)Nr )rr r r rGszConnection.__enter__cCs |dS)N)r)rrrrr r r rJszConnection.__exit__N)r )rrrr r"rrrr r r r r 3s  r )T) __all__ZqueuerZfamiliesobjectrrrr r r r r  s