*j> Z / S Qr SSKJr S/r " S S\5 rS rS
S jr " S S \5 rg) )ClientListenerPipe )QueueNc F \ rS rSrS
S jrS rS r\S 5 rS r S r
S r g) r Nc $ [ U5 U l g N)r _backlog_queue)selfaddressfamilybacklogs G/opt/alt/python313/lib64/python3.13/multiprocessing/dummy/connection.py__init__Listener.__init__ s #Gn c B [ U R R 5 6 $ r
)
Connectionr getr s r acceptListener.accept s 4..22455r c S U l g r
r r s r closeListener.close s
"r c U R $ r
r r s r r
Listener.address s """r c U $ r
r s r __enter__Listener.__enter__! r c $ U R 5 g r
r r exc_type exc_valueexc_tbs r __exit__Listener.__exit__$
r r )NN ) __name__
__module__ __qualname____firstlineno__r r r propertyr
r" r+ __static_attributes__r! r r r r s/ -6# # #r r c b [ 5 [ 5 p!U R X!45 [ X5 $ r
)r putr )r
_in_outs r r r ( s& KK c r c T [ 5 [ 5 p![ X5 [ X!5 4$ r
)r r )duplexabs r r r . s" 7EGq a Z - --r c 6 \ rS rSrS rS S jrS rS rS rSr g)
r 3 c | X l Xl UR =U l U l UR
=U l U l g r
)r8 r7 r6 send
send_bytesr recv
recv_bytes)r r7 r8 s r r Connection.__init__5 s0 &*hh. DO&)gg- DOr c 2 U R R 5 S: a gUS:: a gU R R U R R R U5 S S S 5 U R R 5 S: $ ! , ( d f N+= f)Nr T F)r7 qsize not_emptywait)r timeouts r pollConnection.poll; sk 88>> a c>
XX
HH # #G , xx~~ !##
s &B
Bc g r
r! r s r r Connection.closeD s r c U $ r
r! r s r r" Connection.__enter__G r$ r c $ U R 5 g r
r& r' s r r+ Connection.__exit__J r- r )r7 r8 rB rC r@ rA N)rF )
r/ r0 r1 r2 r rK r r" r+ r4 r! r r r r 3 s . $
r r )T) __all__queuer familiesobjectr r r r r! r r rW s: +
6v ,! .
r