Revision 50880bb2 src/raft/RaftManager.cc
| src/raft/RaftManager.cc | ||
|---|---|---|
| 70 | 70 |
|
| 71 | 71 |
if ( logdb->get_raft_state(raft_xml) != 0 ) |
| 72 | 72 |
{
|
| 73 |
std::ostringstream bsr; |
|
| 74 |
|
|
| 75 |
bsr << "bootstrap state"; |
|
| 76 |
|
|
| 77 |
logdb->insert_log_record(-1, -1, bsr, 0); |
|
| 78 |
|
|
| 73 | 79 |
raft_state.replace("TERM", 0);
|
| 74 | 80 |
raft_state.replace("VOTEDFOR", -1);
|
| 75 | 81 |
|
| 76 | 82 |
raft_state.to_xml(raft_xml); |
| 77 | 83 |
|
| 78 |
logdb->insert_raft_state(raft_xml);
|
|
| 84 |
logdb->update_raft_state(raft_xml);
|
|
| 79 | 85 |
|
| 80 | 86 |
votedfor = -1; |
| 81 | 87 |
term = 0; |
| ... | ... | |
| 411 | 417 |
frm->start_replica_threads(); |
| 412 | 418 |
} |
| 413 | 419 |
|
| 414 |
logdb->insert_raft_state(raft_state_xml);
|
|
| 420 |
logdb->update_raft_state(raft_state_xml);
|
|
| 415 | 421 |
|
| 416 | 422 |
NebulaLog::log("RCM", Log::INFO, "oned is now the leader of zone");
|
| 417 | 423 |
} |
| ... | ... | |
| 480 | 486 |
frm->stop_replica_threads(); |
| 481 | 487 |
} |
| 482 | 488 |
|
| 483 |
logdb->insert_raft_state(raft_state_xml);
|
|
| 489 |
logdb->update_raft_state(raft_state_xml);
|
|
| 484 | 490 |
} |
| 485 | 491 |
|
| 486 | 492 |
/* -------------------------------------------------------------------------- */ |
| ... | ... | |
| 672 | 678 |
|
| 673 | 679 |
pthread_mutex_unlock(&mutex); |
| 674 | 680 |
|
| 675 |
logdb->insert_raft_state(raft_state_xml);
|
|
| 681 |
logdb->update_raft_state(raft_state_xml);
|
|
| 676 | 682 |
|
| 677 | 683 |
return 0; |
| 678 | 684 |
} |
| ... | ... | |
| 927 | 933 |
|
| 928 | 934 |
pthread_mutex_unlock(&mutex); |
| 929 | 935 |
|
| 930 |
logdb->insert_raft_state(raft_state_xml);
|
|
| 936 |
logdb->update_raft_state(raft_state_xml);
|
|
| 931 | 937 |
|
| 932 | 938 |
logdb->get_last_record_index(lindex, lterm); |
| 933 | 939 |
|
| ... | ... | |
| 1008 | 1014 |
|
| 1009 | 1015 |
pthread_mutex_unlock(&mutex); |
| 1010 | 1016 |
|
| 1011 |
logdb->insert_raft_state(raft_state_xml);
|
|
| 1017 |
logdb->update_raft_state(raft_state_xml);
|
|
| 1012 | 1018 |
|
| 1013 | 1019 |
srand(_server_id); |
| 1014 | 1020 |
|
Also available in: Unified diff