ShaYmez/xlxd
1
0
Fork 0
mirror of https://github.com/ShaYmez/xlxd.git synced 2025-08-19 21:02:25 -04:00
Code Issues Projects Releases Wiki Activity

Update cdextraprotocol.cpp

Browse Source
This commit is contained in:
narspt 2021-04-14 01:55:26 +01:00 committed by GitHub
parent d01bed9bd9
commit e6a5c7aed1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 31 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/cdextraprotocol.cpp
View File

@ -119,6 +119,27 @@ void CDextraProtocol::Task(void)
EncodeConnectAckPacket(&Buffer, ProtRev); EncodeConnectAckPacket(&Buffer, ProtRev);
m_Socket.Send(Buffer, Ip); m_Socket.Send(Buffer, Ip);
// check if any client currently streaming on the module
CClients *clients = g_Reflector.GetClients();
for ( int i = 0; i < clients->GetSize(); i++ )
{
if ( clients->GetClient(i)->IsAMaster() && (clients->GetClient(i)->GetReflectorModule() == ToLinkModule) )
{
// found a client streaming on the module, encode a copy of the cached header packet
CBuffer buffer2;
if ( EncodeDvPacket(m_StreamsCache[g_Reflector.GetModuleIndex(ToLinkModule)].m_dvHeader, &buffer2) )
{
// and send it to the connecting client, so it can listen the already streaming client
for ( int j = 0; j < 5; j++ )
{
m_Socket.Send(buffer2, Ip);
}
}
break; // done, stop here
}
}
g_Reflector.ReleaseClients();
// create the client // create the client
CDextraClient *client = new CDextraClient(Callsign, Ip, ToLinkModule, ProtRev); CDextraClient *client = new CDextraClient(Callsign, Ip, ToLinkModule, ProtRev);
@ -216,6 +237,16 @@ void CDextraProtocol::HandleQueue(void)
CPacket *packet = m_Queue.front(); CPacket *packet = m_Queue.front();
m_Queue.pop(); m_Queue.pop();
// get our sender's id
int iModId = g_Reflector.GetModuleIndex(packet->GetModuleId());
// check if it's header and update cache
if ( packet->IsDvHeader() )
{
// this relies on queue feeder setting valid module id
m_StreamsCache[iModId].m_dvHeader = CDvHeaderPacket((const CDvHeaderPacket &)*packet);
}
// encode it // encode it
CBuffer buffer; CBuffer buffer;
if ( EncodeDvPacket(*packet, &buffer) ) if ( EncodeDvPacket(*packet, &buffer) )