summaryrefslogtreecommitdiff
path: root/server3.py
diff options
context:
space:
mode:
authorKali Kaneko (leap communications) <kali@leap.se>2016-04-10 18:42:27 -0400
committerKali Kaneko (leap communications) <kali@leap.se>2016-04-10 18:42:27 -0400
commitc5de6f188dac491f114861648aafb30737da131f (patch)
tree327e20cabbbee4a656c4c57219b63fb0e501416d /server3.py
parentd3604a9a53a04af8c34d08f17b4708c460f76be9 (diff)
move PoCs to its own subdir
Diffstat (limited to 'server3.py')
-rw-r--r--server3.py42
1 files changed, 0 insertions, 42 deletions
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)