We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 17ba762 commit cc3ce6aCopy full SHA for cc3ce6a
src/canWrapper.cc
@@ -646,6 +646,17 @@ void heartbeatsWatchdog() {
646
while (true) {
647
std::this_thread::sleep_for (std::chrono::seconds(1));
648
649
+ {
650
+ // Erase removed CAN buses from heartbeatsRunning
651
+ std::scoped_lock lock{watchdogMtx, canDevicesMtx};
652
+ for(int i = 0; i < heartbeatsRunning.size(); i++) {
653
+ auto deviceIterator = canDeviceMap.find(heartbeatsRunning[i]);
654
+ if (deviceIterator == canDeviceMap.end()) {
655
+ heartbeatsRunning.erase(heartbeatsRunning.begin() + i);
656
+ }
657
658
659
+
660
std::scoped_lock lock{watchdogMtx};
661
662
if (heartbeatsRunning.size() < 1) { break; }
0 commit comments