You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ponymail.apache.org by hu...@apache.org on 2021/09/07 13:32:42 UTC
[incubator-ponymail-foal] branch humbedooh/mbox-stream updated:
init the streaming operator lock
This is an automated email from the ASF dual-hosted git repository.
humbedooh pushed a commit to branch humbedooh/mbox-stream
in repository https://gitbox.apache.org/repos/asf/incubator-ponymail-foal.git
The following commit(s) were added to refs/heads/humbedooh/mbox-stream by this push:
new a2e8b7e init the streaming operator lock
a2e8b7e is described below
commit a2e8b7e8f7cb27f695fac50dfb7dda3d07a9a77f
Author: Daniel Gruno <hu...@apache.org>
AuthorDate: Tue Sep 7 08:32:36 2021 -0500
init the streaming operator lock
---
server/main.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/server/main.py b/server/main.py
index a0d6ab5..78537b4 100644
--- a/server/main.py
+++ b/server/main.py
@@ -62,6 +62,7 @@ class Server(plugins.server.BaseServer):
self.dbpool = asyncio.Queue()
self.runners = plugins.offloader.ExecutorPool()
self.server = None
+ self.streamlock = asyncio.Lock()
# Make a pool of 15 database connections for async queries
for _ in range(1, 15):