cj> X g d Z ddlmZ dgZ G d de Zd Zd
dZ G d d e Zy) )ClientListenerPipe )QueueNc < e Zd ZddZd Zd Zed Zd Zd Z y) r Nc $ t | | _ y N)r _backlog_queue)selfaddressfamilybacklogs 9/usr/lib64/python3.12/multiprocessing/dummy/connection.py__init__zListener.__init__ s #Gn c B t | j j S r )
Connectionr
getr s r acceptzListener.accept s 4..22455r c d | _ y r r
r s r closezListener.close s
"r c | j S r r r s r r zListener.address s """r c | S r r s r __enter__zListener.__enter__! r c $ | j y r r r exc_type exc_valueexc_tbs r __exit__zListener.__exit__$
r )NN )
__name__
__module__ __qualname__r r r propertyr r r% r r r r r s/ -6# # #r r c h t t }}| j ||f t || S r )r putr )r _in_outs r r r ( s, C KKs c4 r c Z t t }}t || t || fS r )r r )duplexabs r r r . s( 7EGqA a Z1 - --r c , e Zd Zd ZddZd Zd Zd Zy)r c || _ || _ |j x| _ | _ |j
x| _ | _ y r )r/ r. r- send
send_bytesr recv
recv_bytes)r r. r/ s r r zConnection.__init__5 s4 &*hh. DO&)gg- DOr c $ | j j dkD ry|dk ry| j j 5 | j j j | d d d | j j dkD S # 1 sw Y &xY w)Nr T F)r. qsize not_emptywait)r timeouts r pollzConnection.poll; sk 88>> a c>
XX
HH # #G , xx~~ !##
s &BBc y r r r s r r zConnection.closeD s r c | S r r r s r r zConnection.__enter__G r r c $ | j y r r r! s r r% zConnection.__exit__J r& r N)r; )r( r) r* r r@ r r r% r r r r r 3 s . $
r r )T) __all__queuer familiesobjectr r r r r r r rH s: +
6v ,! .
r