Mesen/Core/GameClient.cpp

#include "stdafx.h"
#include <thread>
using std::thread;

#include "MessageManager.h"
#include "GameClient.h"
#include "Console.h"
#include "../Utilities/Socket.h"
#include "ClientConnectionData.h"

unique_ptr<GameClient> GameClient::Instance;

GameClient::GameClient()
{
	MessageManager::RegisterNotificationListener(this);
}

GameClient::~GameClient()
{
	_stop = true;
	_clientThread->join();
	MessageManager::UnregisterNotificationListener(this);
}

bool GameClient::Connected()
{
	if(Instance) {
		return Instance->_connected;
	} else {
		return false;
	}
}

void GameClient::Connect(shared_ptr<ClientConnectionData> connectionData)
{
	Instance.reset(new GameClient());
	Instance->PrivateConnect(connectionData);
	Instance->_clientThread.reset(new thread(&GameClient::Exec, Instance.get()));
}

void GameClient::Disconnect()
{
	Instance.reset();
}

void GameClient::PrivateConnect(shared_ptr<ClientConnectionData> connectionData)
{
	_stop = false;
	_socket.reset(new Socket());
	if(_socket->Connect(connectionData->Host.c_str(), connectionData->Port)) {
		_connection.reset(new GameClientConnection(_socket, connectionData));
		_connected = true;
	} else {
		MessageManager::DisplayMessage("Net Play", "Could not connect to server.");
		_connected = false;
		_socket.reset();
	}
}

void GameClient::PrivateDisconnect()
{
	if(_connected) {
		_connected = false;
		_socket.reset();
		_connection.reset();
	}
}

void GameClient::Exec()
{
	if(_connected) {
		while(!_stop) {
			if(!_connection->ConnectionError()) {
				_connection->ProcessMessages();
				_connection->SendInput();
			} else {
				_connected = false;
				_socket.reset();
				_connection.reset();
				break;
			}
			std::this_thread::sleep_for(std::chrono::duration<int, std::milli>(1));
		}
	}
}

void GameClient::ProcessNotification(ConsoleNotificationType type, void* parameter)
{
	if(type == ConsoleNotificationType::GameLoaded && std::this_thread::get_id() != _clientThread->get_id()) {
		GameClient::Disconnect();		
	}
}