a DOg>@sPgdZddlmZdgZGdddeZddZd d d ZGd d d eZdS))ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dSN)r_backlog_queue)selfaddressZfamilyZbacklogr E/opt/alt/python39/lib64/python3.9/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  rcCs&tt}}|||ft||Sr)rputr)r _in_outr r r r(srTcCs"tt}}t||t||fSr)rr)Zduplexabr r r r.src@s6eZdZddZd ddZddZdd Zd d Zd S)rcCs,||_||_|j|_|_|j|_|_dSr)r rrsendZ send_bytesrZrecvZ recv_bytes)r rr r r r r 5szConnection.__init__cCsb|jdkrdS|dkrdS|jj|jj|Wdn1sJ0Y|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