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

ames: count dropped packets (and print every 1k with -v)

Browse Source
This commit is contained in:
Joe Bryan 2020-06-22 13:07:34 -07:00
parent 9816434890
commit e7a95f6d6b
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -38,6 +38,7 @@
c3_o fak_o; // fake keys c3_o fak_o; // fake keys
c3_s por_s; // public IPv4 port c3_s por_s; // public IPv4 port
c3_c* dns_c; // domain XX multiple/fallback c3_c* dns_c; // domain XX multiple/fallback
c3_d dop_d; // drop count (since last print)
c3_w imp_w[256]; // imperial IPs c3_w imp_w[256]; // imperial IPs
time_t imp_t[256]; // imperial IP timestamps time_t imp_t[256]; // imperial IP timestamps
c3_o imp_o[256]; // imperial print status c3_o imp_o[256]; // imperial print status
@ -405,11 +406,18 @@ _ames_recv_cb(uv_udp_t* wax_u,
if ( c3__hear == u3h(egg_u->cad) ) { if ( c3__hear == u3h(egg_u->cad) ) {
u3_auto_drop(&sam_u->car_u, egg_u); u3_auto_drop(&sam_u->car_u, egg_u);
sam_u->dop_d++;
} }
egg_u = nex_u; egg_u = nex_u;
} }
} }
if ( 0 == (sam_u->dop_d % 1000) ) {
if ( (u3C.wag_w & u3o_verbose) ) {
u3l_log("ames: dropped 1.000 packets\r\n");
}
}
} }
c3_free(buf_u->base); c3_free(buf_u->base);
@ -703,6 +711,7 @@ u3_ames_io_init(u3_pier* pir_u)
sam_u->who_d[1] = pir_u->who_d[1]; sam_u->who_d[1] = pir_u->who_d[1];
sam_u->por_s = pir_u->por_s; sam_u->por_s = pir_u->por_s;
sam_u->fak_o = pir_u->fak_o; sam_u->fak_o = pir_u->fak_o;
sam_u->dop_d = 0;
c3_assert( !uv_udp_init(u3L, &sam_u->wax_u) ); c3_assert( !uv_udp_init(u3L, &sam_u->wax_u) );
sam_u->wax_u.data = sam_u; sam_u->wax_u.data = sam_u;