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

vere: retry behn timer failures

Browse Source
This commit is contained in:
Joe Bryan 2020-06-27 01:15:32 -07:00
parent 49444e86c5
commit 3969e78612
1 changed files with 39 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
pkg/urbit/vere/io/behn.c
View File

@ -19,6 +19,42 @@
c3_o alm_o; // alarm
} u3_behn;
/* _behn_wake_bail(): %wake is essential, retry failures.
*/
static void
_behn_wake_bail(u3_ovum* egg_u, u3_noun lud)
{
u3_auto* car_u = egg_u->car_u;
if ( 2 == egg_u->try_w ) {
u3l_log("behn: timer failed\n");
if ( 2 == u3qb_lent(lud) ) {
u3_pier_punt_goof("wake", u3k(u3h(lud)));
u3_pier_punt_goof("crud", u3k(u3h(u3t(lud))));
}
else {
u3_noun dul = lud;
c3_w len_w = 1;
while ( u3_nul != dul ) {
u3l_log("behn: bail %u\r\n", len_w++);
u3_pier_punt_goof("behn", u3k(u3h(dul)));
dul = u3t(dul);
}
}
u3_ovum_free(egg_u);
u3_pier_bail(car_u->pir_u);
}
else {
egg_u->try_w++;
u3_auto_plan(car_u, egg_u);
}
u3z(lud);
}
/* _behn_time_cb(): timer callback.
*/
static void
@ -46,7 +82,9 @@ _behn_time_cb(uv_timer_t* tim_u)
u3_noun wir = u3nc(c3__behn, u3_nul);
u3_noun cad = u3nc(c3__wake, u3_nul);
u3_auto_plan(&teh_u->car_u, u3_ovum_init(0, c3__b, wir, cad));
u3_auto_peer(
u3_auto_plan(&teh_u->car_u, u3_ovum_init(0, c3__b, wir, cad)),
0, 0, _behn_wake_bail);
}
}