Skip to content

Commit 4e513ce

Browse files
softinssoftins
committed
Add handling of CL msgs for Server and client list
1 parent 3513a6e commit 4e513ce

File tree

13 files changed

+96
-54
lines changed

13 files changed

+96
-54
lines changed

‎src/channel.h‎

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,9 @@ class CChannel : public QObject
8686
void SetAddress ( const CHostAddress& NAddr ) { InetAddr = NAddr; }
8787
const CHostAddress& GetAddress() const { return InetAddr; }
8888

89+
void SetTcpConnection ( CTcpConnection* pConnection ) { pTcpConnection = pConnection; }
90+
CTcpConnection* GetTcpConnection() { return pTcpConnection; }
91+
8992
void ResetInfo()
9093
{
9194
bIsIdentified = false;
@@ -186,7 +189,8 @@ class CChannel : public QObject
186189
}
187190

188191
// connection parameters
189-
CHostAddress InetAddr;
192+
CHostAddress InetAddr;
193+
CTcpConnection* pTcpConnection;
190194

191195
// channel info
192196
CChannelCoreInfo ChannelInfo;
@@ -255,9 +259,9 @@ public slots:
255259
PutProtocolData ( iRecCounter, iRecID, vecbyMesBodyData, RecHostAddr );
256260
}
257261

258-
void OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr )
262+
void OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection )
259263
{
260-
emit DetectedCLMessage ( vecbyMesBodyData, iRecID, RecHostAddr );
264+
emit DetectedCLMessage ( vecbyMesBodyData, iRecID, RecHostAddr, pTcpConnection );
261265
}
262266

263267
void OnNewConnection() { emit NewConnection(); }
@@ -282,7 +286,7 @@ public slots:
282286
void RecorderStateReceived ( ERecorderState eRecorderState );
283287
void Disconnected();
284288

285-
void DetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr );
289+
void DetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection );
286290

287291
void ParseMessageBody ( CVector<uint8_t> vecbyMesBodyData, int iRecCounter, int iRecID );
288292
};

‎src/client.cpp‎

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -249,11 +249,19 @@ void CClient::OnSendProtMessage ( CVector<uint8_t> vecMessage )
249249
Socket.SendPacket ( vecMessage, Channel.GetAddress() );
250250
}
251251

252-
void CClient::OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage )
252+
void CClient::OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage, CTcpConnection* pTcpConnection )
253253
{
254254
// the protocol queries me to call the function to send the message
255255
// send it through the network
256-
Socket.SendPacket ( vecMessage, InetAddr );
256+
if ( pTcpConnection )
257+
{
258+
// send to the connected socket directly
259+
pTcpConnection->pTcpSocket->write ( (const char*) &( (CVector<uint8_t>) vecMessage )[0], vecMessage.Size() );
260+
}
261+
else
262+
{
263+
Socket.SendPacket ( vecMessage, InetAddr );
264+
}
257265
}
258266

259267
void CClient::OnInvalidPacketReceived ( CHostAddress RecHostAddr )
@@ -268,10 +276,10 @@ void CClient::OnInvalidPacketReceived ( CHostAddress RecHostAddr )
268276
}
269277
}
270278

271-
void CClient::OnDetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr )
279+
void CClient::OnDetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection )
272280
{
273281
// connection less messages are always processed
274-
ConnLessProtocol.ParseConnectionLessMessageBody ( vecbyMesBodyData, iRecID, RecHostAddr );
282+
ConnLessProtocol.ParseConnectionLessMessageBody ( vecbyMesBodyData, iRecID, RecHostAddr, pTcpConnection );
275283
}
276284

277285
void CClient::OnJittBufSizeChanged ( int iNewJitBufSize )

‎src/client.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -427,7 +427,7 @@ protected slots:
427427
void OnSendProtMessage ( CVector<uint8_t> vecMessage );
428428
void OnInvalidPacketReceived ( CHostAddress RecHostAddr );
429429

430-
void OnDetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr );
430+
void OnDetectedCLMessage ( CVector<uint8_t> vecbyMesBodyData, int iRecID, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection );
431431

432432
void OnReqJittBufSize() { CreateServerJitterBufferMessage(); }
433433
void OnJittBufSizeChanged ( int iNewJitBufSize );
@@ -442,7 +442,7 @@ protected slots:
442442
}
443443
void OnCLPingReceived ( CHostAddress InetAddr, int iMs );
444444

