1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
#include "login.hh"
// TODO(fusion): Support windows eventually?
#if OS_LINUX
# include <errno.h>
# include <signal.h>
#else
# error "Operating system not currently supported."
#endif
// Shutdown Signal
int g_ShutdownSignal = 0;
// Time
int g_MonotonicTimeMS = 0;
// Config
char g_Motd[256] = "";
int g_UpdateRate = 20;
int g_LoginPort = 7171;
int g_MaxConnections = 10;
int g_LoginTimeout = 10000;
char g_QueryManagerHost[100] = "127.0.0.1";
int g_QueryManagerPort = 7174;
char g_QueryManagerPassword[30] = "";
static void ParseMotd(char *Dest, int DestCapacity, const char *String){
char *Motd = (char*)alloca(DestCapacity);
ParseString(Motd, DestCapacity, String);
if(Motd[0] != 0){
snprintf(Dest, DestCapacity, "%u\n%s", HashString(Motd), Motd);
}
}
static void LoginKVCallback(const char *Key, const char *Val){
if(StringEqCI(Key, "LoginPort")){
ParseInteger(&g_LoginPort, Val);
}else if(StringEqCI(Key, "MaxConnections")){
ParseInteger(&g_MaxConnections, Val);
}else if(StringEqCI(Key, "LoginTimeout")){
ParseDuration(&g_LoginTimeout, Val);
}else if(StringEqCI(Key, "UpdateRate")){
ParseInteger(&g_UpdateRate, Val);
}else if(StringEqCI(Key, "QueryManagerHost")){
ParseString(g_QueryManagerHost,
sizeof(g_QueryManagerHost), Val);
}else if(StringEqCI(Key, "QueryManagerPort")){
ParseInteger(&g_QueryManagerPort, Val);
}else if(StringEqCI(Key, "QueryManagerPassword")){
ParseString(g_QueryManagerPassword,
sizeof(g_QueryManagerPassword), Val);
}else if(StringEqCI(Key, "MOTD")){
ParseMotd(g_Motd, sizeof(g_Motd), Val);
}else{
LOG_WARN("Unknown config \"%s\"", Key);
}
}
static bool SigHandler(int SigNr, sighandler_t Handler){
struct sigaction Action = {};
Action.sa_handler = Handler;
sigfillset(&Action.sa_mask);
if(sigaction(SigNr, &Action, NULL) == -1){
LOG_ERR("Failed to change handler for signal %d (%s): (%d) %s",
SigNr, sigdescr_np(SigNr), errno, strerrordesc_np(errno));
return false;
}
return true;
}
static void ShutdownHandler(int SigNr){
g_ShutdownSignal = SigNr;
}
int main(int argc, char **argv){
(void)argc;
(void)argv;
g_ShutdownSignal = 0;
if(!SigHandler(SIGPIPE, SIG_IGN)
|| !SigHandler(SIGINT, ShutdownHandler)
|| !SigHandler(SIGTERM, ShutdownHandler)){
return EXIT_FAILURE;
}
int64 StartTime = GetClockMonotonicMS();
g_MonotonicTimeMS = 0;
LOG("Tibia Login Server v0.1");
if(!ReadConfig("config.cfg", LoginKVCallback)){
return EXIT_FAILURE;
}
atexit(ExitConnections);
atexit(ExitQuery);
if(!InitConnections()){
return EXIT_FAILURE;
}
if(!InitQuery()){
return EXIT_FAILURE;
}
// NOTE(fusion): Print MOTD with escape codes.
char Motd[30];
if(EscapeString(Motd, sizeof(Motd), g_Motd)){
LOG("MOTD: \"%s\"", Motd);
}else{
LOG("MOTD: \"%s...\"", Motd);
}
LOG("Running at %d updates per second...", g_UpdateRate);
int64 UpdateInterval = 1000 / (int64)g_UpdateRate;
while(g_ShutdownSignal == 0){
int64 UpdateStart = GetClockMonotonicMS();
g_MonotonicTimeMS = (int)(UpdateStart - StartTime);
ProcessConnections();
int64 UpdateEnd = GetClockMonotonicMS();
int64 NextUpdate = UpdateStart + UpdateInterval;
if(NextUpdate > UpdateEnd){
SleepMS(NextUpdate - UpdateEnd);
}
}
LOG("Received signal %d (%s), shutting down...",
g_ShutdownSignal, sigdescr_np(g_ShutdownSignal));
return EXIT_SUCCESS;
}
|
