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:16 +0100 |
| commit | 8555869cde39f9e9a9ced5a3e5788209640f6d50 (patch) | |
| tree | 1f64598a3e386baeabb1fdd7a11468b2d2e5cf15 /lib/hashserv | |
| parent | 076baf4fbd328d247508fd399866a397eb34f67e (diff) | |
| download | bitbake-8555869cde39f9e9a9ced5a3e5788209640f6d50.tar.gz | |
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
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 'lib/hashserv')
| -rw-r--r-- | lib/hashserv/server.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/hashserv/server.py b/lib/hashserv/server.py index 8e8498973..a059e5211 100644 --- a/lib/hashserv/server.py +++ b/lib/hashserv/server.py @@ -410,11 +410,11 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): class Server(bb.asyncrpc.AsyncServer): - def __init__(self, db, loop=None, upstream=None, read_only=False): + def __init__(self, db, upstream=None, read_only=False): if upstream and read_only: raise bb.asyncrpc.ServerError("Read-only hashserv cannot pull from an upstream server") - super().__init__(logger, loop) + super().__init__(logger) self.request_stats = Stats() self.db = db |