445-
void OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage );
445+
void OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage, CTcpConnection* pTcpConnection );
446446

447447
void OnCLPingWithNumClientsReceived ( CHostAddress InetAddr, int iMs, int iNumClients );
448448

‎src/protocol.cpp‎

Lines changed: 19 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -605,7 +605,10 @@ void CProtocol::CreateAndImmSendAcknMess ( const int& iID, const int& iCnt )
605605
emit MessReadyForSending ( vecAcknMessage );
606606
}
607607

608-
void CProtocol::CreateAndImmSendConLessMessage ( const int iID, const CVector<uint8_t>& vecData, const CHostAddress& InetAddr )
608+
void CProtocol::CreateAndImmSendConLessMessage ( const int iID,
609+
const CVector<uint8_t>& vecData,
610+
const CHostAddress& InetAddr,
611+
CTcpConnection* pTcpConnection )
609612
{
610613
CVector<uint8_t> vecNewMessage;
611614

@@ -614,7 +617,7 @@ void CProtocol::CreateAndImmSendConLessMessage ( const int iID, const CVector<ui
614617
GenMessageFrame ( vecNewMessage, 0, iID, vecData );
615618

616619
// immediately send message
617-
emit CLMessReadyForSending ( InetAddr, vecNewMessage );
620+
emit CLMessReadyForSending ( InetAddr, vecNewMessage, pTcpConnection );
618621
}
619622

620623
void CProtocol::ParseMessageBody ( const CVector<uint8_t>& vecbyMesBodyData, const int iRecCounter, const int iRecID )
@@ -838,7 +841,10 @@ void CProtocol::ParseMessageBody ( const CVector<uint8_t>& vecbyMesBodyData, con
838841
}
839842
}
840843

841-
void CProtocol::ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMesBodyData, const int iRecID, const CHostAddress& InetAddr )
844+
void CProtocol::ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMesBodyData,
845+
const int iRecID,
846+
const CHostAddress& InetAddr,
847+
CTcpConnection* pTcpConnection )
842848
{
843849
//### TEST: BEGIN ###//
844850
// Test channel implementation: randomly delete protocol messages (50 % loss)
@@ -870,7 +876,7 @@ void CProtocol::ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMe
870876
break;
871877

872878
case PROTMESSID_CLM_REQ_SERVER_LIST:
873-
EvaluateCLReqServerListMes ( InetAddr );
879+
EvaluateCLReqServerListMes ( InetAddr, pTcpConnection );
874880
break;
875881

876882
case PROTMESSID_CLM_SEND_EMPTY_MESSAGE:
@@ -906,7 +912,7 @@ void CProtocol::ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMe
906912
break;
907913

908914
case PROTMESSID_CLM_REQ_CONN_CLIENTS_LIST:
909-
EvaluateCLReqConnClientsListMes ( InetAddr );
915+
EvaluateCLReqConnClientsListMes ( InetAddr, pTcpConnection );
910916
break;
911917

912918
case PROTMESSID_CLM_CHANNEL_LEVEL_LIST:
@@ -2005,7 +2011,7 @@ bool CProtocol::EvaluateCLUnregisterServerMes ( const CHostAddress& InetAddr )
20052011
return false; // no error
20062012
}
20072013

2008-
void CProtocol::CreateCLServerListMes ( const CHostAddress& InetAddr, const CVector<CServerInfo> vecServerInfo )
2014+
void CProtocol::CreateCLServerListMes ( const CHostAddress& InetAddr, const CVector<CServerInfo> vecServerInfo, CTcpConnection* pTcpConnection )
20092015
{
20102016
const int iNumServers = vecServerInfo.Size();
20112017

@@ -2060,7 +2066,7 @@ void CProtocol::CreateCLServerListMes ( const CHostAddress& InetAddr, const CVec
20602066
PutStringUTF8OnStream ( vecData, iPos, strUTF8City );
20612067
}
20622068

2063-
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_SERVER_LIST, vecData, InetAddr );
2069+
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_SERVER_LIST, vecData, InetAddr, pTcpConnection );
20642070
}
20652071

20662072
bool CProtocol::EvaluateCLServerListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData )
@@ -2225,10 +2231,10 @@ void CProtocol::CreateCLReqServerListMes ( const CHostAddress& InetAddr )
22252231
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_REQ_SERVER_LIST, CVector<uint8_t> ( 0 ), InetAddr );
22262232
}
22272233

