summaryrefslogtreecommitdiff
path: root/blob-multiprocess/multiproc.py
diff options
context:
space:
mode:
authordrebs <drebs@riseup.net>2018-01-05 09:37:26 -0200
committerdrebs <drebs@riseup.net>2018-01-05 09:37:26 -0200
commit7a2960d78baa00ef21da4e54c037a3f8cd78ccfc (patch)
tree8ac9e9b1b9b591365446ee00225323716c4232cb /blob-multiprocess/multiproc.py
parentdde6cc729b2a32fc0201e9a124827e4bd7e6ca99 (diff)
Fix directory name.
Diffstat (limited to 'blob-multiprocess/multiproc.py')
-rw-r--r--blob-multiprocess/multiproc.py58
1 files changed, 0 insertions, 58 deletions
diff --git a/blob-multiprocess/multiproc.py b/blob-multiprocess/multiproc.py
deleted file mode 100644
index c367e04..0000000
--- a/blob-multiprocess/multiproc.py
+++ /dev/null
@@ -1,58 +0,0 @@
-#!/usr/bin/env python
-
-from argparse import ArgumentParser
-from twisted.internet import reactor
-from twisted.internet.protocol import ProcessProtocol
-from twisted.python.failure import Failure
-
-
-class BlobsServerProtocol(ProcessProtocol):
-
- def outReceived(self, data):
- if not isinstance(data, Failure):
- data = data.strip()
- if data:
- print(data)
-
- def errorReceived(self, data):
- if not isinstance(data, Failure):
- data = data.strip()
- if data:
- print(data)
-
- def processEnded(self, data):
- if not isinstance(data, Failure):
- data = data.strip()
- if data:
- print(data)
-
- # def processExited(self, data):
- # print(data)
-
-
-def parse_args():
- parser = ArgumentParser()
- parser.add_argument('--procs', type=int, default=4,
- help="the number of processes to spawn")
- args = parser.parse_args()
- return args
-
-
-def spawn_servers(procs):
- protocol = BlobsServerProtocol()
- children = []
- python = '/home/drebs/.virtualenvs/apps/bin/python'
- for port in range(8001, 8001 + procs):
- args = [python, './blobs-server.py', '/tmp/blobs', str(port)]
- child = reactor.spawnProcess(protocol, python, args)
- children.append(child)
-
-
-def main():
- args = parse_args()
- spawn_servers(args.procs)
- reactor.run()
-
-
-if __name__ == "__main__":
- main()