juju/paxos
juju/paxos
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Able to accept connection

Browse Source
This commit is contained in:
Julien CLEMENT 2020-05-05 15:59:10 +02:00
parent f512de7313
commit b6c825a877
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main.cc
View File

@ -6,12 +6,27 @@
paxos::EventWatcherRegistry paxos::event_register; paxos::EventWatcherRegistry paxos::event_register;
ev_signal sigint_watcher;
static void sigint_cb(struct ev_loop* loop, ev_signal*, int)
{
ev_break(loop, EVBREAK_ALL);
}
int main(int, char **argv) int main(int, char **argv)
{ {
paxos::ServerConfig server_config = paxos::ServerConfig::parse(argv[1]); paxos::ServerConfig server_config = paxos::ServerConfig::parse(argv[1]);
ev_signal_init(&sigint_watcher, sigint_cb, SIGINT);
paxos::event_register.get_event_loop().register_sigint_watcher(&sigint_watcher);
paxos::LegislatorFactory::Create(server_config.self_);
for (auto config : server_config.legislators_) for (auto config : server_config.legislators_)
{ {
paxos::LegislatorFactory::Create(config); paxos::LegislatorFactory::Create(config);
} }
paxos::event_register.get_event_loop()();
return 0;
} }