2228-
bool CProtocol::EvaluateCLReqServerListMes ( const CHostAddress& InetAddr )
2234+
bool CProtocol::EvaluateCLReqServerListMes ( const CHostAddress& InetAddr, CTcpConnection* pTcpConnection )
22292235
{
22302236
// invoke message action
2231-
emit CLReqServerList ( InetAddr );
2237+
emit CLReqServerList ( InetAddr, pTcpConnection );
22322238

22332239
return false; // no error
22342240
}
@@ -2363,7 +2369,7 @@ bool CProtocol::EvaluateCLReqVersionAndOSMes ( const CHostAddress& InetAddr )
23632369
return false; // no error
23642370
}
23652371

2366-
void CProtocol::CreateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<CChannelInfo>& vecChanInfo )
2372+
void CProtocol::CreateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<CChannelInfo>& vecChanInfo, CTcpConnection* pTcpConnection )
23672373
{
23682374
const int iNumClients = vecChanInfo.Size();
23692375

@@ -2411,7 +2417,7 @@ void CProtocol::CreateCLConnClientsListMes ( const CHostAddress& InetAddr, const
24112417
PutStringUTF8OnStream ( vecData, iPos, strUTF8City );
24122418
}
24132419

2414-
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_CONN_CLIENTS_LIST, vecData, InetAddr );
2420+
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_CONN_CLIENTS_LIST, vecData, InetAddr, pTcpConnection );
24152421
}
24162422

24172423
bool CProtocol::EvaluateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData )
@@ -2478,10 +2484,10 @@ void CProtocol::CreateCLReqConnClientsListMes ( const CHostAddress& InetAddr )
24782484
CreateAndImmSendConLessMessage ( PROTMESSID_CLM_REQ_CONN_CLIENTS_LIST, CVector<uint8_t> ( 0 ), InetAddr );
24792485
}
24802486

2481-
bool CProtocol::EvaluateCLReqConnClientsListMes ( const CHostAddress& InetAddr )
2487+
bool CProtocol::EvaluateCLReqConnClientsListMes ( const CHostAddress& InetAddr, CTcpConnection* pTcpConnection )
24822488
{
24832489
// invoke message action
2484-
emit CLReqConnClientsList ( InetAddr );
2490+
emit CLReqConnClientsList ( InetAddr, pTcpConnection );
24852491

24862492
return false; // no error
24872493
}

‎src/protocol.h‎

Lines changed: 16 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
#include <cmath>
3232
#include "global.h"
3333
#include "util.h"
34+
#include "tcpserver.h"
3435

3536
/* Definitions ****************************************************************/
3637
// protocol message IDs
@@ -141,15 +142,15 @@ class CProtocol : public QObject
141142
void CreateCLRegisterServerMes ( const CHostAddress& InetAddr, const CHostAddress& LInetAddr, const CServerCoreInfo& ServerInfo );
142143
void CreateCLRegisterServerExMes ( const CHostAddress& InetAddr, const CHostAddress& LInetAddr, const CServerCoreInfo& ServerInfo );
143144
void CreateCLUnregisterServerMes ( const CHostAddress& InetAddr );
144-
void CreateCLServerListMes ( const CHostAddress& InetAddr, const CVector<CServerInfo> vecServerInfo );
145+
void CreateCLServerListMes ( const CHostAddress& InetAddr, const CVector<CServerInfo> vecServerInfo, CTcpConnection* pTcpConnection );
145146
void CreateCLRedServerListMes ( const CHostAddress& InetAddr, const CVector<CServerInfo> vecServerInfo );
146147
void CreateCLReqServerListMes ( const CHostAddress& InetAddr );
147148
void CreateCLSendEmptyMesMes ( const CHostAddress& InetAddr, const CHostAddress& TargetInetAddr );
148149
void CreateCLEmptyMes ( const CHostAddress& InetAddr );
149150
void CreateCLDisconnection ( const CHostAddress& InetAddr );
150151
void CreateCLVersionAndOSMes ( const CHostAddress& InetAddr );
151152
void CreateCLReqVersionAndOSMes ( const CHostAddress& InetAddr );
152-
void CreateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<CChannelInfo>& vecChanInfo );
153+
void CreateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<CChannelInfo>& vecChanInfo, CTcpConnection* pTcpConnection );
153154
void CreateCLReqConnClientsListMes ( const CHostAddress& InetAddr );
154155
void CreateCLChannelLevelListMes ( const CHostAddress& InetAddr, const CVector<uint16_t>& vecLevelList, const int iNumClients );
155156
void CreateCLRegisterServerResp ( const CHostAddress& InetAddr, const ESvrRegResult eResult );
@@ -164,7 +165,10 @@ class CProtocol : public QObject
164165

