ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2025-01-06 15:11:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

adds explicit _pier_writ_unlink function

Browse Source
This commit is contained in:
Joe Bryan 2019-04-04 23:28:43 -07:00
parent aaa5b31969
commit a4735e8c93
1 changed files with 20 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
pkg/urbit/vere/pier.c
View File

@ -255,6 +255,25 @@ _pier_disk_commit_request(u3_writ* wit_u)
} }
} }
/* _pier_writ_unlink(): unlink writ from queue.
*/
static void
_pier_writ_unlink(u3_writ* wit_u)
{
u3_pier* pir_u = wit_u->pir_u;
#ifdef VERBOSE_EVENTS
fprintf(stderr, "pier: (%" PRIu64 "): delete\r\n", wit_u->evt_d);
#endif
pir_u->ext_u = wit_u->nex_u;
if ( wit_u == pir_u->ent_u ) {
c3_assert(pir_u->ext_u == 0);
pir_u->ent_u = 0;
}
}
/* _pier_writ_dispose(): dispose of writ. /* _pier_writ_dispose(): dispose of writ.
*/ */
static void static void
@ -492,18 +511,7 @@ start:
// XX must be done before releasing effects // XX must be done before releasing effects
// which is currently reentrant // which is currently reentrant
// //
{ _pier_writ_unlink(wit_u);
#ifdef VERBOSE_EVENTS
fprintf(stderr, "pier: (%" PRIu64 "): delete\r\n", wit_u->evt_d);
#endif
pir_u->ext_u = wit_u->nex_u;
if ( wit_u == pir_u->ent_u ) {
c3_assert(pir_u->ext_u == 0);
pir_u->ent_u = 0;
}
}
// will be false during replay // will be false during replay
// //