urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-14 20:02:51 +03:00
Code Issues Packages Projects Releases Wiki Activity

total hack to get effects processed sooner

Browse Source
This commit is contained in:
~hatteb-mitlyd 2014-06-18 12:04:27 -07:00
parent 16f01b11b0
commit 98a44cde66
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
v/raft.c
View File

@ -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;
}
}
}