ó L]c@s˘dZddlZddlmZmZmZdefd„ƒYZdeefd„ƒYZdeefd „ƒYZ d eefd „ƒYZ ddd gZ dS( sProxy classes and functions.i˙˙˙˙N(tDevicet ThreadDevicet ProcessDevicet ProxyBasecBsSeZdZejd„Zd„Zd„Zd„Zd„Z d„Z d„Z RS(s"Base class for overriding methods.cCsAtj|d|d|ƒ||_g|_g|_g|_dS(Ntin_typetout_type(Rt__init__tmon_typet _mon_bindst _mon_connectst _mon_sockopts(tselfRRR((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR s    cCs|jj|ƒdS(saEnqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details. N(Rtappend(R taddr((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pytbind_monscOs0|j|||Ž}|jd||fƒ|S(sħEnqueue a random port on the given interface for binding on mon_socket. See zmq.Socket.bind_to_random_port for details. .. versionadded:: 18.0 s%s:%i(t_reserve_random_portR(R R targstkwargstport((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pytbind_mon_to_random_portscCs|jj|ƒdS(sgEnqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details. N(R R (R R ((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyt connect_mon*scCs|jj||fƒdS(sfEnqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details. N(R R (R topttvalue((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pytsetsockopt_mon1scCsİtj|ƒ\}}|j}|j|jƒ}x'|jD]\}}|j||ƒq:Wx|jD]}|j|ƒqdWx|j D]}|j |ƒq…W|||fS(N( Rt_setup_socketst_contexttsocketRR t setsockoptRtbindR tconnect(R tinstoutstctxtmonsRRtiface((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR8s cCs,|jƒ\}}}tj|||ƒdS(N(Rtzmqtproxy(R RRR!((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyt run_deviceIs( t__name__t __module__t__doc__R#tPUBRRRRRRR%(((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR s     tProxycBseZdZRS(s¨Threadsafe 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. (R&R'R((((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR*Ms t ThreadProxycBseZdZRS(s&Proxy in a Thread. See Proxy for more.(R&R'R((((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR+[st ProcessProxycBseZdZRS(s'Proxy in a Process. See Proxy for more.(R&R'R((((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyR,_s( R(R#tzmq.devices.basedeviceRRRtobjectRR*R+R,t__all__(((s6lib/python2.7/site-packages/zmq/devices/proxydevice.pyts C