Change incoming socket HWM to avoid limiting the number of requests

kusanagi · Feb 21, 2022 · 17925fc · 17925fc
1 parent 4fd6843
commit 17925fc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -5,6 +5,8 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/)
 and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ## [Unreleased]
+### Changed
+- Change incoming socket HWM to avoid limiting the number of incoming requests
 
 ## [3.0.1] - 2021-08-16
 ### Added

diff --git a/kusanagi/sdk/lib/server.py b/kusanagi/sdk/lib/server.py
@@ -313,6 +313,7 @@ async def listen(self):
         try:
             ctx = zmq.asyncio.Context()
             socket = ctx.socket(zmq.REP)
+            socket.hwm = 0
             socket.bind(channel)
         except zmq.error.ZMQError as err:  # pragma: no cover
             if err.errno == errno.EADDRINUSE: