mirror of
https://github.com/OpenFusionProject/OpenFusion.git
synced 2024-09-19 18:18:20 +00:00
dongresource
006d1000c7
This replaces the unnecessary deallocations on program termination. Passing in the suppression list environment variable via setenv() doesn't seem to work, so I've added a comment in the Makefile to explain invocation.
159 lines
3.8 KiB
C++
159 lines
3.8 KiB
C++
#include "CNLoginServer.hpp"
|
|
#include "CNShardServer.hpp"
|
|
#include "PlayerManager.hpp"
|
|
#include "ChatManager.hpp"
|
|
#include "MobManager.hpp"
|
|
#include "ItemManager.hpp"
|
|
#include "MissionManager.hpp"
|
|
#include "NanoManager.hpp"
|
|
#include "NPCManager.hpp"
|
|
#include "TransportManager.hpp"
|
|
#include "Database.hpp"
|
|
#include "TableData.hpp"
|
|
#include "ChunkManager.hpp"
|
|
|
|
#include "settings.hpp"
|
|
|
|
#include "../version.h"
|
|
|
|
#if defined(__MINGW32__) && !defined(_GLIBCXX_HAS_GTHREADS)
|
|
#include "mingw/mingw.thread.h"
|
|
#else
|
|
#include <thread>
|
|
#endif
|
|
#include <string>
|
|
#include <chrono>
|
|
#include <signal.h>
|
|
|
|
// HACK
|
|
#ifdef __has_feature
|
|
#if __has_feature(address_sanitizer)
|
|
#define __SANITIZE_ADDRESS__ 1
|
|
#endif
|
|
#endif
|
|
|
|
CNShardServer *shardServer = nullptr;
|
|
std::thread *shardThread = nullptr;
|
|
|
|
void startShard(CNShardServer* server) {
|
|
server->start();
|
|
}
|
|
|
|
#ifndef _WIN32
|
|
// terminate gracefully on SIGINT (for gprof)
|
|
void terminate(int arg) {
|
|
std::cout << "OpenFusion: terminating." << std::endl;
|
|
|
|
if (shardServer != nullptr && shardThread != nullptr) {
|
|
shardServer->kill();
|
|
shardThread->join();
|
|
}
|
|
|
|
exit(0);
|
|
}
|
|
|
|
void initsignals() {
|
|
struct sigaction act;
|
|
|
|
memset((void*)&act, 0, sizeof(act));
|
|
sigemptyset(&act.sa_mask);
|
|
|
|
// tell the OS to not kill us if you use a broken pipe, just let us know thru recv() or send()
|
|
act.sa_handler = SIG_IGN;
|
|
if (sigaction(SIGPIPE, &act, NULL) < 0) {
|
|
perror("sigaction");
|
|
exit(1);
|
|
}
|
|
|
|
act.sa_handler = terminate;
|
|
if (sigaction(SIGINT, &act, NULL) < 0) {
|
|
perror("sigaction");
|
|
exit(1);
|
|
}
|
|
}
|
|
#endif
|
|
|
|
int main() {
|
|
#ifdef _WIN32
|
|
WSADATA wsaData;
|
|
if (WSAStartup(MAKEWORD(1, 1), &wsaData) != 0) {
|
|
std::cerr << "OpenFusion: WSAStartup failed" << std::endl;
|
|
exit(EXIT_FAILURE);
|
|
}
|
|
#else
|
|
initsignals();
|
|
#endif
|
|
srand(getTime());
|
|
settings::init();
|
|
std::cout << "[INFO] OpenFusion v" GIT_VERSION << std::endl;
|
|
std::cout << "[INFO] Protocol version: " << PROTOCOL_VERSION << std::endl;
|
|
std::cout << "[INFO] Intializing Packet Managers..." << std::endl;
|
|
TableData::init();
|
|
PlayerManager::init();
|
|
ChatManager::init();
|
|
MobManager::init();
|
|
ItemManager::init();
|
|
MissionManager::init();
|
|
NanoManager::init();
|
|
NPCManager::init();
|
|
TransportManager::init();
|
|
|
|
Database::open();
|
|
|
|
std::cout << "[INFO] Starting Server Threads..." << std::endl;
|
|
CNLoginServer loginServer(settings::LOGINPORT);
|
|
shardServer = new CNShardServer(settings::SHARDPORT);
|
|
|
|
shardThread = new std::thread(startShard, (CNShardServer*)shardServer);
|
|
|
|
loginServer.start();
|
|
|
|
shardServer->kill();
|
|
shardThread->join();
|
|
|
|
#ifdef _WIN32
|
|
WSACleanup();
|
|
#endif
|
|
return 0;
|
|
}
|
|
|
|
// helper functions
|
|
|
|
std::string U16toU8(char16_t* src) {
|
|
try {
|
|
std::wstring_convert<std::codecvt_utf8_utf16<char16_t>,char16_t> convert;
|
|
return convert.to_bytes(src);
|
|
} catch(const std::exception& e) {
|
|
return "";
|
|
}
|
|
}
|
|
|
|
// returns number of char16_t that was written at des
|
|
size_t U8toU16(std::string src, char16_t* des) {
|
|
std::wstring_convert<std::codecvt_utf8_utf16<char16_t>,char16_t> convert;
|
|
std::u16string tmp = convert.from_bytes(src);
|
|
|
|
// copy utf16 string to buffer
|
|
memcpy(des, tmp.c_str(), sizeof(char16_t) * tmp.length());
|
|
des[tmp.length()] = '\0';
|
|
|
|
return tmp.length();
|
|
}
|
|
|
|
time_t getTime() {
|
|
using namespace std::chrono;
|
|
|
|
milliseconds value = duration_cast<milliseconds>((time_point_cast<milliseconds>(high_resolution_clock::now())).time_since_epoch());
|
|
|
|
return (time_t)value.count();
|
|
}
|
|
|
|
// returns system time in seconds
|
|
time_t getTimestamp() {
|
|
using namespace std::chrono;
|
|
|
|
seconds value = duration_cast<seconds>((time_point_cast<seconds>(system_clock::now())).time_since_epoch());
|
|
|
|
return (time_t)value.count();
|
|
}
|