o ?Og>@sPgdZddlmZdgZGdddeZddZd d d ZGd d d eZdS))ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dSN)r_backlog_queue)selfaddressZfamilyZbacklogr G/opt/alt/python310/lib64/python3.10/multiprocessing/dummy/connection.py__init__zListener.__init__cCst|jSr) Connectionrgetr r r r acceptrzListener.acceptcCs d|_dSrrrr r r closes zListener.closecCs|jSrrrr r r r szListener.addresscC|Srr rr r r __enter__!zListener.__enter__cC |dSrrr exc_type exc_valueZexc_tbr r r __exit__$ zListener.__exit__)NNr) __name__ __module__ __qualname__r rrpropertyr rrr r r r rs   rcCs&tt}}|||ft||Sr)rputr)r _in_outr r r r(s rTcCs"tt}}t||t||fSr)rr)Zduplexabr r r r.src@s6eZdZddZd ddZddZdd Zd d Zd S)rcCs,||_||_|j|_|_|j|_|_dSr)r%r$r#sendZ send_bytesrZrecvZ recv_bytes)r r$r%r r r r 5szConnection.__init__cCsb|jdkr dS|dkrdS|jj|jj|Wdn1s%wY|jdkS)NrTr)F)r$ZqsizeZ not_emptywait)r Ztimeoutr r r poll;s zConnection.pollcCsdSrr rr r r rDrzConnection.closecCrrr rr r r rGrzConnection.__enter__cCrrrrr r r rJrzConnection.__exit__N)r))rr r!r r+rrrr r r r r3s    r)T) __all__queuerZfamiliesobjectrrrrr r r r s