From 98a44cde66dd74f5bdcaf1fba4b3c7cebb20c930 Mon Sep 17 00:00:00 2001 From: ~hatteb-mitlyd Date: Wed, 18 Jun 2014 12:04:27 -0700 Subject: [PATCH] total hack to get effects processed sooner --- v/raft.c | 14 ++------------ 1 file changed, 2 insertions(+), 12 deletions(-) diff --git a/v/raft.c b/v/raft.c index 45f6c89b32..66848bb205 100644 --- a/v/raft.c +++ b/v/raft.c @@ -1621,7 +1621,6 @@ _raft_comm(u2_reck* rec_u, c3_d bid_d) egg_u = rec_u->ova.egg_u; while ( egg_u ) { if ( egg_u->ent_d <= bid_d ) { - egg_u->did = u2_yes; egg_u->cit = u2_yes; } else break; egg_u = egg_u->nex_u; @@ -1711,15 +1710,7 @@ u2_raft_work(u2_reck* rec_u) rec_u->ova.egg_u = egg_u->nex_u; } - if ( u2_yes == egg_u->cit ) { - _raft_kick_all(rec_u, vir); - } - else { - // We poked an event, but Raft failed to persist it. - // TODO: gracefully recover. - uL(fprintf(uH, "vere: event executed but not persisted\n")); - c3_assert(0); - } + egg_u->cit = u2_yes; free(egg_u); } else break; @@ -1789,9 +1780,8 @@ u2_raft_work(u2_reck* rec_u) rec_u->ova.geg_u->nex_u = egg_u; rec_u->ova.geg_u = egg_u; } - } - else { _raft_kick_all(rec_u, vir); + egg_u->did = u2_yes; } } }