Filter triggered topics without subscribers

2019-10-17 01:23:27 +02:00
parent d8fe3a25b8
commit de688869d6
1 changed files with 13 additions and 0 deletions
@@ -295,6 +295,19 @@ public:
            return;
        }

+        /* bug fix: Filter triggered topics without subscribers */
+        int numFilteredTriggeredTopics = 0;
+        for (int i = 0; i < numTriggeredTopics; i++) {
+            if (triggeredTopics[i]->subs.size()) {
+                triggeredTopics[numFilteredTriggeredTopics++] = triggeredTopics[i];
+            }
+        }
+        numTriggeredTopics = numFilteredTriggeredTopics;
+
+        if (!numTriggeredTopics) {
+            return;
+        }
+
        /* bug fix: update min, as the one tracked via subscribe gets invalid as you unsubscribe */
        min = (Subscriber *)UINTPTR_MAX;
        for (int i = 0; i < numTriggeredTopics; i++) {