B b ,c" @srdZddlZddlmZmZmZGdddZGdddeeZGdd d eeZGd d d eeZ dd d gZ 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 r6lib/python3.7/site-packages/zmq/devices/proxydevice.pyr s zProxyBase.__init__cCs|j|dS)zaEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N)r append)r addrrrrbind_monszProxyBase.bind_moncOs(|j|f||}|d||f|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)Z_reserve_random_portr)r rargskwargsZportrrrbind_mon_to_random_portsz!ProxyBase.bind_mon_to_random_portcCs|j|dS)zgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)r r)r rrrr connect_mon*szProxyBase.connect_moncCs|j||fdS)zfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)r r)r optvaluerrrsetsockopt_mon1szProxyBase.setsockopt_moncCst|\}}|j}||j}|j|x|jD]\}}|||q4Wx|j D]}| |qTWx|j D]}| |qnW|||fS)N) r_setup_socketsZ_contextZsocketr Z_socketsrr Z setsockoptr Zbindr Zconnect)r insoutsZctxmonsrrZifacerrrr8s    zProxyBase._setup_socketscCs |\}}}t|||dS)N)rzmqproxy)r rrrrrr run_deviceJszProxyBase.run_deviceN) __name__ __module__ __qualname____doc__rZPUBrrrrrrr rrrrr src@seZdZdZdS)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. N)r!r"r#r$rrrrr%Os r%c@seZdZdZdS) ThreadProxyz&Proxy in a Thread. See Proxy for more.N)r!r"r#r$rrrrr&]sr&c@seZdZdZdS) ProcessProxyz'Proxy in a Process. See Proxy for more.N)r!r"r#r$rrrrr'asr') r$rZzmq.devices.basedevicerrrrr%r&r'__all__rrrrsE