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):