j dZddlZddlmZmZmZGddZGddeeZGdd eeZGd d eeZ gd Z dS) zProxy classes and functions.N)Device ProcessDevice ThreadDevicecJeZdZdZejfdZdZdZdZ dZ dZ dZ d S) ProxyBasez"Base class for overriding methods.cltj|||||_g|_g|_g|_dS)N)in_typeout_type)r__init__mon_type _mon_binds _mon_connects _mon_sockopts)selfr r r s d/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/zmq/devices/proxydevice.pyr zProxyBase.__init__ s=gAAAA  c:|j|dS)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|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 :)_reserve_random_portr)rrargskwargsports rbind_mon_to_random_portz!ProxyBase.bind_mon_to_random_portsK)t(?????? &&&&''' rc:|j|dS)zgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N)rrrs r connect_monzProxyBase.connect_mon)s! !!$'''''rc>|j||fdS)zfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N)rr)roptvalues rsetsockopt_monzProxyBase.setsockopt_mon0s% !!3,/////rcrtj|\}}|j}||j}|j||jD]\}}||||j D]}| ||j D]}| ||||fSN) r_setup_sockets_contextsocketr _socketsrr setsockoptr bindrconnect)rinsoutsctxmonsr"r#ifaces rr'zProxyBase._setup_sockets7s)$// Tmzz$-(( T""", ( (JC OOC ' ' ' '_  E IIe    '  E LL    D$rcb|\}}}tj|||dSr&)r'zmqproxy)rr.r/r1s r run_devicezProxyBase.run_deviceIs3--//T4 #tT"""""rN) __name__ __module__ __qualname____doc__r4PUBr rrr r$r'r6rrrr s,,367    %%%   (((000$#####rrceZdZdZdS)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. Nr7r8r9r:r<rrr>r>Ns    rr>ceZdZdZdS) ThreadProxyz&Proxy in a Thread. See Proxy for more.Nr?r<rrrArA\s0000rrAceZdZdZdS) ProcessProxyz'Proxy in a Process. See Proxy for more.Nr?r<rrrCrC`s1111rrC)r>rArC) r:r4zmq.devices.basedevicerrrrr>rArC__all__r<rrrFs""  FFFFFFFFFFA#A#A#A#A#A#A#A#H     Iv   11111)\111222229m222   r