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

Joe looked at this; this was because of u3we vs u3ke.

Browse Source
This commit is contained in:
Elliot Glaysher 2019-04-19 17:02:57 -07:00
parent a849b1b81e
commit 96942f3dd5
2 changed files with 29 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/urbit/include/vere/vere.h
View File

@ -1359,3 +1359,7 @@ void u3m_lmdb_read_identity(MDB_env* environment,
u3_noun* is_fake,
u3_noun* life);
c3_o u3m_lmdb_read_events(MDB_env* environment,
c3_d first_event_d,
c3_d len_d,
void (*callback)(c3_d id, u3_noun ovo));

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

@ -328,6 +328,29 @@ _pier_disk_read_header(u3_disk* log_u)
#endif
}
static void
_pier_db_on_commit_loaded(c3_d id,
u3_noun ovo)
{
// Enqueues the event for replay
}
/* _pier_db_load_commit(): load len_d commits >= lav_d; enqueue for replay
*/
static void
_pier_db_load_commits(u3_pier* pir_u,
c3_d lav_d,
c3_d len_d)
{
u3m_lmdb_read_events(pir_u->log_u->db_u,
lav_d,
len_d,
_pier_db_on_commit_loaded);
}
/* _pier_disk_load_commit(): load len_d commits >= lav_d; enqueue for replay
*/
static void
@ -718,13 +741,13 @@ _pier_work_boot(u3_pier* pir_u, c3_o sav_o)
u3_noun who = u3i_chubs(2, pir_u->who_d);
u3_noun len = u3i_chubs(1, &pir_u->lif_d);
u3_noun msg = u3nq(c3__boot, who, pir_u->fak_o, len);
if ( c3y == sav_o ) {
_pier_db_write_header(pir_u, who, u3k(pir_u->fak_o), len);
}
u3_atom mat = u3we_jam(msg);
u3_noun msg = u3nq(c3__boot, who, pir_u->fak_o, len);
u3_atom mat = u3ke_jam(msg);
if ( c3y == sav_o ) {
_pier_disk_write_header(pir_u, u3k(mat));
}