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() | 
