1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
from __future__ import print_function
from ResponseProvider import Payload
from ResponseProvider import ResponseProvider
from ResponseProvider import ResponseProviderMixin
from threading import Timer
import os
import threading
import tornado.ioloop
import tornado.web
import logging
class MainHandler(tornado.web.RequestHandler, ResponseProviderMixin):
ping_count = 1
self_destruct_timer = None
def got_pinged(self):
MainHandler.ping_count += 1
def kill(self):
MainHandler.ping_count -= 1
if MainHandler.ping_count <= 0: #so that if we decrease the value from several threads we still kill it.
MainHandler.suicide()
if MainHandler.self_destruct_timer:
MainHandler.self_destruct_timer.cancel()
def dispatch_response(self, payload):
self.set_status(payload.response_code())
for h in payload.headers():
self.add_header(h, payload.headers()[h])
self.add_header("Content-Length", payload.length())
self.write(payload.message())
def prepare_headers(self):
ret = dict()
for h in self.request.headers:
ret[h.lower()] = self.request.headers.get(h)
return ret
def init_vars(self):
self.response_provider = ResponseProvider(self)
self.headers = self.prepare_headers()
def prepare(self):
MainHandler.reset_self_destruct_timer()
self.init_vars()
def get(self, param):
self.dispatch_response(self.response_provider.response_for_url_and_headers(self.request.uri, self.headers))
def post(self, param):
self.dispatch_response(Payload(self.request.body))
@staticmethod
def suicide():
tornado.ioloop.IOLoop.current().stop()
logging.info("The server's life has come to an end, pid: {}".format(os.getpid()))
@staticmethod
def reset_self_destruct_timer():
if MainHandler.self_destruct_timer:
logging.debug("Canceling the kill timer")
MainHandler.self_destruct_timer.cancel()
MainHandler.self_destruct_timer = Timer(MainHandler.lifespan, MainHandler.suicide)
logging.debug("Starting the kill timer")
MainHandler.self_destruct_timer.start()
@staticmethod
def start_serving():
thread = threading.Thread(target=tornado.ioloop.IOLoop.current().start)
thread.deamon = True
thread.start()
@staticmethod
def init_server(port, lifespan):
MainHandler.lifespan = lifespan
MainHandler.reset_self_destruct_timer()
application = tornado.web.Application([
(r"/(.*)", MainHandler),
])
application.listen(port)
|