165166
void ParseMessageBody ( const CVector<uint8_t>& vecbyMesBodyData, const int iRecCounter, const int iRecID );
166167

167-
void ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMesBodyData, const int iRecID, const CHostAddress& InetAddr );
168+
void ParseConnectionLessMessageBody ( const CVector<uint8_t>& vecbyMesBodyData,
169+
const int iRecID,
170+
const CHostAddress& InetAddr,
171+
CTcpConnection* pTcpConnection );
168172

169173
static bool IsConnectionLessMessageID ( const int iID ) { return ( iID >= 1000 ) && ( iID < 2000 ); }
170174

@@ -243,7 +247,10 @@ class CProtocol : public QObject
243247

244248
void CreateAndSendMessage ( const int iID, const CVector<uint8_t>& vecData );
245249

246-
void CreateAndImmSendConLessMessage ( const int iID, const CVector<uint8_t>& vecData, const CHostAddress& InetAddr );
250+
void CreateAndImmSendConLessMessage ( const int iID,
251+
const CVector<uint8_t>& vecData,
252+
const CHostAddress& InetAddr,
253+
CTcpConnection* pTcpConnection = nullptr );
247254

248255
bool EvaluateJitBufMes ( const CVector<uint8_t>& vecData );
249256
bool EvaluateReqJitBufMes();
@@ -272,13 +279,13 @@ class CProtocol : public QObject
272279
bool EvaluateCLUnregisterServerMes ( const CHostAddress& InetAddr );
273280
bool EvaluateCLServerListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
274281
bool EvaluateCLRedServerListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
275-
bool EvaluateCLReqServerListMes ( const CHostAddress& InetAddr );
282+
bool EvaluateCLReqServerListMes ( const CHostAddress& InetAddr, CTcpConnection* pTcpConnection );
276283
bool EvaluateCLSendEmptyMesMes ( const CVector<uint8_t>& vecData );
277284
bool EvaluateCLDisconnectionMes ( const CHostAddress& InetAddr );
278285
bool EvaluateCLVersionAndOSMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
279286
bool EvaluateCLReqVersionAndOSMes ( const CHostAddress& InetAddr );
280287
bool EvaluateCLConnClientsListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
281-
bool EvaluateCLReqConnClientsListMes ( const CHostAddress& InetAddr );
288+
bool EvaluateCLReqConnClientsListMes ( const CHostAddress& InetAddr, CTcpConnection* pTcpConnection );
282289
bool EvaluateCLChannelLevelListMes ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
283290
bool EvaluateCLRegisterServerResp ( const CHostAddress& InetAddr, const CVector<uint8_t>& vecData );
284291

@@ -303,7 +310,7 @@ public slots:
303310
signals:
304311
// transmitting
305312
void MessReadyForSending ( CVector<uint8_t> vecMessage );
306-
void CLMessReadyForSending ( CHostAddress InetAddr, CVector<uint8_t> vecMessage );
313+
void CLMessReadyForSending ( CHostAddress InetAddr, CVector<uint8_t> vecMessage, CTcpConnection* pTcpConnection );
307314

308315
// receiving
309316
void ChangeJittBufSize ( int iNewJitBufSize );
@@ -338,13 +345,13 @@ public slots:
338345
void CLUnregisterServerReceived ( CHostAddress InetAddr );
339346
void CLServerListReceived ( CHostAddress InetAddr, CVector<CServerInfo> vecServerInfo );
340347
void CLRedServerListReceived ( CHostAddress InetAddr, CVector<CServerInfo> vecServerInfo );
341-
void CLReqServerList ( CHostAddress InetAddr );
348+
void CLReqServerList ( CHostAddress InetAddr, CTcpConnection* pTcpConnection );
342349
void CLSendEmptyMes ( CHostAddress TargetInetAddr );
343350
void CLDisconnection ( CHostAddress InetAddr );
344351
void CLVersionAndOSReceived ( CHostAddress InetAddr, COSUtil::EOpSystemType eOSType, QString strVersion );
345352
void CLReqVersionAndOS ( CHostAddress InetAddr );
346353
void CLConnClientsListMesReceived ( CHostAddress InetAddr, CVector<CChannelInfo> vecChanInfo );
347-
void CLReqConnClientsList ( CHostAddress InetAddr );
354+
void CLReqConnClientsList ( CHostAddress InetAddr, CTcpConnection* pTcpConnection );
348355
void CLChannelLevelListReceived ( CHostAddress InetAddr, CVector<uint16_t> vecLevelList );
349356
void CLRegisterServerResp ( CHostAddress InetAddr, ESvrRegResult eStatus );
350357
};

