commit b664cfe2533e4bbf00fd5e7e0211bf7161ee2a04
author shangxu <shangxu@domob.cn> Fri Nov 13 18:03:01 2020 +0800
committer Jens Geyer <Jens-G@users.noreply.github.com> Thu Apr 21 09:13:52 2022 +0200
tree 34d4ee28eca26e9259ef2ab5d17ebb264e54ee26
parent 0dc52985ca06cb948eae251dce789f7f863fc243

fix Out Of Memory when use TNonblockingServer

lib/py/src/server/TNonblockingServer.py

diff --git a/lib/py/src/server/TNonblockingServer.py b/lib/py/src/server/TNonblockingServer.py
index f62d486..ac06496 100644
--- a/lib/py/src/server/TNonblockingServer.py
+++ b/lib/py/src/server/TNonblockingServer.py
@@ -151,6 +151,10 @@
             while len(self._rbuf) >= self._reading.end:
                 if self._reading.is_header:
                     mlen, = struct.unpack('!i', self._rbuf[:4])
+                    if mlen < 0:
+                        logger.error('could not read the head from frame')
+                        self.close()
+                        break
                     self._reading = Message(self._reading.end, mlen, False)
                     self.status = WAIT_MESSAGE
                 else: