official
/
OpenLCP
1
0
Fork 0
Code Releases 1 Activity

rename variable to reflect validity for both rx and tx

This commit is contained in:
Kevin Matz 2022-12-02 12:52:52 -05:00
parent 8e082fb112
commit 6a2d1242be
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
protocol/esta/dmx/universe.cpp
View File

@ -87,11 +87,11 @@ double Universe::rxRate()
*/
long Universe::rxAge()
{
if (!last_seen_.time_since_epoch().count())
if (!last_updated_.time_since_epoch().count())
return -1; // universe has never been seen
auto now = std::chrono::system_clock::now();
auto elapsed = std::chrono::duration_cast<std::chrono::milliseconds>(now - last_seen_);
auto elapsed = std::chrono::duration_cast<std::chrono::milliseconds>(now - last_updated_);
return elapsed.count();
}
@ -189,7 +189,7 @@ void Universe::setValue(const uint16_t address, const uint8_t value)
null_start_mutex.unlock();
setStatus(Status::DMX_ACTIVE);
last_seen_ = std::chrono::system_clock::now();
last_updated_ = std::chrono::system_clock::now();
doDataCallbacks();
}
@ -213,7 +213,7 @@ void Universe::setValue(const uint16_t start, const uint16_t footprint,
null_start_mutex.unlock();
setStatus(Status::DMX_ACTIVE);
last_seen_ = std::chrono::system_clock::now();
last_updated_ = std::chrono::system_clock::now();
doDataCallbacks();
}
@ -266,7 +266,7 @@ void Universe::rx_timeout_(bool add_now)
if (add_now)
{
setStatus(Status::DMX_ACTIVE);
last_seen_ = now;
last_updated_ = now;
rx_times_.push(now);
}
else if (age >= E111_DATA_LOSS_TIMEOUT)

2
protocol/esta/dmx/universe.h
View File

@ -84,7 +84,7 @@ class Universe {
private:
std::chrono::system_clock::time_point last_seen_;
std::chrono::system_clock::time_point last_updated_;
std::queue<std::chrono::time_point<std::chrono::system_clock>> rx_times_;
void rx_timeout_(bool add_now = false);