Mpj%SrSSKrSSKrSSKJrJrJr SSKJr SSK J r J r "SS\ 5r 0r \\\4\S'0r\\\ 4\S '0r\\\4\S 'SS .S jrS rSrSrg)aCross-process transport for callback messages. When a callback is registered on an estimator that uses multiple worker processes, every worker ends up with its own copy of the callback (sent there by pickling). However, the user-visible state (e.g. logs being filled in or progress bars advancing) lives on the main process. This module provides a way for the worker copies to ship their messages back to the main process over a local endpoint (a UNIX socket on Unix, a Windows named pipe on Windows). Remark: we don't use a `multiprocessing.Manager` because its proxy objects become unusable once the Manager subprocess is gone, e.g. after unpickling in a fresh interpreter. The only ways to work around that either rely on multiprocessing private API or give up cross-process capabilities. N)Client ConnectionListener)Thread)Callable NamedTuplec.\rSrSr%Sr\\S'\\S'Srg)ListenerHandleaqA picklable reference to a main-process listener. Attributes ---------- address : str Address of the local endpoint the listener is bound to. Workers use this to connect, and the main process also uses it as a key into this module's registries to find the live listener. authkey : bytes Shared secret used to authenticate connections to the listener. addressauthkeyN) __name__ __module__ __qualname____firstlineno____doc__str__annotations__bytes__static_attributes__rW/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/sklearn/callback/_transport.pyr r s L Nrr _listeners_message_consumers_worker_connections)ownercH^^^[R"S5n[USS9m[TRUS9nT[ UR'T[ UR'Ub[R"U[U5 U4SjmUU4Sjn[USS9R5 U$) aCreate a listener for incoming messages on the main process. Also registers the listener and its message consumer in the module-level dicts. Parameters ---------- message_consumer : callable A one-argument function, `message_consumer(message)`, that processes incoming message to update the callback's state. This callable may be called from multiple different threads, and must therefore behave in a thread-safe manner. owner : callback instance, default=None Optional owner callback. When provided, the listener is automatically closed when `owner` gets garbage-collected. Returns ------- listener_handle : ListenerHandle A reference to the listener. )r backlog)r r c>T"UR55 URS5 M)![[4a gf=f)N)recvsendEOFErrorOSError)connmessage_consumers r_handleopen_listener.._handleisB  - $'"   s*-AAc>TR5n[TU4SS9R5 M-![a gf=f)NT)targetargsdaemon)acceptr&rstart)r'r)listeners r_acceptopen_listener.._accepttsI ( ' = C C E   s 0 ==T)r,r.) osurandomrr r rrweakreffinalizeclose_listenerrr0)r(rr listener_handler2r)r1s` @@r open_listenerr:Ds*jjnG5H$X-=-=wOO*2J&&'2B../ @ F '$'--/ rc[RURS5 [RURS5nUbUR 5 gg)zEStop listening for `listener_handle` and free its background threads.N)rpopr rclose)r9r1s rr8r8sC?22D9~~o55trIs  CC'ZB#% Dh $*,Dh', .0T#z/*/.29x.r