|
|
|
@ -88,18 +88,11 @@ void CURFProtocol::Task(void)
|
|
|
|
// acknowledge connecting request
|
|
|
|
// acknowledge connecting request
|
|
|
|
// following is version dependent
|
|
|
|
// following is version dependent
|
|
|
|
if (EProtoRev::original == CURFPeer::GetProtocolRevision(Version))
|
|
|
|
if (EProtoRev::original == CURFPeer::GetProtocolRevision(Version))
|
|
|
|
{
|
|
|
|
|
|
|
|
// already connected ?
|
|
|
|
|
|
|
|
CPeers *peers = g_Reflector.GetPeers();
|
|
|
|
|
|
|
|
if ( peers->FindPeer(Callsign, Ip, EProtocol::urf) == nullptr )
|
|
|
|
|
|
|
|
{
|
|
|
|
{
|
|
|
|
// acknowledge the request
|
|
|
|
// acknowledge the request
|
|
|
|
EncodeConnectAckPacket(&Buffer, Modules);
|
|
|
|
EncodeConnectAckPacket(&Buffer, Modules);
|
|
|
|
Send(Buffer, Ip);
|
|
|
|
Send(Buffer, Ip);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
g_Reflector.ReleasePeers();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
else
|
|
|
|
else
|
|
|
|
{
|
|
|
|
{
|
|
|
|
EncodeConnectNackPacket(&Buffer);
|
|
|
|
EncodeConnectNackPacket(&Buffer);
|
|
|
|
|