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
|
/* Copyright (C) 2011-2013 Codership Oy <info@codership.com> */
#include "garb_recv_loop.hpp"
#include <signal.h>
namespace garb
{
static Gcs*
global_gcs(0);
void
signal_handler (int signum)
{
log_info << "Received signal " << signum;
global_gcs->close();
}
RecvLoop::RecvLoop (const Config& config)
:
config_(config),
gconf_ (config_.options()),
gcs_ (gconf_, config_.name(), config_.address(), config_.group())
{
/* set up signal handlers */
global_gcs = &gcs_;
struct sigaction sa;
memset (&sa, 0, sizeof(sa));
sa.sa_handler = signal_handler;
if (sigaction (SIGTERM, &sa, NULL))
{
gu_throw_error(errno) << "Falied to install signal hadler for signal "
<< "SIGTERM";
}
if (sigaction (SIGINT, &sa, NULL))
{
gu_throw_error(errno) << "Falied to install signal hadler for signal "
<< "SIGINT";
}
loop();
}
void
RecvLoop::loop()
{
while (1)
{
gcs_action act;
gcs_.recv (act);
switch (act.type)
{
case GCS_ACT_TORDERED:
if (gu_unlikely(!(act.seqno_g & 127)))
/* == report_interval_ of 128 */
{
gcs_.set_last_applied (act.seqno_g);
}
break;
case GCS_ACT_COMMIT_CUT:
break;
case GCS_ACT_STATE_REQ:
gcs_.join (-ENOSYS); /* we can't donate state */
break;
case GCS_ACT_CONF:
{
const gcs_act_conf_t* const cc
(reinterpret_cast<const gcs_act_conf_t*>(act.buf));
if (cc->conf_id > 0) /* PC */
{
if (GCS_NODE_STATE_PRIM == cc->my_state)
{
gcs_.request_state_transfer (config_.sst(),config_.donor());
gcs_.join(cc->seqno);
}
}
else if (cc->memb_num == 0) // SELF-LEAVE after closing connection
{
log_info << "Exiting main loop";
return;
}
if (config_.sst() != Config::DEFAULT_SST)
{
// we requested custom SST, so we're done here
gcs_.close();
}
break;
}
case GCS_ACT_JOIN:
case GCS_ACT_SYNC:
case GCS_ACT_FLOW:
case GCS_ACT_SERVICE:
case GCS_ACT_ERROR:
case GCS_ACT_UNKNOWN:
break;
}
if (act.buf)
{
free (const_cast<void*>(act.buf));
}
}
}
} /* namespace garb */
|