fix bm connect issues

unstable
Tom Early 4 years ago
parent 284595cd74
commit 437f8fb17a

@ -332,7 +332,7 @@ void CBMProtocol::HandlePeerLinks(void)
// send connect packet to re-initiate peer link // send connect packet to re-initiate peer link
EncodeConnectPacket(&buffer, (*it).GetModules()); EncodeConnectPacket(&buffer, (*it).GetModules());
Send(buffer, (*it).GetIp(), XLX_PORT); Send(buffer, (*it).GetIp(), XLX_PORT);
std::cout << "Sending connect packet to XLX peer " << (*it).GetCallsign() << " @ " << (*it).GetIp() << " for modules " << (*it).GetModules() << std::endl; std::cout << "Sending connect packet to BM peer " << (*it).GetCallsign() << " @ " << (*it).GetIp() << " for modules " << (*it).GetModules() << std::endl;
} }
} }
@ -520,11 +520,11 @@ void CBMProtocol::EncodeConnectPacket(CBuffer *Buffer, const char *Modules)
Buffer->Set(tag, sizeof(tag)); Buffer->Set(tag, sizeof(tag));
// our callsign // our callsign
Buffer->resize(Buffer->size()+8); Buffer->resize(Buffer->size()+8);
g_Reflector.GetCallsign().GetCallsign(Buffer->data()+1); m_ReflectorCallsign.GetCallsign(Buffer->data()+1);
// our version // our version, fake it
Buffer->Append((uint8_t)VERSION_MAJOR); Buffer->Append((uint8_t)2);
Buffer->Append((uint8_t)VERSION_MINOR); Buffer->Append((uint8_t)4);
Buffer->Append((uint8_t)VERSION_REVISION); Buffer->Append((uint8_t)31);
// the modules we share // the modules we share
Buffer->Append(Modules); Buffer->Append(Modules);
Buffer->resize(39); Buffer->resize(39);
@ -538,7 +538,7 @@ void CBMProtocol::EncodeDisconnectPacket(CBuffer *Buffer)
Buffer->Set(tag, sizeof(tag)); Buffer->Set(tag, sizeof(tag));
// our callsign // our callsign
Buffer->resize(Buffer->size()+8); Buffer->resize(Buffer->size()+8);
g_Reflector.GetCallsign().GetCallsign(Buffer->data()+1); m_ReflectorCallsign.GetCallsign(Buffer->data()+1);
Buffer->Append((uint8_t)0); Buffer->Append((uint8_t)0);
} }
@ -550,11 +550,11 @@ void CBMProtocol::EncodeConnectAckPacket(CBuffer *Buffer, const char *Modules)
Buffer->Set(tag, sizeof(tag)); Buffer->Set(tag, sizeof(tag));
// our callsign // our callsign
Buffer->resize(Buffer->size()+8); Buffer->resize(Buffer->size()+8);
g_Reflector.GetCallsign().GetCallsign(Buffer->data()+1); m_ReflectorCallsign.GetCallsign(Buffer->data()+1);
// our version // our version, fake it
Buffer->Append((uint8_t)VERSION_MAJOR); Buffer->Append((uint8_t)2);
Buffer->Append((uint8_t)VERSION_MINOR); Buffer->Append((uint8_t)4);
Buffer->Append((uint8_t)VERSION_REVISION); Buffer->Append((uint8_t)31);
// the modules we share // the modules we share
Buffer->Append(Modules); Buffer->Append(Modules);
Buffer->resize(39); Buffer->resize(39);
@ -568,7 +568,7 @@ void CBMProtocol::EncodeConnectNackPacket(CBuffer *Buffer)
Buffer->Set(tag, sizeof(tag)); Buffer->Set(tag, sizeof(tag));
// our callsign // our callsign
Buffer->resize(Buffer->size()+8); Buffer->resize(Buffer->size()+8);
g_Reflector.GetCallsign().GetCallsign(Buffer->data()+1); m_ReflectorCallsign.GetCallsign(Buffer->data()+1);
Buffer->Append((uint8_t)0); Buffer->Append((uint8_t)0);
} }

@ -77,7 +77,7 @@
// protocols --------------------------------------------------- // protocols ---------------------------------------------------
#ifndef NO_G3 #ifndef NO_G3
enum class EProtocol { any, none, dextra, dplus, dcs, xlx, urf, dmrplus, dmrmmdvm, ysf, m17, g3 }; enum class EProtocol { any, none, dextra, dplus, dcs, bm, urf, dmrplus, dmrmmdvm, ysf, m17, g3 };
#else #else
enum class EProtocol { any, none, dextra, dplus, dcs, bm, urf, dmrplus, dmrmmdvm, ysf, m17 }; enum class EProtocol { any, none, dextra, dplus, dcs, bm, urf, dmrplus, dmrmmdvm, ysf, m17 };
#endif #endif

@ -63,7 +63,7 @@ bool CProtocols::Init(void)
return false; return false;
m_Protocols.emplace_back(std::unique_ptr<CBMProtocol>(new CBMProtocol)); m_Protocols.emplace_back(std::unique_ptr<CBMProtocol>(new CBMProtocol));
if (! m_Protocols.back()->Initialize(nullptr, EProtocol::bm, XLX_PORT, DMR_IPV4, DMR_IPV6)) if (! m_Protocols.back()->Initialize("XLX", EProtocol::bm, XLX_PORT, DMR_IPV4, DMR_IPV6))
return false; return false;
m_Protocols.emplace_back(std::unique_ptr<CDmrplusProtocol>(new CDmrplusProtocol)); m_Protocols.emplace_back(std::unique_ptr<CDmrplusProtocol>(new CDmrplusProtocol));

Loading…
Cancel
Save

Powered by TurnKey Linux.