=Og>fgdZddlmZdgZGddeZdZd dZGd d eZdS) )ClientListenerPipe)QueueNcDeZdZd dZdZdZedZdZdZ dS) rNc.t||_dSN)r_backlog_queue)selfaddressfamilybacklogs G/opt/alt/python311/lib64/python3.11/multiprocessing/dummy/connection.py__init__zListener.__init__s#GnncBt|jSr ) Connectionr getr s racceptzListener.accepts4.224455rcd|_dSr r rs rclosezListener.closes"rc|jSr rrs rr zListener.addresss ""rc|Sr rs r __enter__zListener.__enter__! rc.|dSr rr exc_type exc_valueexc_tbs r__exit__zListener.__exit__$ r)NNr) __name__ __module__ __qualname__rrrpropertyr rr&rrrrrs----666#####X#rrctt}}|||ft||Sr )rputr)r _in_outs rrr(s9C KKs  c4  rTcztt}}t||t||fSr )rr)duplexabs rrr.s2 77EGGqA a  Z1-- --rc.eZdZdZddZdZdZdZdS) rcn||_||_|jx|_|_|jx|_|_dSr )r/r.r-send send_bytesrrecv recv_bytes)r r.r/s rrzConnection.__init__5s4 &*h. DO&)g- DOOOrc|jdkrdS|dkrdS|jj5|jj|dddn #1swxYwY|jdkS)NrTr:F)r.qsize not_emptywait)r timeouts rpollzConnection.poll;s 8>>  a  4 c>>5 X  - - H  # #G , , , - - - - - - - - - - - - - - -x~~!##s A  A$'A$cdSr rrs rrzConnection.closeDs rc|Sr rrs rrzConnection.__enter__Grrc.|dSr r!r"s rr&zConnection.__exit__Jr'rN)r:)r(r)r*rr@rrr&rrrrr3sd... $$$$   rr)T) __all__queuerfamiliesobjectrrrrrrrrHs + * * 6v,!!! .... r