diff options
Diffstat (limited to 'bitbake/lib/prserv/serv.py')
| -rw-r--r-- | bitbake/lib/prserv/serv.py | 9 |
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 | |||
| 245 | class PRServSingleton(object): | 236 | class 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 |
