b3feddfef3
* try to resolve merge conflict
* feat: TU19 (Dec 2014) Features & Content (#32)
* December 2014 files
* Working release build
* Fix compilation issues
* Add sound to Windows64Media
* Add DLC content and force Tutorial DLC
* Revert "Add DLC content and force Tutorial DLC"
This reverts commit 97a4399472.
* Disable broken light packing
* Disable breakpoint during DLC texture map load
Allows DLC loading but the DLC textures are still broken
* Fix post build not working
* ...
* fix vs2022 build
* fix cmake build
---------
Co-authored-by: Loki <lokirautio@gmail.com>
83 lines
1.8 KiB
C++
83 lines
1.8 KiB
C++
#include "stdafx.h"
|
|
|
|
#include "SQRNetworkManager.h"
|
|
|
|
bool SQRNetworkManager::s_safeToRespondToGameBootInvite = false;
|
|
|
|
void SQRNetworkManager::SafeToRespondToGameBootInvite()
|
|
{
|
|
s_safeToRespondToGameBootInvite = true;
|
|
}
|
|
|
|
int SQRNetworkManager::GetSendQueueSizeBytes()
|
|
{
|
|
int queueSize = 0;
|
|
int playerCount = GetPlayerCount();
|
|
for(int i = 0; i < playerCount; ++i)
|
|
{
|
|
SQRNetworkPlayer *player = GetPlayerByIndex( i );
|
|
if( player != NULL )
|
|
{
|
|
queueSize += player->GetTotalSendQueueBytes();
|
|
}
|
|
}
|
|
return queueSize;
|
|
}
|
|
|
|
int SQRNetworkManager::GetSendQueueSizeMessages()
|
|
{
|
|
int queueSize = 0;
|
|
int playerCount = GetPlayerCount();
|
|
for(int i = 0; i < playerCount; ++i)
|
|
{
|
|
SQRNetworkPlayer *player = GetPlayerByIndex( i );
|
|
if( player != NULL )
|
|
{
|
|
queueSize += player->GetTotalSendQueueMessages();
|
|
}
|
|
}
|
|
return queueSize;
|
|
}
|
|
|
|
int SQRNetworkManager::GetOutstandingAckCount(SQRNetworkPlayer *pSQRPlayer)
|
|
{
|
|
int ackCount = 0;
|
|
int playerCount = GetPlayerCount();
|
|
for(int i = 0; i < playerCount; ++i)
|
|
{
|
|
SQRNetworkPlayer *pSQRPlayer2 = GetPlayerByIndex( i );
|
|
if( pSQRPlayer2 )
|
|
{
|
|
if( ( pSQRPlayer == pSQRPlayer2 ) || (pSQRPlayer->IsSameSystem(pSQRPlayer2) ) )
|
|
{
|
|
ackCount += pSQRPlayer2->m_acksOutstanding;
|
|
}
|
|
}
|
|
}
|
|
return ackCount;
|
|
}
|
|
|
|
void SQRNetworkManager::RequestWriteAck(int smallId)
|
|
{
|
|
EnterCriticalSection(&m_csAckQueue);
|
|
m_queuedAckRequests.push(smallId);
|
|
LeaveCriticalSection(&m_csAckQueue);
|
|
}
|
|
|
|
void SQRNetworkManager::TickWriteAcks()
|
|
{
|
|
EnterCriticalSection(&m_csAckQueue);
|
|
while(m_queuedAckRequests.size() > 0)
|
|
{
|
|
int smallId = m_queuedAckRequests.front();
|
|
m_queuedAckRequests.pop();
|
|
SQRNetworkPlayer *player = GetPlayerBySmallId(smallId);
|
|
if( player )
|
|
{
|
|
LeaveCriticalSection(&m_csAckQueue);
|
|
player->WriteAck();
|
|
EnterCriticalSection(&m_csAckQueue);
|
|
}
|
|
}
|
|
LeaveCriticalSection(&m_csAckQueue);
|
|
} |