Adding watchdog to host serial port

This commit is contained in:
Andy CA6JAU 2017-08-20 11:19:58 -03:00
parent 5b313b7cec
commit 8f317fd332
3 changed files with 32 additions and 17 deletions

5
IO.cpp
View File

@ -386,6 +386,11 @@ void CIO::resetWatchdog()
m_watchdog = 0U; m_watchdog = 0U;
} }
uint32_t CIO::getWatchdog()
{
return m_watchdog;
}
bool CIO::hasLockout() const bool CIO::hasLockout() const
{ {
return m_lockout; return m_lockout;

1
IO.h
View File

@ -52,6 +52,7 @@ public:
bool hasLockout() const; bool hasLockout() const;
void resetWatchdog(); void resetWatchdog();
uint32_t getWatchdog();
private: private:
bool m_started; bool m_started;

View File

@ -421,6 +421,10 @@ void CSerialPort::process()
m_ptr = 1U; m_ptr = 1U;
m_len = 0U; m_len = 0U;
} }
else {
m_ptr = 0U;
m_len = 0U;
}
} else if (m_ptr == 1U) { } else if (m_ptr == 1U) {
// Handle the frame length // Handle the frame length
m_len = m_buffer[m_ptr] = c; m_len = m_buffer[m_ptr] = c;
@ -645,9 +649,9 @@ void CSerialPort::process()
#if defined(SERIAL_REPEATER) #if defined(SERIAL_REPEATER)
case MMDVM_SERIAL: { case MMDVM_SERIAL: {
for (uint8_t i = 3U; i < m_len; i++) for (uint8_t i = 3U; i < m_len; i++)
m_repeat.put(m_buffer[i]); m_repeat.put(m_buffer[i]);
} }
break; break;
#endif #endif
@ -663,23 +667,28 @@ void CSerialPort::process()
} }
} }
if (io.getWatchdog() >= 48000U) {
m_ptr = 0U;
m_len = 0U;
}
#if defined(SERIAL_REPEATER) #if defined(SERIAL_REPEATER)
// Write any outgoing serial data // Write any outgoing serial data
uint16_t space = m_repeat.getData(); uint16_t space = m_repeat.getData();
if (space > 0U) { if (space > 0U) {
int avail = availableForWriteInt(3U); int avail = availableForWriteInt(3U);
if (avail < space) if (avail < space)
space = avail; space = avail;
for (uint16_t i = 0U; i < space; i++) { for (uint16_t i = 0U; i < space; i++) {
uint8_t c = m_repeat.get(); uint8_t c = m_repeat.get();
writeInt(3U, &c, 1U); writeInt(3U, &c, 1U);
} }
} }
// Read any incoming serial data // Read any incoming serial data
while (availableInt(3U)) while (availableInt(3U))
readInt(3U); readInt(3U);
#endif #endif
} }