ApplicationServer.cpp

Go to the documentation of this file.

#include <tdme/engine/logics/ApplicationServer.h>
 
#include <memory>
#include <string>
 
#include <tdme/tdme.h>
#include <tdme/engine/logics/ApplicationServerClient.h>
#include <tdme/engine/logics/Context.h>
#include <tdme/engine/logics/ServerThread.h>
#include <tdme/engine/physics/World.h>
#include <tdme/network/udpserver/UDPServer.h>
#include <tdme/network/udpserver/UDPServerClient.h>
#include <tdme/utilities/Console.h>
 
using std::make_unique;
using std::string;
using std::to_string;
using std::unique_ptr;
 
using tdme::engine::logics::ApplicationServer;
 
using tdme::engine::logics::ApplicationServerClient;
using tdme::engine::logics::Context;
using tdme::engine::logics::ServerThread;
using tdme::network::udpserver::UDPServer;
using tdme::network::udpserver::UDPServerClient;
using tdme::utilities::Console;
 
ApplicationServer::ApplicationServer(const string& name, const string& host, const uint16_t port, const unsigned int maxCCU, int pathFindingThreadCount) : UDPServer(name, host, port, maxCCU), pathFindingThreadCount(pathFindingThreadCount) {
    setIOThreadCount(2);
    setWorkerThreadCount(2);
 
    //
    Console::println("ApplicationServer::ApplicationServer(): Starting WS UDP server @ " + host + ":" + to_string(port));
}
 
Context* ApplicationServer::createContext() {
    Console::println("ApplicationServer::createContext()");
    return new Context(true);
}
 
void ApplicationServer::start() {
    // init
    Console::println("ApplicationServer::ApplicationServer(): Initializing");
 
    //
    context = unique_ptr<Context>(createContext());
    context->getPathFinding()->setThreadCount(pathFindingThreadCount);
    context->setWorld(new World("applicationserver-world"));
    // set up logics
    setupLogics();
    //
    context->addNewLogics();
    logicsThread = make_unique<ServerThread>(context.get(), this);
    context->setLogicsMutex(this->logicsThread->getMutex());
 
    // starting game logic thread
    Console::println("ApplicationServer::ApplicationServer(): Starting game logic thread");
    logicsThread->start();
 
    //
    UDPServer::start();
}
 
ApplicationServer::~ApplicationServer() {
    Console::println("ApplicationServer::~ApplicationServer(): Shutting down");
 
    //
    logicsThread->stop();
    logicsThread->join();
 
    //
    context->shutdown();
}
 
UDPServerClient* ApplicationServer::accept(const uint32_t clientId, const std::string& ip, const uint16_t port) {
    Console::println("Accepting client connection with '" + ip + ":" + to_string(port) + "'");
 
    //
    return new ApplicationServerClient(clientId, ip, port);
}