summaryrefslogtreecommitdiffstats
path: root/bitbake/lib/hashserv/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib/hashserv/__init__.py')
-rw-r--r--bitbake/lib/hashserv/__init__.py14
1 files changed, 12 insertions, 2 deletions
diff --git a/bitbake/lib/hashserv/__init__.py b/bitbake/lib/hashserv/__init__.py
index 86aa7e9de6..1d5e08ee5a 100644
--- a/bitbake/lib/hashserv/__init__.py
+++ b/bitbake/lib/hashserv/__init__.py
@@ -13,6 +13,7 @@ import logging
13import socketserver 13import socketserver
14import queue 14import queue
15import threading 15import threading
16import signal
16from datetime import datetime 17from datetime import datetime
17 18
18logger = logging.getLogger('hashserv') 19logger = logging.getLogger('hashserv')
@@ -147,8 +148,14 @@ class ThreadedHTTPServer(HTTPServer):
147 self.handlerthread.daemon = False 148 self.handlerthread.daemon = False
148 149
149 self.handlerthread.start() 150 self.handlerthread.start()
151
152 signal.signal(signal.SIGTERM, self.sigterm_exception)
150 super().serve_forever() 153 super().serve_forever()
151 154
155 def sigterm_exception(self, signum, stackframe):
156 self.server_close()
157 os._exit(0)
158
152 def process_request_thread(self): 159 def process_request_thread(self):
153 while not self.quit: 160 while not self.quit:
154 try: 161 try:
@@ -163,6 +170,7 @@ class ThreadedHTTPServer(HTTPServer):
163 self.handle_error(request, client_address) 170 self.handle_error(request, client_address)
164 finally: 171 finally:
165 self.shutdown_request(request) 172 self.shutdown_request(request)
173 os._exit(0)
166 174
167 def process_request(self, request, client_address): 175 def process_request(self, request, client_address):
168 self.requestqueue.put((request, client_address)) 176 self.requestqueue.put((request, client_address))
@@ -208,6 +216,8 @@ def create_server(addr, dbname, prefix=''):
208 cursor.execute('CREATE INDEX IF NOT EXISTS taskhash_lookup ON tasks_v2 (method, taskhash)') 216 cursor.execute('CREATE INDEX IF NOT EXISTS taskhash_lookup ON tasks_v2 (method, taskhash)')
209 cursor.execute('CREATE INDEX IF NOT EXISTS outhash_lookup ON tasks_v2 (method, outhash)') 217 cursor.execute('CREATE INDEX IF NOT EXISTS outhash_lookup ON tasks_v2 (method, outhash)')
210 218
211 logger.info('Starting server on %s', addr) 219 ret = ThreadedHTTPServer(addr, Handler)
220
221 logger.info('Starting server on %s\n', ret.server_port)
212 222
213 return ThreadedHTTPServer(addr, Handler) 223 return ret