From aafe65a14254d27e11a5d61a97314869bcc80fea Mon Sep 17 00:00:00 2001
From: Eugen Rochko <eugen@zeonfederated.com>
Date: Sat, 1 May 2021 23:19:18 +0200
Subject: Change log level of worker start/end to warn in streaming API
 (#16110)

---
 streaming/index.js | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'streaming')

diff --git a/streaming/index.js b/streaming/index.js
index c50d35583..0af80daad 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -99,11 +99,11 @@ const startMaster = () => {
     log.warn('UNIX domain socket is now supported by using SOCKET. Please migrate from PORT hack.');
   }
 
-  log.info(`Starting streaming API server master with ${numWorkers} workers`);
+  log.warn(`Starting streaming API server master with ${numWorkers} workers`);
 };
 
 const startWorker = (workerId) => {
-  log.info(`Starting worker ${workerId}`);
+  log.warn(`Starting worker ${workerId}`);
 
   const pgConfigs = {
     development: {
@@ -1067,11 +1067,11 @@ const startWorker = (workerId) => {
   }, 30000);
 
   attachServerWithConfig(server, address => {
-    log.info(`Worker ${workerId} now listening on ${address}`);
+    log.warn(`Worker ${workerId} now listening on ${address}`);
   });
 
   const onExit = () => {
-    log.info(`Worker ${workerId} exiting, bye bye`);
+    log.warn(`Worker ${workerId} exiting`);
     server.close();
     process.exit(0);
   };
-- 
cgit 


From c5c46dd6ee7f54a25c08216d957af45e68a20131 Mon Sep 17 00:00:00 2001
From: Eugen Rochko <eugen@zeonfederated.com>
Date: Sun, 2 May 2021 14:30:26 +0200
Subject: Fix "cb is not a function" error in streaming API server (#16134)

Third argument of `ping` is the callback

Regression from #15932
---
 streaming/index.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'streaming')

diff --git a/streaming/index.js b/streaming/index.js
index 0af80daad..7bb645a13 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -1062,7 +1062,7 @@ const startWorker = (workerId) => {
       }
 
       ws.isAlive = false;
-      ws.ping('', false, true);
+      ws.ping('', false);
     });
   }, 30000);
 
-- 
cgit