a DOg>@sPgdZddlmZdgZGdddeZddZd d d ZGd d d eZdS))ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dSN)r_backlog_queue)selfaddressfamilybacklogr 8/usr/lib64/python3.9/multiprocessing/dummy/connection.py__init__szListener.__init__cCst|jSr) Connectionrgetr r r racceptszListener.acceptcCs d|_dSrrrr r rcloseszListener.closecCs|jSrrrr r rr szListener.addresscCs|Srr rr r r __enter__!szListener.__enter__cCs |dSrrr exc_type exc_valueexc_tbr r r__exit__$szListener.__exit__)NNr) __name__ __module__ __qualname__rrrpropertyr rrr r r rrs  rcCs&tt}}|||ft||Sr)rputr)r _in_outr r rr(srTcCs"tt}}t||t||fSr)rr)duplexabr r rr.src@s6eZdZddZd ddZddZdd Zd d Zd S)rcCs,||_||_|j|_|_|j|_|_dSr)r#r"r!send send_bytesrrecv recv_bytes)r r"r#r r rr5szConnection.__init__cCsb|jdkrdS|dkrdS|jj|jj|Wdn1sJ0Y|jdkS)NrTr+F)r"qsize not_emptywait)r timeoutr r rpoll;s ,zConnection.pollcCsdSrr rr r rrDszConnection.closecCs|Srr rr r rrGszConnection.__enter__cCs |dSrrrr r rrJszConnection.__exit__N)r+)rrrrr0rrrr r r rr3s  r)T) __all__queuerfamiliesobjectrrrrr r r r s