urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-24 03:14:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

vere: strip out notifications system

Browse Source
This commit is contained in:
Liam Fitzgerald 2022-04-15 16:42:53 -05:00
parent 4ae93c8bd0
commit 72851e0ae7
2 changed files with 0 additions and 84 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/urbit/include/c/motes.h
View File

@ -74,7 +74,6 @@
# define c3__ber c3_s3('b','e','r') # define c3__ber c3_s3('b','e','r')
# define c3__bias c3_s4('b','i','a','s') # define c3__bias c3_s4('b','i','a','s')
# define c3__bic c3_s3('b','i','c') # define c3__bic c3_s3('b','i','c')
# define c3__bide c3_s4('b','i','d', 'e')
# define c3__bind c3_s4('b','i','n','d') # define c3__bind c3_s4('b','i','n','d')
# define c3__bink c3_s4('b','i','n','k') # define c3__bink c3_s4('b','i','n','k')
# define c3__bird c3_s4('b','i','r','d') # define c3__bird c3_s4('b','i','r','d')
@ -557,7 +556,6 @@
# define c3__hop c3_s3('h','o','p') # define c3__hop c3_s3('h','o','p')
# define c3__hosc c3_s4('h','o','s','c') # define c3__hosc c3_s4('h','o','s','c')
# define c3__hose c3_s4('h','o','s','e') # define c3__hose c3_s4('h','o','s','e')
# define c3__howl c3_s4('h','o','w','l')
# define c3__hrul c3_s4('h','r','u','l') # define c3__hrul c3_s4('h','r','u','l')
# define c3__hsbn c3_s4('h','s','b','n') # define c3__hsbn c3_s4('h','s','b','n')
# define c3__hsbr c3_s4('h','s','b','r') # define c3__hsbr c3_s4('h','s','b','r')

82
pkg/urbit/vere/io/ames.c
View File

@ -12,7 +12,6 @@
typedef struct _u3_fine { typedef struct _u3_fine {
c3_y ver_y; // fine protocol c3_y ver_y; // fine protocol
u3p(u3h_root) sac_p; // scry cache hashtable u3p(u3h_root) sac_p; // scry cache hashtable
u3p(u3h_root) bid_p; // pending notifications
struct _u3_ames* sam_u; // ames backpointer struct _u3_ames* sam_u; // ames backpointer
} u3_fine; } u3_fine;
@ -1012,52 +1011,6 @@ _fine_lane_scry_cb(void* vod_p, u3_noun nun)
u3z(nun); u3z(nun);
} }
/* _fine_ef_howl(): broadcast notification of newly bound data
*/
static void
_fine_ef_howl(u3_ames* sam_u, u3_noun pax, u3_noun lis)
{
u3_noun pas = lis;
// put packets in cache
_fine_put_cache(sam_u, pax, pas);
// iterate over subscribers, sending immediately if we have the lane
// else, scry for a lane
u3_weak who = u3h_get(sam_u->fin_s.bid_p, pax);
if ( who == u3_none ) {
u3l_log("no listeners\n");
} else {
u3_noun her = u3qdi_tap(who);
u3_noun him = her; // original ref for counting
while ( her != u3_nul ) {
u3_weak lac = _ames_lane_from_cache(sam_u->lax_p, u3h(her));
u3_pact* pac_u = c3_calloc(sizeof(*pac_u));
pac_u->sam_u = sam_u;
_fine_got_pack(pac_u, u3h(lis));
if ( lac == u3_none ) {
u3l_log("no lane\n");
u3_noun pax = _lane_scry_path(u3k(u3h(her)));
u3_pier_peek_last(sam_u->pir_u, u3_nul, c3__ax,
u3_nul, pax, pac_u, _fine_lane_scry_cb);
} else {
c3_d lan_d = u3r_chub(0, lac);
pac_u->lan_u.pip_w = (c3_w)lan_d;
pac_u->lan_u.por_s = (c3_s)(lan_d >> 32);
_fine_send(pac_u);
}
her = u3t(her);
}
u3z(him);
}
}
/* _ames_ef_send(): send packet to network (v4). /* _ames_ef_send(): send packet to network (v4).
*/ */
@ -1453,30 +1406,6 @@ static void _fine_got_pack(u3_pact* pac_u, u3_noun fra)
u3z(fra); u3z(fra);
} }
static void _fine_bide(u3_pact* pac_u, u3_noun pax)
{
u3_ames* sam_u = pac_u->sam_u;
u3_weak set = u3h_get(sam_u->fin_s.bid_p, pax);
if ( u3_none == set ) {
set = u3_nul;
}
u3_noun her = u3i_chubs(2, pac_u->req_u.pre_u.sen_d);
u3_noun new = u3qdi_put(set, her);
u3h_put(sam_u->fin_s.bid_p, pax, new);
u3_noun cad = u3nc(c3__bide, pax);
u3_noun wir = u3nc(c3__fine, u3_nul);
u3_ovum* ovo_u = u3_ovum_init(0, c3__ames, u3k(wir), u3k(cad));
u3_auto_plan(&sam_u->car_u, ovo_u);
u3z(wir);
u3z(cad);
}
/* _fine_pack_scry_cb(): receive all packets for datum out of fine /* _fine_pack_scry_cb(): receive all packets for datum out of fine
*/ */
static void _fine_pack_scry_cb(void* vod_p, u3_noun nun) static void _fine_pack_scry_cb(void* vod_p, u3_noun nun)
@ -1488,7 +1417,6 @@ static void _fine_pack_scry_cb(void* vod_p, u3_noun nun)
u3_noun pax = u3do("stab", u3i_string(pac_u->req_u.pat_c)); u3_noun pax = u3do("stab", u3i_string(pac_u->req_u.pat_c));
if(pas == u3_none) { if(pas == u3_none) {
_fine_bide(pac_u, u3k(pax));
_ames_pact_free(pac_u); _ames_pact_free(pac_u);
u3z(pax); u3z(pax);
@ -2076,13 +2004,6 @@ _ames_kick_newt(u3_ames* sam_u, u3_noun tag, u3_noun dat)
ret_o = c3y; ret_o = c3y;
} break; } break;
case c3__howl: {
u3_noun pat = u3k(u3h(dat));
u3_noun lis = u3k(u3t(dat));
_fine_ef_howl(sam_u, pat, lis);
ret_o = c3y;
} break;
case c3__hoot: { case c3__hoot: {
u3_noun lan = u3k(u3h(dat)); u3_noun lan = u3k(u3h(dat));
u3_noun pac = u3k(u3t(dat)); u3_noun pac = u3k(u3t(dat));
@ -2250,9 +2171,6 @@ u3_ames_io_init(u3_pier* pir_u)
// 50 bytes (average) per path * 100_000 = 5MB // 50 bytes (average) per path * 100_000 = 5MB
sam_u->fin_s.sac_p = u3h_new_cache(100000); sam_u->fin_s.sac_p = u3h_new_cache(100000);
// hashtable for notificatiosn
sam_u->fin_s.bid_p = u3h_new_cache(100000);
//NOTE some numbers on memory usage for the lane cache //NOTE some numbers on memory usage for the lane cache
// //
// assuming we store: // assuming we store: