Don't update min in publish
This commit is contained in:
@@ -137,10 +137,7 @@ private:
|
|||||||
if (!iterator->terminatingWildcardChild->triggered) {
|
if (!iterator->terminatingWildcardChild->triggered) {
|
||||||
triggeredTopics[numTriggeredTopics++] = iterator->terminatingWildcardChild;
|
triggeredTopics[numTriggeredTopics++] = iterator->terminatingWildcardChild;
|
||||||
|
|
||||||
/* Keep track of lowest subscriber */
|
|
||||||
if (*iterator->terminatingWildcardChild->subs.begin() < min) {
|
|
||||||
min = *iterator->terminatingWildcardChild->subs.begin();
|
|
||||||
}
|
|
||||||
|
|
||||||
iterator->terminatingWildcardChild->triggered = true;
|
iterator->terminatingWildcardChild->triggered = true;
|
||||||
}
|
}
|
||||||
@@ -167,10 +164,7 @@ private:
|
|||||||
if (!iterator->triggered) {
|
if (!iterator->triggered) {
|
||||||
triggeredTopics[numTriggeredTopics++] = iterator;
|
triggeredTopics[numTriggeredTopics++] = iterator;
|
||||||
|
|
||||||
/* Keep track of lowest subscriber */
|
|
||||||
if (*iterator->subs.begin() < min) {
|
|
||||||
min = *iterator->subs.begin();
|
|
||||||
}
|
|
||||||
|
|
||||||
iterator->triggered = true;
|
iterator->triggered = true;
|
||||||
}
|
}
|
||||||
@@ -426,4 +420,4 @@ public:
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
Reference in New Issue
Block a user