]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/dashboard: privatize NotificationQueue methods
authorRicardo Dias <rdias@suse.com>
Thu, 8 Mar 2018 13:50:34 +0000 (13:50 +0000)
committerRicardo Dias <rdias@suse.com>
Tue, 27 Mar 2018 12:43:41 +0000 (13:43 +0100)
Signed-off-by: Ricardo Dias <rdias@suse.com>
src/pybind/mgr/dashboard/tools.py

index 153d21f5de5c68b854c91bf3eb68c3086c48317a..b138454cb23d605320116f2c13fc4806bc0385f3 100644 (file)
@@ -641,7 +641,7 @@ class NotificationQueue(threading.Thread):
             cls._cond.notify()
 
     @classmethod
-    def notify_listeners(cls, events):
+    def _notify_listeners(cls, events):
         for ev in events:
             notify_type, notify_value = ev
             with cls._lock:
@@ -660,11 +660,11 @@ class NotificationQueue(threading.Thread):
                     private_buffer.append(self._queue.popleft())
             except IndexError:
                 pass
-            self.notify_listeners(private_buffer)
+            self._notify_listeners(private_buffer)
             with self._cond:
                 self._cond.wait(1.0)
         # flush remaining events
         logger.debug("NQ: flush remaining events: %s", len(self._queue))
-        self.notify_listeners(self._queue)
+        self._notify_listeners(self._queue)
         self._queue.clear()
         logger.debug("notification queue finished")