Y] f g d Z ddlmZ dgZ G d de Zd Zd dZ G d d
e ZdS ) )ClientListenerPipe )QueueNc D e Zd Zd dZd Zd Zed Zd Zd Z dS )
r N c . t | | _ d S N)r _backlog_queue)selfaddressfamilybacklogs M/opt/alt/python-internal/lib64/python3.11/multiprocessing/dummy/connection.py__init__zListener.__init__ s #Gnn c B t | j S r
)
Connectionr getr s r acceptzListener.accept s 4.224455r c d | _ d S 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 . | d S r
r r exc_type exc_valueexc_tbs r __exit__zListener.__exit__$
r )NNr )
__name__
__module__ __qualname__r r r propertyr
r r& r r r r r s - - - -6 6 6# # # # # X# r r c t t }}| ||f t || S r
)r putr )r
_in_outs r r r ( s9 C KKs c4 r Tc z t t }}t || t || fS r
)r r )duplexabs r r r . s2 77EGGqA a Z1 - - --r c . e Zd Zd ZddZd Zd Zd ZdS ) r c n || _ || _ |j x| _ | _ |j x| _ | _ d S r
)r/ r. r- send
send_bytesr recv
recv_bytes)r r. r/ s r r zConnection.__init__5 s4 &*h. DO&)g- DOOOr c | j dk rdS |dk rdS | j j 5 | j j | d d d n # 1 swxY w Y | j dk S )Nr Tr: F)r. qsize not_emptywait)r timeouts r pollzConnection.poll; s 8>> a 4 c>>5
X
- - H # #G , , , - - - - - - - - - - - - - - -x~~ !##s A A$'A$c d S r
r r s r r zConnection.closeD s r c | S r
r r s r r zConnection.__enter__G r r c . | d S 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 sd . . . $ $ $ $
r r )T) __all__queuer familiesobjectr r r r r r r rH s +
*
*
6 v ,! ! ! . . . .
r