mirror of
https://github.com/g4klx/MMDVMHost
synced 2025-12-23 08:45:48 +08:00
Merge branch 'mqtt' into mqtt_plus
This commit is contained in:
@@ -564,7 +564,10 @@ void CM17Control::writeNetwork()
|
|||||||
m_networkWatchdog.start();
|
m_networkWatchdog.start();
|
||||||
|
|
||||||
if (!m_allowEncryption) {
|
if (!m_allowEncryption) {
|
||||||
unsigned char type = m_netLSF.getEncryptionType();
|
CM17LSF lsf;
|
||||||
|
lsf.setNetwork(netData);
|
||||||
|
|
||||||
|
unsigned char type = lsf.getEncryptionType();
|
||||||
if (type != M17_ENCRYPTION_TYPE_NONE) {
|
if (type != M17_ENCRYPTION_TYPE_NONE) {
|
||||||
m_network->reset();
|
m_network->reset();
|
||||||
return;
|
return;
|
||||||
|
|||||||
@@ -40,6 +40,8 @@ m_lsf(NULL),
|
|||||||
m_valid(false)
|
m_valid(false)
|
||||||
{
|
{
|
||||||
m_lsf = new unsigned char[M17_LSF_LENGTH_BYTES];
|
m_lsf = new unsigned char[M17_LSF_LENGTH_BYTES];
|
||||||
|
|
||||||
|
::memset(m_lsf, 0x00U, M17_LSF_LENGTH_BYTES);
|
||||||
}
|
}
|
||||||
|
|
||||||
CM17LSF::~CM17LSF()
|
CM17LSF::~CM17LSF()
|
||||||
|
|||||||
@@ -105,7 +105,7 @@ bool CM17Network::write(const unsigned char* data)
|
|||||||
buffer[53U] = 0x00U;
|
buffer[53U] = 0x00U;
|
||||||
|
|
||||||
if (m_debug)
|
if (m_debug)
|
||||||
CUtils::dump(1U, "M17 data transmitted", buffer, 54U);
|
CUtils::dump(1U, "M17 Network Transmitted", buffer, 54U);
|
||||||
|
|
||||||
return m_socket.write(buffer, 54U, m_addr, m_addrLen);
|
return m_socket.write(buffer, 54U, m_addr, m_addrLen);
|
||||||
}
|
}
|
||||||
@@ -132,7 +132,7 @@ void CM17Network::clock(unsigned int ms)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (m_debug)
|
if (m_debug)
|
||||||
CUtils::dump(1U, "M17 Network Data Received", buffer, length);
|
CUtils::dump(1U, "M17 Network Received", buffer, length);
|
||||||
|
|
||||||
if (!m_enabled)
|
if (!m_enabled)
|
||||||
return;
|
return;
|
||||||
@@ -189,7 +189,9 @@ void CM17Network::reset()
|
|||||||
|
|
||||||
void CM17Network::enable(bool enabled)
|
void CM17Network::enable(bool enabled)
|
||||||
{
|
{
|
||||||
if (!enabled && m_enabled)
|
if (enabled && !m_enabled)
|
||||||
|
reset();
|
||||||
|
else if (!enabled && m_enabled)
|
||||||
m_buffer.clear();
|
m_buffer.clear();
|
||||||
|
|
||||||
m_enabled = enabled;
|
m_enabled = enabled;
|
||||||
@@ -210,7 +212,7 @@ void CM17Network::sendPing()
|
|||||||
buffer[3U] = 'G';
|
buffer[3U] = 'G';
|
||||||
|
|
||||||
if (m_debug)
|
if (m_debug)
|
||||||
CUtils::dump(1U, "M17 data transmitted", buffer, 4U);
|
CUtils::dump(1U, "M17 Network Transmitted", buffer, 4U);
|
||||||
|
|
||||||
m_socket.write(buffer, 4U, m_addr, m_addrLen);
|
m_socket.write(buffer, 4U, m_addr, m_addrLen);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user