‎src/server.cpp‎

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -468,11 +468,19 @@ void CServer::OnServerFull ( CHostAddress RecHostAddr )
468468
ConnLessProtocol.CreateCLServerFullMes ( RecHostAddr );
469469
}
470470

471-
void CServer::OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage )
471+
void CServer::OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage, CTcpConnection* pTcpConnection )
472472
{
473473
// the protocol queries me to call the function to send the message
474474
// send it through the network
475-
Socket.SendPacket ( vecMessage, InetAddr );
475+
if ( pTcpConnection )
476+
{
477+
// send to the connected socket directly
478+
pTcpConnection->pTcpSocket->write ( (const char*) &( (CVector<uint8_t>) vecMessage )[0], vecMessage.Size() );
479+
}
480+
else
481+
{
482+
Socket.SendPacket ( vecMessage, InetAddr );
483+
}
476484
}
477485

478486
void CServer::OnCLDisconnection ( CHostAddress InetAddr )
@@ -1429,12 +1437,12 @@ void CServer::DumpChannels ( const QString& title )
14291437
}
14301438
}
14311439

1432-
void CServer::OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr )
1440+
void CServer::OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection )
14331441
{
14341442
QMutexLocker locker ( &Mutex );
14351443

14361444
// connection less messages are always processed
1437-
ConnLessProtocol.ParseConnectionLessMessageBody ( vecbyMesBodyData, iRecID, RecHostAddr );
1445+
ConnLessProtocol.ParseConnectionLessMessageBody ( vecbyMesBodyData, iRecID, RecHostAddr, pTcpConnection );
14381446
}
14391447

14401448
void CServer::OnProtocolMessageReceived ( int iRecCounter, int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr )

‎src/server.h‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -340,9 +340,9 @@ public slots:
340340

341341
void OnServerFull ( CHostAddress RecHostAddr );
342342

343-
void OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage );
343+
void OnSendCLProtMessage ( CHostAddress InetAddr, CVector<uint8_t> vecMessage, CTcpConnection* pTcpConnection );
344344

345-
void OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr );
345+
void OnProtocolCLMessageReceived ( int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr, CTcpConnection* pTcpConnection );
346346

347347
void OnProtocolMessageReceived ( int iRecCounter, int iRecID, CVector<uint8_t> vecbyMesBodyData, CHostAddress RecHostAddr );
348348

@@ -362,11 +362,14 @@ public slots:
362362
}
363363
}
364364

365-
void OnCLReqServerList ( CHostAddress InetAddr ) { ServerListManager.RetrieveAll ( InetAddr ); }
365+
void OnCLReqServerList ( CHostAddress InetAddr, CTcpConnection* pTcpConnection ) { ServerListManager.RetrieveAll ( InetAddr, pTcpConnection ); }
366366

367367
void OnCLReqVersionAndOS ( CHostAddress InetAddr ) { ConnLessProtocol.CreateCLVersionAndOSMes ( InetAddr ); }
368368

369-
void OnCLReqConnClientsList ( CHostAddress InetAddr ) { ConnLessProtocol.CreateCLConnClientsListMes ( InetAddr, CreateChannelList() ); }
369+
void OnCLReqConnClientsList ( CHostAddress InetAddr, CTcpConnection* pTcpConnection )
370+
{
371+
ConnLessProtocol.CreateCLConnClientsListMes ( InetAddr, CreateChannelList(), pTcpConnection );
372+
}
370373

371374
void OnCLRegisterServerReceived ( CHostAddress InetAddr, CHostAddress LInetAddr, CServerCoreInfo ServerInfo )
372375
{

0 commit comments

Comments
 (0)