[ambari] branch branch-2.7 updated: AMBARI-24638. Ambari-agent process consuming more memory. (aonishuk)

[aonishuk]

This is an automated email from the ASF dual-hosted git repository.

aonishuk pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/ambari.git


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new 57df9fe  AMBARI-24638. Ambari-agent process consuming more memory. 
(aonishuk)
57df9fe is described below

commit 57df9febbbf6bec44efd67b198d9d0e0f8a69d8a
Author: Andrew Onishuk <aonis...@hortonworks.com>
AuthorDate: Fri Sep 14 11:08:52 2018 +0300

    AMBARI-24638. Ambari-agent process consuming more memory. (aonishuk)
---
 ambari-common/src/main/python/ambari_ws4py/websocket.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/ambari-common/src/main/python/ambari_ws4py/websocket.py 
b/ambari-common/src/main/python/ambari_ws4py/websocket.py
index 78d233e..53f1a43 100644
--- a/ambari-common/src/main/python/ambari_ws4py/websocket.py
+++ b/ambari-common/src/main/python/ambari_ws4py/websocket.py
@@ -480,7 +480,8 @@ class WebSocket(object):
         if not bytes and self.reading_buffer_size > 0:
             return False
 
-        self.reading_buffer_size = s.parser.send(bytes) or DEFAULT_READING_SIZE
+        with self.lock:
+          self.reading_buffer_size = s.parser.send(bytes) or 
DEFAULT_READING_SIZE
 
         if s.closing is not None:
             logger.info("Closing message received (%d) '%s'" % 
(s.closing.code, s.closing.reason))