ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-11-10 10:05:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:urbit/urbit

Browse Source
This commit is contained in:
C. Guy Yarvin 2014-04-23 10:03:05 -07:00
commit ff716a6122
124 changed files with 1355 additions and 1341 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
v/sist.c
View File

@ -72,9 +72,13 @@ u2_sist_pack(u2_reck* rec_u, c3_w tem_w, c3_w typ_w, c3_w* bob_w, c3_w len_w)
c3_assert(0); c3_assert(0);
} }
lug_u->len_d += (c3_d)(lar_u.len_w + c3_wiseof(lar_u)); lug_u->len_d += (c3_d)(lar_u.len_w + c3_wiseof(lar_u));
free(bob_w); free(bob_w);
// Sync. Or, what goes by sync.
{
fsync(lug_u->fid_i); // fsync is almost useless, F_FULLFSYNC too slow
}
return rec_u->ent_w; return rec_u->ent_w;
} }
@ -884,6 +888,7 @@ _sist_rest(u2_reck* rec_u)
{ {
c3_w ent_w; c3_w ent_w;
c3_d end_d; c3_d end_d;
u2_bean rup = u2_no;
end_d = u2R->lug_u.len_d; end_d = u2R->lug_u.len_d;
ent_w = 0; ent_w = 0;
@ -913,8 +918,17 @@ _sist_rest(u2_reck* rec_u)
} }
if ( lar_u.syn_w != u2_mug((c3_w)tar_d) ) { if ( lar_u.syn_w != u2_mug((c3_w)tar_d) ) {
uL(fprintf(uH, "record (%s) is corrupt (f)\n", ful_c)); if ( u2_no == rup ) {
u2_lo_bail(rec_u); uL(fprintf(uH, "corruption detected; attempting to fix\n"));
rup = u2_yes;
}
uL(fprintf(uH, "lar:%x mug:%x\n", lar_u.syn_w, u2_mug((c3_w)tar_d)));
end_d--; u2R->lug_u.len_d--;
continue;
}
else if ( u2_yes == rup ) {
uL(fprintf(uH, "matched at %x\n", lar_u.syn_w));
rup = u2_no;
} }
if ( lar_u.ent_w == 0 ) { if ( lar_u.ent_w == 0 ) {