Revision 87b5e5cb src/raft/RaftManager.cc
| src/raft/RaftManager.cc | ||
|---|---|---|
| 74 | 74 |
|
| 75 | 75 |
bsr << "bootstrap state"; |
| 76 | 76 |
|
| 77 |
logdb->insert_log_record(-1, -1, bsr, 0); |
|
| 77 |
logdb->insert_log_record(-1, -1, bsr, 0, -1);
|
|
| 78 | 78 |
|
| 79 | 79 |
raft_state.replace("TERM", 0);
|
| 80 | 80 |
raft_state.replace("VOTEDFOR", -1);
|
| ... | ... | |
| 1038 | 1038 |
replica_params.add(xmlrpc_c::value_int(lr->term)); |
| 1039 | 1039 |
replica_params.add(xmlrpc_c::value_int(lr->prev_index)); |
| 1040 | 1040 |
replica_params.add(xmlrpc_c::value_int(lr->prev_term)); |
| 1041 |
replica_params.add(xmlrpc_c::value_int(lr->fed_index)); |
|
| 1041 | 1042 |
replica_params.add(xmlrpc_c::value_string(lr->sql)); |
| 1042 | 1043 |
|
| 1043 | 1044 |
// ------------------------------------------------------------------------- |
| ... | ... | |
| 1176 | 1177 |
Nebula& nd = Nebula::instance(); |
| 1177 | 1178 |
LogDB * logdb = nd.get_logdb(); |
| 1178 | 1179 |
|
| 1179 |
FedReplicaManager * frm = nd.get_frm(); |
|
| 1180 |
|
|
| 1181 | 1180 |
unsigned int lindex, lterm; |
| 1182 | 1181 |
|
| 1183 | 1182 |
std::ostringstream oss; |
| ... | ... | |
| 1206 | 1205 |
|
| 1207 | 1206 |
if ( nd.is_federation_enabled() ) |
| 1208 | 1207 |
{
|
| 1209 |
oss << "<FEDLOG_INDEX>" << frm->get_last_index() << "</FEDLOG_INDEX>";
|
|
| 1208 |
oss << "<FEDLOG_INDEX>" << logdb->last_federated() << "</FEDLOG_INDEX>";
|
|
| 1210 | 1209 |
} |
| 1211 | 1210 |
else |
| 1212 | 1211 |
{
|
Also available in: Unified diff