Fixed dependencies of Control Plane to use external_lib sources

1 files changed, 42 insertions, 0 deletions

diff --git a/external_libs/python/pyzmq-14.7.0/examples/gevent/poll.py b/external_libs/python/pyzmq-14.7.0/examples/gevent/poll.py
new file mode 100644
index 00000000..1daf80a7
--- /dev/null
+++ b/external_libs/python/pyzmq-14.7.0/examples/gevent/poll.py
@@ -0,0 +1,42 @@
+import gevent
+from zmq import green as zmq
+
+# Connect to both receiving sockets and send 10 messages
+def sender():
+
+    sender = context.socket(zmq.PUSH)
+    sender.connect('inproc://polltest1')
+    sender.connect('inproc://polltest2')
+
+    for i in xrange(10):
+        sender.send('test %d' % i)
+        gevent.sleep(1)
+
+
+# create zmq context, and bind to pull sockets
+context = zmq.Context()
+receiver1 = context.socket(zmq.PULL)
+receiver1.bind('inproc://polltest1')
+receiver2 = context.socket(zmq.PULL)
+receiver2.bind('inproc://polltest2')
+
+gevent.spawn(sender)
+
+# Create poller and register both reciever sockets
+poller = zmq.Poller()
+poller.register(receiver1, zmq.POLLIN)
+poller.register(receiver2, zmq.POLLIN)
+
+# Read 10 messages from both reciever sockets
+msgcnt = 0
+while msgcnt < 10:
+    socks = dict(poller.poll())
+    if receiver1 in socks and socks[receiver1] == zmq.POLLIN:
+        print "Message from receiver1: %s" % receiver1.recv()
+        msgcnt += 1
+
+    if receiver2 in socks and socks[receiver2] == zmq.POLLIN:
+        print "Message from receiver2: %s" % receiver2.recv()
+        msgcnt += 1
+
+print "%d messages received" % msgcnt