From c5de6f188dac491f114861648aafb30737da131f Mon Sep 17 00:00:00 2001 From: "Kali Kaneko (leap communications)" Date: Sun, 10 Apr 2016 18:42:27 -0400 Subject: move PoCs to its own subdir --- server3.py | 42 ------------------------------------------ 1 file changed, 42 deletions(-) delete mode 100644 server3.py (limited to 'server3.py') diff --git a/server3.py b/server3.py deleted file mode 100644 index d737d4b..0000000 --- a/server3.py +++ /dev/null @@ -1,42 +0,0 @@ -import os -import sys -from klein import run, route - -from twisted.internet import defer -from twisted.internet import reactor -from twisted.python import log - -from ampoule import pool - -import tasks - -log.startLogging(sys.stdout) - -FIB = os.environ.get('FIB', tasks.FIB_DEFAULT) - - -@route('/') -def home(request): - d = pp.doWork(tasks.Fib, n=int(FIB)) - d.addCallback(lambda res: 'answer is >>> {r}\n'.format(r=res['fib'])) - return d - -@route('/hi') -def ping(request): - return 'easy!' - - -pp = None - - -@defer.inlineCallbacks -def start_pool(): - global pp - # TODO get max number of processors - pp = pool.ProcessPool(tasks.FibCalculator, min=1, max=4) - print 'starting pool' - yield pp.start() - -if __name__ == "__main__": - reactor.callWhenRunning(start_pool) - run("localhost", 8080) -- cgit v1.2.3