From eb301d0b9dc856f1982ccca640e3fc0fb339d259 Mon Sep 17 00:00:00 2001
From: Kazuhito Yokoi <kazuhito.yokoi.nx@hitachi.com>
Date: Fri, 27 Sep 2019 17:04:19 +0900
Subject: [PATCH] Add logging function for queue size

---
 .../@node-red/nodes/core/function/89-delay.js   | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/packages/node_modules/@node-red/nodes/core/function/89-delay.js b/packages/node_modules/@node-red/nodes/core/function/89-delay.js
index f80e58365..079227194 100644
--- a/packages/node_modules/@node-red/nodes/core/function/89-delay.js
+++ b/packages/node_modules/@node-red/nodes/core/function/89-delay.js
@@ -92,6 +92,7 @@ module.exports = function(RED) {
         this.randomID = -1;
         this.lastSent = null;
         this.drop = n.drop;
+        this.droppedMsgs = 0;
         var node = this;
 
         function ourTimeout(handler, delay) {
@@ -137,6 +138,19 @@ module.exports = function(RED) {
             }
         }
 
+        setInterval(function () {
+            if (node.buffer.length !== 0) {
+                node.debug("node.buffer.length = " + node.buffer.length);
+            }
+        }, 15 * 1000);
+
+        setInterval(function () {
+            if (node.droppedMsgs !== 0) {
+                node.debug("node.droppedMsgs = " + node.droppedMsgs);
+                node.droppedMsgs = 0;
+            }
+        }, 15 * 1000);
+
         if (node.pauseType === "delay") {
             node.on("input", function(msg) {
                 if (msg.hasOwnProperty("flush")) { flushDelayList(); }
@@ -218,6 +232,9 @@ module.exports = function(RED) {
                             }
                             if (node.buffer.length < _maxKeptMsgsCount) {
                                 node.buffer.push(msg);
+                            } else {
+                                node.trace("dropped due to buffer overflow. msg._msgid = " + msg._msgid);
+                                node.droppedMsgs++;
                             }
                         }
                     } else {