o w[e>@sPgdZddlmZdgZGdddeZddZd d d ZGd d d eZdS))ClientListenerPipe)QueueNc@sBeZdZdddZddZddZed d Zd d Zd dZ dS)rNcCst||_dSN)r_backlog_queue)selfaddressfamilybacklogr 7/usr/lib/python3.10/multiprocessing/dummy/connection.py__init__zListener.__init__cCst|jSr) Connectionrgetr r r racceptrzListener.acceptcCs d|_dSrrrr r rcloses zListener.closecCs|jSrrrr r rr szListener.addresscC|Srr rr r r __enter__!zListener.__enter__cC |dSrrr exc_type exc_valueexc_tbr r r__exit__$ zListener.__exit__)NNr) __name__ __module__ __qualname__rrrpropertyr rr r r r rrs   rcCs&tt}}|||ft||Sr)rputr)r _in_outr r rr(s rTcCs"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|jdkr dS|dkrdS|jj|jj|Wdn1s%wY|jdkS)NrTr0F)r'qsize not_emptywait)r timeoutr r rpoll;s zConnection.pollcCsdSrr rr r rrDrzConnection.closecCrrr rr r rrGrzConnection.__enter__cCrrrrr r rr Jr!zConnection.__exit__N)r0)r"r#r$rr5rrr r r r rr3s    r)T) __all__queuerfamiliesobjectrrrrr r r rs