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
131
132
133
134
135
136
137
138
|
/*
* Module: main.cc
*
* **** License ****
* Version: VPL 1.0
*
* The contents of this file are subject to the Vyatta Public License
* Version 1.0 ("License"); you may not use this file except in
* compliance with the License. You may obtain a copy of the License at
* http://www.vyatta.com/vpl
*
* Software distributed under the License is distributed on an "AS IS"
* basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
* the License for the specific language governing rights and limitations
* under the License.
*
* This code was originally developed by Vyatta, Inc.
* Portions created by Vyatta are Copyright (C) 2007 Vyatta, Inc.
* All Rights Reserved.
*
* Author: Michael Larson
* Date: 2007
* Description:
*
* **** End License ****
*
*/
#include <signal.h>
#include <syslog.h>
#include <stdio.h>
#include <iostream>
#include "loadbalance.hh"
LoadBalance *g_lb = NULL;
static void usage()
{
cout << "lb -fh" << endl;
cout << "-f [file] configuration file" << endl;
cout << "-t load configuration file only and exit" << endl;
cout << "-h help" << endl;
}
static void sig_end(int signo)
{
if (g_lb)
delete g_lb;
cerr << "End signal: " << signo << endl;
syslog(LOG_ERR, "wan_lb, exit signal caught, exiting..");
exit(0);
}
static void sig_user(int signo)
{
if (g_lb)
delete g_lb;
cerr << "User signal: " << signo << endl;
syslog(LOG_ERR, "wan_lb, user exit signal caught, exiting..");
exit(0);
}
int main(int argc, char* argv[])
{
int ch;
bool config_debug_mode = false;
string c_file;
//grab inputs
while ((ch = getopt(argc, argv, "f:ht")) != -1) {
switch (ch) {
case 'f':
c_file = optarg;
break;
case 'h':
usage();
exit(0);
case 't':
config_debug_mode = true;
break;
default:
usage();
exit(0);
}
}
//parse conf file
if (c_file.empty()) {
cout << "Configuration file is empty" << endl;
exit(0);
}
g_lb = new LoadBalance();
bool success = g_lb->set_conf(c_file);
if (success == false) {
syslog(LOG_ERR, "wan_lb: error loading configuration file: %s", c_file.c_str());
exit(0);
}
if (config_debug_mode) {
exit(0);
}
#ifdef DEBUG
cout << "STARTING CYCLE" << endl;
#endif
g_lb->init();
//signal handler here
// sighup...
signal(SIGINT, sig_end);
signal(SIGTERM, sig_end);
signal(SIGUSR1, sig_user);
//drop into event loop
do {
#ifdef DEBUG
cout << "main.cc: starting new cycle" << endl;
#endif
//health test
g_lb->health_test();
//apply rules
g_lb->apply_rules();
//update show output
g_lb->output();
g_lb->sleep();
} while (g_lb->start_cycle());
exit(0);
}
|
