U if>@sRdddgZddlmZdgZGdddeZddZd d dZGd d d eZdS) ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dSN)r_backlog_queue)selfaddressZfamilyZbacklogr E/opt/alt/python38/lib64/python3.8/multiprocessing/dummy/connection.py__init__szListener.__init__cCst|jSr) Connectionrgetr r r r acceptszListener.acceptcCs d|_dSrrrr r r closeszListener.closecCs|jSrrrr r r r szListener.addresscCs|Srr rr r r __enter__!szListener.__enter__cCs |dSrrr exc_type exc_valueZexc_tbr r r __exit__$szListener.__exit__)NNr) __name__ __module__ __qualname__r rrpropertyr rrr r r r rs  cCs&tt}}|||ft||Sr)rputr)r _in_outr r r r(sTcCs"tt}}t||t||fSr)rr)Zduplexabr r r r.sc@s6eZdZddZd ddZddZdd Zd d Zd S)rcCs,||_||_|j|_|_|j|_|_dSr)r rrsendZ send_bytesrZrecvZ recv_bytes)r rr r r r r 5szConnection.__init__c CsN|jdkrdS|dkrdS|jj|jj|W5QRX|jdkS)NrTr$F)rZqsizeZ not_emptywait)r Ztimeoutr r r poll;s zConnection.pollcCsdSrr rr r r rDszConnection.closecCs|Srr rr r r rGszConnection.__enter__cCs |dSrrrr r r rJszConnection.__exit__N)r$)rrrr r&rrrr r r r r3s  r)T) __all__ZqueuerZfamiliesobjectrrrrr r r r  s