diff options
author | Joshua Watt <JPEWhacker@gmail.com> | 2021-08-19 12:46:41 -0400 |
---|---|---|
committer | Richard Purdie <richard.purdie@linuxfoundation.org> | 2021-08-23 08:30:54 +0100 |
commit | fdc908f321da852856a07c19e3d9a33ccb273dda (patch) | |
tree | a26f6e925cb1a03be33c9817ac88abe742b43564 /bitbake/lib/hashserv | |
parent | e8182a794da04212e8815c1cb6d01f4f7744424f (diff) | |
download | poky-fdc908f321da852856a07c19e3d9a33ccb273dda.tar.gz |
bitbake: bitbake: asyncrpc: Defer all asyncio to child process
Reworks the async I/O API so that the async loop is only created in the
child process. This requires deferring the creation of the server until
the child process and a queue to transfer the bound address back to the
parent process
(Bitbake rev: 8555869cde39f9e9a9ced5a3e5788209640f6d50)
Signed-off-by: Joshua Watt <JPEWhacker@gmail.com>
[small loop -> self.loop fix in serv.py]
Signed-off-by: Scott Murray <scott.murray@konsulko.com>
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'bitbake/lib/hashserv')
-rw-r--r-- | bitbake/lib/hashserv/server.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/bitbake/lib/hashserv/server.py b/bitbake/lib/hashserv/server.py index 8e84989737..a059e52115 100644 --- a/bitbake/lib/hashserv/server.py +++ b/bitbake/lib/hashserv/server.py | |||
@@ -410,11 +410,11 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): | |||
410 | 410 | ||
411 | 411 | ||
412 | class Server(bb.asyncrpc.AsyncServer): | 412 | class Server(bb.asyncrpc.AsyncServer): |
413 | def __init__(self, db, loop=None, upstream=None, read_only=False): | 413 | def __init__(self, db, upstream=None, read_only=False): |
414 | if upstream and read_only: | 414 | if upstream and read_only: |
415 | raise bb.asyncrpc.ServerError("Read-only hashserv cannot pull from an upstream server") | 415 | raise bb.asyncrpc.ServerError("Read-only hashserv cannot pull from an upstream server") |
416 | 416 | ||
417 | super().__init__(logger, loop) | 417 | super().__init__(logger) |
418 | 418 | ||
419 | self.request_stats = Stats() | 419 | self.request_stats = Stats() |
420 | self.db = db | 420 | self.db = db |