ilikecats/stk-code_catmod
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

debug info in synchronization protocol

Browse Source 
git-svn-id: svn+ssh://svn.code.sf.net/p/supertuxkart/code/main/branches/hilnius@13211 178a84e3-b1eb-0310-8ba1-8eac791a3b58
This commit is contained in:
hilnius 2013-07-13 23:35:34 +00:00
parent e002d4f1bd
commit 8a2f6a9888
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/network/protocols/synchronization_protocol.cpp
View File

@ -58,12 +58,13 @@ void SynchronizationProtocol::notifyEvent(Event* event)
NetworkString response;
response.ai8(event->data.gui8(talk_id)).ai32(token).ai8(0).ai32(sequence);
m_listener->sendMessage(this, peers[talk_id], response, false);
Log::info("SynchronizationProtocol", "Answering sequence %u", sequence);
}
else // response
{
if (sequence < m_pings[peer_id].size())
{
Log::warn("SynchronizationProtocol", "The sequence isn't known.");
Log::warn("SynchronizationProtocol", "The sequence# %u isn't known.", sequence);
return;
}
m_pings[peer_id][sequence].second = Time::getRealTime();
@ -89,13 +90,14 @@ void SynchronizationProtocol::setup()
void SynchronizationProtocol::update()
{
static double timer = Time::getRealTime();
if (Time::getRealTime() > timer+0.1 && m_pings_count < 100) // max 100 pings (10 seconds)
if (Time::getRealTime() > timer+2.0 && m_pings_count < 100) // max 100 pings (10 seconds)
{
std::vector<STKPeer*> peers = NetworkManager::getInstance()->getPeers();
for (unsigned int i = 0; i < peers.size(); i++)
{
NetworkString ns;
ns.ai8(i).addUInt32(peers[i]->getClientServerToken()).addUInt8(1).addUInt32(m_pings[i].size());
Log::info("SynchronizationProtocol", "Added sequence number %u", m_pings[i].size());
timer = Time::getRealTime();
m_pings[i].push_back(std::pair<double, double>(timer, 0.0));
m_listener->sendMessage(this, peers[i], ns, false);