diff options
author | drebs <drebs@riseup.net> | 2018-01-05 09:37:26 -0200 |
---|---|---|
committer | drebs <drebs@riseup.net> | 2018-01-05 09:37:26 -0200 |
commit | 7a2960d78baa00ef21da4e54c037a3f8cd78ccfc (patch) | |
tree | 8ac9e9b1b9b591365446ee00225323716c4232cb /blob-multiprocess/multiproc.py | |
parent | dde6cc729b2a32fc0201e9a124827e4bd7e6ca99 (diff) |
Fix directory name.
Diffstat (limited to 'blob-multiprocess/multiproc.py')
-rw-r--r-- | blob-multiprocess/multiproc.py | 58 |
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() |