Track delta of msg processed by worker vs main

EdwardLu2018 · Jul 11, 2024 · 574e720 · 574e720
1 parent f28fde6
commit 574e720
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/src/systems/core/mqtt.js b/src/systems/core/mqtt.js
@@ -14,6 +14,8 @@ import { ARENA_EVENTS, ACTIONS } from '../../constants';
 const warn = AFRAME.utils.debug('ARENA:MQTT:warn');
 // const error = AFRAME.utils.debug('ARENA:MQTT:error');
 
+let lastMetricTick = new Date().getTime();
+
 AFRAME.registerSystem('arena-mqtt', {
     schema: {
         mqttHost: { type: 'string', default: ARENA.defaults.mqttHost },
@@ -139,6 +141,12 @@ AFRAME.registerSystem('arena-mqtt', {
      * @param {object} message
      */
     onSceneMessageArrived(message) {
+        const now = new Date().getTime();
+        if (now - lastMetricTick > 1000) {
+            console.log(`Worker message delay: ${now - message.workerTimestamp}ms`);
+            lastMetricTick = now;
+        }
+        delete message.workerTimestamp;
         const theMessage = message.payloadObj; // This will be given as json
 
         if (!theMessage) {

diff --git a/src/systems/core/workers/mqtt-worker.js b/src/systems/core/workers/mqtt-worker.js
@@ -118,6 +118,7 @@ class MQTTWorker {
         const topicCategory = topic.split('/')[1];
         const handler = this.messageHandlers[topicCategory];
         if (handler) {
+            message.workerTimestamp = new Date().getTime();
             handler(message);
         }
     }