summaryrefslogtreecommitdiffstats
path: root/external_libs/python/pyzmq-14.7.0/examples/device/server.py
diff options
context:
space:
mode:
Diffstat (limited to 'external_libs/python/pyzmq-14.7.0/examples/device/server.py')
-rw-r--r--external_libs/python/pyzmq-14.7.0/examples/device/server.py52
1 files changed, 0 insertions, 52 deletions
diff --git a/external_libs/python/pyzmq-14.7.0/examples/device/server.py b/external_libs/python/pyzmq-14.7.0/examples/device/server.py
deleted file mode 100644
index b29a3c1b..00000000
--- a/external_libs/python/pyzmq-14.7.0/examples/device/server.py
+++ /dev/null
@@ -1,52 +0,0 @@
-"""A device based server."""
-
-#
-# Copyright (c) 2010 Brian E. Granger and Eugene Chernyshov
-#
-# This file is part of pyzmq.
-#
-# pyzmq is free software; you can redistribute it and/or modify it under
-# the terms of the Lesser GNU General Public License as published by
-# the Free Software Foundation; either version 3 of the License, or
-# (at your option) any later version.
-#
-# pyzmq is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-# Lesser GNU General Public License for more details.
-#
-# You should have received a copy of the Lesser GNU General Public License
-# along with this program. If not, see <http://www.gnu.org/licenses/>.
-
-import zmq
-import os
-import threading
-import time
-
-print 'Server', os.getpid()
-
-def routine(context):
- socket = context.socket(zmq.REP)
-
- socket.connect("inproc://workers")
-
- while True:
- message = socket.recv()
- time.sleep(1)
- socket.send(message)
-
-context = zmq.Context(1)
-
-workers = context.socket(zmq.DEALER)
-workers.bind("inproc://workers");
-
-clients = context.socket(zmq.DEALER)
-clients.bind('tcp://127.0.0.1:5555')
-
-for i in range(10):
- thread = threading.Thread(target=routine, args=(context, ))
- thread.start()
-
-zmq.device(zmq.QUEUE, clients, workers)
-
-print "Finished"