stats优化

Author: snowinszu

lib/hub.js

@@ -1,3 +1,4 @@
+const cluster = require('cluster');
 const redis = require('./broker/redis');
 const { getProtoBuf } = require("./utils/protoBuf");
 const { randomNum, timeout} = require("./utils/tool");
@@ -293,23 +294,25 @@ class Hub {
 
     async _handlePeerNotFound(client, toPeerId, peerId) {
         // this.logger.info(`_handlePeerNotFound ${client} ${toPeerId} ${peerId}`);
-        this.stats.notFoundCount ++;
         const msg = {
             action: 'signal',
             from_peer_id: toPeerId,
         }
         if (client) {
             if (toPeerId === client.notFoundIdCache) return
             client.notFoundIdCache = toPeerId;
+            this.stats.notFoundCount ++;
             return this.sendJsonToClient(client, msg);
         }
         // polling to another worker
-        if (redis.getIsAlive()) {
+        if (!cluster.isPrimary && redis.getIsAlive()) {
             const { node } = await this._getRemotePeerInfo(peerId);
             if (node) {
                 // this.logger.info(`polling to another worker, send peer not found`);
                 if (!node.sendMsgSignal(msg, peerId)) {
                     // this.logger.warn(`sendMsgSignal to remote ${addr} failed`);
+                } else {
+                    this.stats.notFoundCount ++;
                 }
             }
         }