Skip to content

Commit f86461d

Browse files
authored
Merge pull request #19 from REVrobotics/improve-heartbeats
2 parents baa60a7 + 1654b21 commit f86461d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/canWrapper.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -682,13 +682,13 @@ void heartbeatsWatchdog() {
682682
for(int i = 0; i < heartbeatsRunning.size(); i++) {
683683
if (sparkHeartbeatMap.contains(heartbeatsRunning[i])) {
684684
// Clear the scheduled heartbeat that has outdated data so that the updated one gets sent out immediately
685-
_sendCANMessage(descriptor, SPARK_HEARTBEAT_ID, disabledSparkHeartbeat, 8, -1);
685+
_sendCANMessage(heartbeatsRunning[i], SPARK_HEARTBEAT_ID, disabledSparkHeartbeat, 8, -1);
686686

687687
_sendCANMessage(heartbeatsRunning[i], SPARK_HEARTBEAT_ID, disabledSparkHeartbeat, 8, HEARTBEAT_PERIOD_MS);
688688
}
689689
if (revCommonHeartbeatMap.contains(heartbeatsRunning[i])) {
690690
// Clear the scheduled heartbeat that has outdated data so that the updated one gets sent out immediately
691-
_sendCANMessage(descriptor, REV_COMMON_HEARTBEAT_ID, disabledRevCommonHeartbeat, 1, -1);
691+
_sendCANMessage(heartbeatsRunning[i], REV_COMMON_HEARTBEAT_ID, disabledRevCommonHeartbeat, 1, -1);
692692

693693
_sendCANMessage(heartbeatsRunning[i], REV_COMMON_HEARTBEAT_ID, disabledRevCommonHeartbeat, 1, HEARTBEAT_PERIOD_MS);
694694
}
@@ -699,13 +699,13 @@ void heartbeatsWatchdog() {
699699
for(int i = 0; i < heartbeatsRunning.size(); i++) {
700700
if (auto heartbeatEntry = sparkHeartbeatMap.find(heartbeatsRunning[i]); heartbeatEntry != sparkHeartbeatMap.end()) {
701701
// Clear the scheduled heartbeat that has outdated data so that the updated one gets sent out immediately
702-
_sendCANMessage(descriptor, SPARK_HEARTBEAT_ID, heartbeatEntry->second.data(), 8, -1);
702+
_sendCANMessage(heartbeatsRunning[i], SPARK_HEARTBEAT_ID, heartbeatEntry->second.data(), 8, -1);
703703

704704
_sendCANMessage(heartbeatsRunning[i], SPARK_HEARTBEAT_ID, heartbeatEntry->second.data(), 8, HEARTBEAT_PERIOD_MS);
705705
}
706706
if (auto heartbeatEntry = revCommonHeartbeatMap.find(heartbeatsRunning[i]); heartbeatEntry != revCommonHeartbeatMap.end()) {
707707
// Clear the scheduled heartbeat that has outdated data so that the updated one gets sent out immediately
708-
_sendCANMessage(descriptor, REV_COMMON_HEARTBEAT_ID, heartbeatEntry->second.data(), 1, -1);
708+
_sendCANMessage(heartbeatsRunning[i], REV_COMMON_HEARTBEAT_ID, heartbeatEntry->second.data(), 1, -1);
709709

710710
_sendCANMessage(heartbeatsRunning[i], REV_COMMON_HEARTBEAT_ID, heartbeatEntry->second.data(), 1, HEARTBEAT_PERIOD_MS);
711711
}

0 commit comments

Comments
 (0)