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