@@ -37,7 +37,7 @@ std::map<std::string, std::shared_ptr<rev::usb::CANDevice>> canDeviceMap;
37
37
38
38
std::mutex watchdogMtx;
39
39
std::vector<std::string> heartbeatsRunning;
40
- auto latestHeartbeatAck = std::chrono::system_clock ::now();
40
+ auto latestHeartbeatAck = std::chrono::steady_clock ::now();
41
41
42
42
// Only call when holding canDevicesMtx
43
43
void removeExtraDevicesFromDeviceMap (std::vector<std::string> descriptors) {
@@ -665,7 +665,7 @@ void heartbeatsWatchdog() {
665
665
666
666
if (heartbeatsRunning.size () < 1 ) { break ; }
667
667
668
- auto now = std::chrono::system_clock ::now ();
668
+ auto now = std::chrono::steady_clock ::now ();
669
669
std::chrono::duration<double > elapsed_seconds = now-latestHeartbeatAck;
670
670
if (elapsed_seconds.count () > 1 ) {
671
671
uint8_t sparkMaxHeartbeat[] = {0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 };
@@ -680,7 +680,7 @@ void heartbeatsWatchdog() {
680
680
681
681
void ackHeartbeats (const Napi::CallbackInfo& info) {
682
682
std::scoped_lock lock{watchdogMtx};
683
- latestHeartbeatAck = std::chrono::system_clock ::now ();
683
+ latestHeartbeatAck = std::chrono::steady_clock ::now ();
684
684
}
685
685
686
686
// Params:
@@ -702,7 +702,7 @@ void startRevCommonHeartbeat(const Napi::CallbackInfo& info) {
702
702
703
703
if (heartbeatsRunning.size () == 0 ) {
704
704
heartbeatsRunning.push_back (descriptor);
705
- latestHeartbeatAck = std::chrono::system_clock ::now ();
705
+ latestHeartbeatAck = std::chrono::steady_clock ::now ();
706
706
std::thread hb (heartbeatsWatchdog);
707
707
hb.detach ();
708
708
} else {
@@ -748,7 +748,7 @@ void setSparkMaxHeartbeatData(const Napi::CallbackInfo& info) {
748
748
749
749
if (heartbeatsRunning.size () == 0 ) {
750
750
heartbeatsRunning.push_back (descriptor);
751
- latestHeartbeatAck = std::chrono::system_clock ::now ();
751
+ latestHeartbeatAck = std::chrono::steady_clock ::now ();
752
752
std::thread hb (heartbeatsWatchdog);
753
753
hb.detach ();
754
754
} else {
0 commit comments