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
|
package MasterServer::Core::Core;
use strict;
use warnings;
use AnyEvent;
use Exporter 'import';
use DBI;
our @EXPORT = qw | halt select_database_type main |;
################################################################################
## Handle shutting down the program in case a fatal error occurs.
################################################################################
sub halt {
my $self = shift;
# log shutdown
$self->log("stop", "Stopping the masterserver.");
# clear all other timers, network servers, etc
$self->{dbh}->disconnect() if (defined $self->{dbh});
$self->{dbh} = undef;
$self->{scope} = undef;
# and send signal to condition var to let the loops end
$self->{must_halt}->send;
# log halt
$self->log("stop", "Shutting down NOW!");
# time for a beer.
exit;
}
################################################################################
## Set up the database connection
################################################################################
sub select_database_type {
my $self = shift;
# Connect to database
$self->{dbh} = $self->database_login();
# and test whether we succeeded.
$self->halt() unless (defined $self->{dbh});
}
################################################################################
## Initialize all processes and start various functions
################################################################################
sub main {
my $self = shift;
# condition var prevents or allows the program from ending
$self->{must_halt} = AnyEvent->condvar;
# force version info
$self->version();
# print startup
print "Running...\n";
# keep several objects alive outside their original scope
$self->{scope} = ();
# startup procedure information
$self->log("info", "");
$self->log("info", "");
$self->log("info", "333networks Master Server Application.");
$self->log("info", "Hostname: $self->{masterserver_hostname}");
$self->log("info", "Build: $self->{build_type}");
$self->log("info", "Version: $self->{build_version}");
$self->log("info", "Author: $self->{build_author}");
$self->log("info", "Logs: $self->{log_dir}");
# determine the type of database and load the appropriate module
$self->select_database_type();
#
# Prepare necessary tasks for running the masterserver
#
# (re)load the list with ciphers from the config file, into the database
$self->load_ciphers();
# set first run flag to avoid ignoring servers after downtime
$self->{firstrun} = undef;
$self->{firstruntime} = time;
###
#
# activate all schedulers and functions
#
###
#
# Timers
#
# tasks that are executed once or twice per hour
$self->{scope}->{long_periodic_tasks} = $self->long_periodic_tasks();
#
# tasks that are executed every few minutes
$self->{scope}->{short_periodic_tasks} = $self->short_periodic_tasks();
#
# tasks that are executed every few milliseconds
$self->{scope}->{udp_ticker} = $self->udp_ticker();
#
# Network listeners
#
# start the listening service (listen for UDP beacons)
$self->{scope}->{beacon_catcher} = $self->beacon_catcher();
#
# provide server lists to clients with the browser host server
$self->{scope}->{browser_host} = $self->browser_host();
# all modules loaded. Running...
$self->log("info", "All modules loaded. Masterserver is now running.");
# prevent main program from ending prematurely
$self->{must_halt}->recv;
}
1;
|
