o Zh @spdZddlZddlmZmZmZGdddZGdddeeZGdd d eeZGd d d eeZ gd Z dS) zProxy classes and functions.N)Device ProcessDevice ThreadDevicec@sNeZdZdZejfddZddZddZdd Z d d Z d d Z ddZ dS) ProxyBasez"Base class for overriding methods.cCs,tj|||d||_g|_g|_g|_dS)N)in_typeout_type)r__init__mon_type _mon_binds _mon_connects _mon_sockopts)selfrrr rN/var/www/html/lang_env/lib/python3.10/site-packages/zmq/devices/proxydevice.pyr s  zProxyBase.__init__cC|j|dS)zaEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N)r appendr addrrrrbind_monzProxyBase.bind_moncOs0|j|g|Ri|}||d||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_reserve_random_portr)r rargskwargsportrrrbind_mon_to_random_portsz!ProxyBase.bind_mon_to_random_portcCr)zgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)r rrrrr connect_mon)rzProxyBase.connect_moncCs|j||fdS)zfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)r r)r optvaluerrrsetsockopt_mon0szProxyBase.setsockopt_moncCs~t|\}}|j}||j}|j||jD] \}}|||q|j D]}| |q'|j D]}| |q2|||fSN) r_setup_sockets_contextsocketr Z_socketsrr setsockoptr bindr connect)r insoutsctxmonsrrZifacerrrr 7s       zProxyBase._setup_socketscCs |\}}}t|||dSr)r zmqproxy)r r&r'r)rrr run_deviceIszProxyBase.run_deviceN) __name__ __module__ __qualname____doc__r*ZPUBrrrrrr r,rrrrr s rc@eZdZdZdS)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. Nr-r.r/r0rrrrr2Nr2c@r1) ThreadProxyz&Proxy in a Thread. See Proxy for more.Nr3rrrrr5\r4r5c@r1) ProcessProxyz'Proxy in a Process. See Proxy for more.Nr3rrrrr6`r4r6)r2r5r6) r0r*Zzmq.devices.basedevicerrrrr2r5r6__all__rrrrsD