ytf! dZddlZddlmZmZmZGddZGddeeZGdd eeZGd d eeZ gd Z y) zProxy classes and functions.N)Device ProcessDevice ThreadDevicecReZdZdZej fdZdZdZdZ dZ dZ dZ y ) ProxyBasez"Base class for overriding methods.cltj|||||_g|_g|_g|_y)N)in_typeout_type)r__init__mon_type _mon_binds _mon_connects _mon_sockopts)selfr r r s a/var/www/html/software/conda/envs/higlass/lib/python3.12/site-packages/zmq/devices/proxydevice.pyr zProxyBase.__init__ s0gA  c:|jj|y)zaEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N)r appendraddrs rbind_monzProxyBase.bind_mons t$rc^|j|g|i|}|jd||fz|S)zEnqueue a random port on the given interface for binding on mon_socket. See zmq.Socket.bind_to_random_port for details. .. versionadded:: 18.0 z%s:%i)_reserve_random_portr)rrargskwargsports rbind_mon_to_random_portz!ProxyBase.bind_mon_to_random_ports:)t((??? gt ,- rc:|jj|y)zgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)rrrs r connect_monzProxyBase.connect_mon)s !!$'rc>|jj||fy)zfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)rr)roptvalues rsetsockopt_monzProxyBase.setsockopt_mon0s !!3,/rctj|\}}|j}|j|j}|j j ||jD]\}}|j|||jD]}|j||jD]}|j||||fSN) r_setup_sockets_contextsocketr _socketsrr setsockoptr bindrconnect)rinsoutsctxmonsr!r"ifaces rr&zProxyBase._setup_sockets7s))$/ Tmmzz$--( T",, (JC OOC ' (__ E IIe  '' E LL  D$rcZ|j\}}}tj|||yr%)r&zmqproxy)rr-r.r0s r run_devicezProxyBase.run_deviceIs&--/T4 #tT"rN) __name__ __module__ __qualname____doc__r3PUBr rrrr#r&r5rrrr s/,3677 % (0$#rrceZdZdZy)ProxyaThreadsafe Proxy object. See zmq.devices.Device for most of the spec. This subclass adds a _mon version of each _{in|out} method, for configuring the monitor socket. A Proxy is a 3-socket ZMQ Device that functions just like a QUEUE, except each message is also sent out on the monitor socket. A PUB socket is the most logical choice for the mon_socket, but it is not required. Nr6r7r8r9r;rrr=r=Ns rr=ceZdZdZy) ThreadProxyz&Proxy in a Thread. See Proxy for more.Nr>r;rrr@r@\s0rr@ceZdZdZy) ProcessProxyz'Proxy in a Process. See Proxy for more.Nr>r;rrrBrB`s1rrB)r=r@rB) r9r3zmq.devices.basedevicerrrrr=r@rB__all__r;rrrEsQ"  FFA#A#H Iv 1)\129m2 r