Differential D120 Diff 881 ps/trunk/source/network/NetServer.cpp

Changeset View

Standalone View

ps/trunk/source/network/NetServer.cpp

Show First 20 Lines • Show All 1,172 Lines • ▼ Show 20 Lines	bool CNetServerWorker::OnStartGame(void* context, CFsmEvent* event)

return true;		return true;
}		}

bool CNetServerWorker::OnLoadedGame(void* context, CFsmEvent* event)		bool CNetServerWorker::OnLoadedGame(void* context, CFsmEvent* event)
{		{
ENSURE(event->GetType() == (uint)NMT_LOADED_GAME);		ENSURE(event->GetType() == (uint)NMT_LOADED_GAME);

CNetServerSession* session = (CNetServerSession*)context;		CNetServerSession* loadedSession = (CNetServerSession*)context;
CNetServerWorker& server = session->GetServer();		CNetServerWorker& server = loadedSession->GetServer();

// We're in the loading state, so wait until every player has loaded before		// We're in the loading state, so wait until every client has loaded
// starting the game		// before starting the game
ENSURE(server.m_State == SERVER_STATE_LOADING);		ENSURE(server.m_State == SERVER_STATE_LOADING);
server.CheckGameLoadStatus(session);		if (server.CheckGameLoadStatus(loadedSession))
		return true;

		CClientsLoadingMessage message;
		// We always send all GUIDs of clients in the loading state
		// so that we don't have to bother about switching GUI pages
		for (CNetServerSession* session : server.m_Sessions)
		if (session->GetCurrState() != NSS_INGAME && loadedSession->GetGUID() != session->GetGUID())
		{
		CClientsLoadingMessage::S_m_Clients client;
		client.m_GUID = session->GetGUID();
		message.m_Clients.push_back(client);
		}

		// Send to the client who has loaded the game but did not reach the NSS_INGAME state yet
		loadedSession->SendMessage(&message);
		server.Broadcast(&message, { NSS_INGAME });

return true;		return true;
}		}

bool CNetServerWorker::OnJoinSyncingLoadedGame(void* context, CFsmEvent* event)		bool CNetServerWorker::OnJoinSyncingLoadedGame(void* context, CFsmEvent* event)
{		{
// A client rejoining an in-progress game has now finished loading the		// A client rejoining an in-progress game has now finished loading the
// map and deserialized the initial state.		// map and deserialized the initial state.
▲ Show 20 Lines • Show All 130 Lines • ▼ Show 20 Lines	bool CNetServerWorker::OnClientPaused(void* context, CFsmEvent* event)
{		{
if (session->GetCurrState() == NSS_INGAME && message->m_GUID != session->GetGUID())		if (session->GetCurrState() == NSS_INGAME && message->m_GUID != session->GetGUID())
session->SendMessage(message);		session->SendMessage(message);
}		}

return true;		return true;
}		}

void CNetServerWorker::CheckGameLoadStatus(CNetServerSession* changedSession)		bool CNetServerWorker::CheckGameLoadStatus(CNetServerSession* changedSession)
{		{
for (const CNetServerSession* session : m_Sessions)		for (const CNetServerSession* session : m_Sessions)
if (session != changedSession && session->GetCurrState() != NSS_INGAME)		if (session != changedSession && session->GetCurrState() != NSS_INGAME)
return;		return false;

// Inform clients that everyone has loaded the map and that the game can start		// Inform clients that everyone has loaded the map and that the game can start
CLoadedGameMessage loaded;		CLoadedGameMessage loaded;
loaded.m_CurrentTurn = 0;		loaded.m_CurrentTurn = 0;

// Notice the changedSession is still in the NSS_PREGAME state		// Notice the changedSession is still in the NSS_PREGAME state
Broadcast(&loaded, { NSS_PREGAME, NSS_INGAME });		Broadcast(&loaded, { NSS_PREGAME, NSS_INGAME });

m_State = SERVER_STATE_INGAME;		m_State = SERVER_STATE_INGAME;
		return true;
}		}

void CNetServerWorker::StartGame()		void CNetServerWorker::StartGame()
{		{
m_ServerTurnManager = new CNetServerTurnManager(*this);		m_ServerTurnManager = new CNetServerTurnManager(*this);

for (const CNetServerSession* session : m_Sessions)		for (const CNetServerSession* session : m_Sessions)
m_ServerTurnManager->InitialiseClient(session->GetHostID(), 0); // TODO: only for non-observers		m_ServerTurnManager->InitialiseClient(session->GetHostID(), 0); // TODO: only for non-observers
▲ Show 20 Lines • Show All 117 Lines • Show Last 20 Lines