ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-15 18:12:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

vere: scry out next behn timer for backstop

Browse Source 
Instead of potentially waiting ten minutes in the problematic case, we
scry out the next timer from behn and set to that (if we haven't set
a new timer while we were waiting for the scry).
This commit is contained in:
Fang 2020-06-24 23:31:08 +02:00
parent 2be266de8c
commit afd1808745
No known key found for this signature in database
GPG Key ID: EB035760C1BBA972
1 changed files with 30 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -19,6 +19,8 @@
c3_o alm; // alarm c3_o alm; // alarm
} u3_behn; } u3_behn;
static void _behn_scry_cb(void* vod_p, u3_noun nun);
/* _behn_time_cb(): timer callback. /* _behn_time_cb(): timer callback.
*/ */
static void static void
@ -27,7 +29,7 @@ _behn_time_cb(uv_timer_t* tim_u)
u3_behn* teh_u = tim_u->data; u3_behn* teh_u = tim_u->data;
teh_u->alm = c3n; teh_u->alm = c3n;
// start another timer for 10 minutes // take initiative to start the next timer, just in case
// //
// This is a backstop to deal with the case where a %doze is not // This is a backstop to deal with the case where a %doze is not
// properly sent, for example after a crash. If the timer continues // properly sent, for example after a crash. If the timer continues
@ -35,9 +37,10 @@ _behn_time_cb(uv_timer_t* tim_u)
// transient error, this will get us past it. // transient error, this will get us past it.
// //
{ {
c3_d gap_d = 10 * 60 * 1000; u3_noun pax = u3i_trel(u3i_string("timers"), u3i_string("next"), u3_nul);
teh_u->alm = c3y; u3_lord_peek_last(teh_u->car_u.pir_u->god_u, u3_nul,
uv_timer_start(&teh_u->tim_u, _behn_time_cb, gap_d, 0); c3_s2('b', 'x'), u3_nul, pax,
teh_u, _behn_scry_cb);
} }
// send timer event // send timer event
@ -82,6 +85,29 @@ _behn_ef_doze(u3_behn* teh_u, u3_noun wen)
u3z(wen); u3z(wen);
} }
/* _behn_scry_cb(): next timer scry result callback.
*/
static void
_behn_scry_cb(void* vod_p, u3_noun nun)
{
u3_behn* teh_u = vod_p;
u3_weak tim = u3r_at(7, nun);
if (c3y == teh_u->alm) {
// timer already set while we were scrying, no-op
}
else if (u3_none == tim) {
// fall back to a timer for 10 minutes
//
c3_d gap_d = 10 * 60 * 1000;
teh_u->alm = c3y;
uv_timer_start(&teh_u->tim_u, _behn_time_cb, gap_d, 0);
} else {
_behn_ef_doze(teh_u, u3k(tim));
}
u3z(nun);
}
/* _behn_io_talk(): notify %behn that we're live /* _behn_io_talk(): notify %behn that we're live
*/ */
static void static void