Tj>XgdZddlmZdgZGddeZdZd dZGdd eZy) )ClientListenerPipe)QueueNc<eZdZddZdZdZedZdZdZ y) rNc$t||_yN)r_backlog_queue)selfaddressfamilybacklogs 7/usr/lib/python3.12/multiprocessing/dummy/connection.py__init__zListener.__init__s#GncBt|jjSr ) Connectionr getr s racceptzListener.accepts4..22455rcd|_yr r rs rclosezListener.closes "rc|jSr rrs rr zListener.addresss"""rc|Sr rs r __enter__zListener.__enter__! rc$|jyr rr exc_type exc_valueexc_tbs r__exit__zListener.__exit__$  r)NN) __name__ __module__ __qualname__rrrpropertyr rr%rrrrrs/-6###rrchtt}}|j||ft||Sr )rputr)r _in_outs rrr(s,C KKs  c4  rcZtt}}t||t||fSr )rr)duplexabs rrr.s( 7EGqA a Z1- --rc,eZdZdZddZdZdZdZy)rc||_||_|jx|_|_|j x|_|_yr )r/r.r-send send_bytesrrecv recv_bytes)r r.r/s rrzConnection.__init__5s4 &*hh. DO&)gg- DOrc$|jjdkDry|dkry|jj5|jjj|ddd|jjdkDS#1swY&xYw)NrTF)r.qsize not_emptywait)r timeouts rpollzConnection.poll;sr 88>> a  c> XX   - HH   # #G , -xx~~!## - -s &BBcyr rrs rrzConnection.closeDs rc|Sr rrs rrzConnection.__enter__Grrc$|jyr r r!s rr%zConnection.__exit__Jr&rN)r;)r(r)r*rr@rrr%rrrrr3s. $ rr)T) __all__queuerfamiliesobjectrrrrrrrrHs: + 6v,! . r