summaryrefslogtreecommitdiffstats
path: root/bitbake/lib/prserv/serv.py
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib/prserv/serv.py')
-rw-r--r--bitbake/lib/prserv/serv.py9
1 files changed, 0 insertions, 9 deletions
diff --git a/bitbake/lib/prserv/serv.py b/bitbake/lib/prserv/serv.py
index 05573d06cc..3992056f88 100644
--- a/bitbake/lib/prserv/serv.py
+++ b/bitbake/lib/prserv/serv.py
@@ -42,10 +42,7 @@ class PRServerClient(bb.asyncrpc.AsyncServerConnection):
42 try: 42 try:
43 return await super().dispatch_message(msg) 43 return await super().dispatch_message(msg)
44 except: 44 except:
45 self.server.table.sync()
46 raise 45 raise
47 else:
48 self.server.table.sync_if_dirty()
49 46
50 async def handle_test_pr(self, request): 47 async def handle_test_pr(self, request):
51 '''Finds the PR value corresponding to the request. If not found, returns None and doesn't insert a new value''' 48 '''Finds the PR value corresponding to the request. If not found, returns None and doesn't insert a new value'''
@@ -233,15 +230,9 @@ class PRServer(bb.asyncrpc.AsyncServer):
233 return tasks 230 return tasks
234 231
235 async def stop(self): 232 async def stop(self):
236 self.table.sync_if_dirty()
237 self.db.disconnect() 233 self.db.disconnect()
238 await super().stop() 234 await super().stop()
239 235
240 def signal_handler(self):
241 super().signal_handler()
242 if self.table:
243 self.table.sync()
244
245class PRServSingleton(object): 236class PRServSingleton(object):
246 def __init__(self, dbfile, logfile, host, port, upstream): 237 def __init__(self, dbfile, logfile, host, port, upstream):
247 self.dbfile = dbfile 238 self.dbfile = dbfile