urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2025-01-03 10:02:32 +03:00
Code Issues Packages Projects Releases Wiki Activity

Use same election timeout always

Browse Source 
In particular, we wait at least 150ms after starting up before declaring
an election, to give the old leader a chance to send us a heartbeat.
This commit is contained in:
Steve Dee 2014-03-10 16:25:48 -07:00
parent 6466a1760a
commit 399530d379
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
v/raft.c
View File

@ -148,12 +148,14 @@ _raft_alloc(uv_handle_t* had_u, size_t siz_i)
return buf_u;
}
/* _raft_election_rand(): pseudorandom component of election timeout.
/* _raft_election_rand(): election timeout.
*/
static c3_w
_raft_election_rand()
{
return ((float) rand() / RAND_MAX) * 150;
c3_w ret = (1.0 + (float) rand() / RAND_MAX) * 150;
//uL(fprintf(uH, "raft: timeout %d\n", ret));
return ret;
}
/* _raft_promote(): actions on raft leader election.
@ -285,7 +287,7 @@ _raft_do_rest(u2_rcon* ron_u, const u2_rmsg* msg_u)
sas_i = uv_timer_stop(&raf_u->tim_u);
c3_assert(0 == sas_i);
sas_i = uv_timer_start(&raf_u->tim_u, &_raft_time_cb,
150 + _raft_election_rand(), 0);
_raft_election_rand(), 0);
c3_assert(0 == sas_i);
}
@ -1287,7 +1289,7 @@ _raft_time_cb(uv_timer_t* tim_u, c3_i sas_i)
}
case u2_raty_cand: {
sas_i = uv_timer_start(tim_u, _raft_time_cb,
150 + _raft_election_rand(), 0);
_raft_election_rand(), 0);
c3_assert(sas_i == 0);
_raft_start_election(raf_u);
break;