[PATCH] Added peering1 example in Python.

[Piero Cornice]

Signed-off-by: Piero Cornice <root at pieroland.net>
---
 examples/Python/peering1.py |   94 ++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 84 insertions(+), 10 deletions(-)

diff --git a/examples/Python/peering1.py b/examples/Python/peering1.py
index 69a8816..f8aa0d9 100644
--- a/examples/Python/peering1.py
+++ b/examples/Python/peering1.py
@@ -1,13 +1,87 @@
-No-one has translated the peering1 example into Python yet.  Be the first to create
-peering1 in Python and get one free Internet!  If you're the author of the Python
-binding, this is a great way to get people to use 0MQ in Python.
+#
+#   Broker peering simulation (part 1) in Python
+#   Prototypes the state flow
+#
+#   Author : Piero Cornice
+#   Contact: root(at)pieroland(dot)net
+#
 
-To submit a new translation email it to zeromq-dev at lists.zeromq.org.  Please:
+import zmq
+import time
+import random
 
-* Stick to identical functionality and naming used in examples so that readers
-  can easily compare languages.
-* You MUST place your name as author in the examples so readers can contact you.
-* You MUST state in the email that you license your code under the MIT/X11
-  license.
+def main(args):
+
+    myself = args[1]
+    print "Hello, I am", myself
+
+    context = zmq.Context()
+
+    # State Back-End
+    statebe = context.socket(zmq.PUB)
+
+    # State Front-End
+    statefe = context.socket(zmq.SUB)
+    statefe.setsockopt(zmq.SUBSCRIBE, '')
+
+    bind_address = "ipc://" + myself + "-state.ipc"
+    statebe.bind(bind_address)
+
+    for i in range(len(args) - 2):
+        endpoint = "ipc://" + args[i + 2] + "-state.ipc"
+        statefe.connect(endpoint)
+        time.sleep(1.0)
+
+    poller = zmq.Poller()
+    poller.register(statefe, zmq.POLLIN)
+
+    while True:
+
+########## Solution with poll() ##########
+        socks = dict(poller.poll(1000))
+
+        try:
+            # Handle incoming status message
+            if socks[statefe] == zmq.POLLIN:
+                msg = statefe.recv_multipart()
+                print 'Received:', msg
+
+        except KeyError:
+            # Send our address and a random value
+            # for worker availability
+            msg = []
+            msg.append(bind_address)
+            msg.append(str(random.randrange(1, 10)))
+            statebe.send_multipart(msg)
+##################################
+
+######### Solution with select() #########
+#        (pollin, pollout, pollerr) = zmq.select([statefe], [], [], 1)
+#
+#        if len(pollin) > 0 and pollin[0] == statefe:
+#            # Handle incoming status message
+#            msg = statefe.recv_multipart()
+#            print 'Received:', msg
+#
+#        else:
+#            # Send our address and a random value
+#            # for worker availability
+#            msg = []
+#            msg.append(bind_address)
+#            msg.append(str(random.randrange(1, 10)))
+#            statebe.send_multipart(msg)
+##################################
+
+    poller.unregister(statefe)
+    time.sleep(1.0)
+
+
+if __name__ == '__main__':
+    import sys
+
+    if len(sys.argv) < 2:
+        print "Usage: peering.py <myself> <peer_1> ... <peer_N>"
+        raise SystemExit
+
+    main(sys.argv)
 
-Subscribe to this list at http://lists.zeromq.org/mailman/listinfo/zeromq-dev.
-- 
1.7.2.3


--------------000308090503010701010603--