Add blackhole tile (#1632)

* add new tiles * add in blackhole tile * remove for now * changes
firedancer-io · Apr 24, 2024 · ebeaa94 · ebeaa94
1 parent 7eecb38
commit ebeaa94
Show file tree

Hide file tree

Showing 4 changed files with 43 additions and 0 deletions.
diff --git a/src/app/fdctl/Local.mk b/src/app/fdctl/Local.mk
@@ -27,6 +27,7 @@ $(call add-objs,run/tiles/fd_bank,fd_fdctl)
 $(call add-objs,run/tiles/fd_shred,fd_fdctl)
 $(call add-objs,run/tiles/fd_store,fd_fdctl)
 $(call add-objs,run/tiles/fd_sign,fd_fdctl)
+$(call add-objs,run/tiles/fd_blackhole,fd_fdctl)
 
 # fdctl topologies
 $(call add-objs,run/topos/fd_frankendancer,fd_fdctl)

diff --git a/src/app/fdctl/main.c b/src/app/fdctl/main.c
@@ -27,6 +27,7 @@ extern fd_topo_run_tile_t fd_tile_shred;
 extern fd_topo_run_tile_t fd_tile_store;
 extern fd_topo_run_tile_t fd_tile_sign;
 extern fd_topo_run_tile_t fd_tile_metric;
+extern fd_topo_run_tile_t fd_tile_blackhole;
 
 fd_topo_run_tile_t * TILES[] = {
   &fd_tile_net,
@@ -41,6 +42,7 @@ fd_topo_run_tile_t * TILES[] = {
   &fd_tile_store,
   &fd_tile_sign,
   &fd_tile_metric,
+  &fd_tile_blackhole,
   NULL,
 };
 

diff --git a/src/app/fdctl/run/tiles/fd_blackhole.c b/src/app/fdctl/run/tiles/fd_blackhole.c
@@ -0,0 +1,38 @@
+#include "tiles.h"
+
+/**
+ * Tile used to filter out all packets when used as a consumer.
+ * As the name suggests, it is a "black hole" for incoming packets.
+*/
+
+static void
+before_frag( void * _ctx    FD_PARAM_UNUSED,
+             ulong  in_idx  FD_PARAM_UNUSED,
+             ulong  seq     FD_PARAM_UNUSED,
+             ulong  sig     FD_PARAM_UNUSED,
+             int *  opt_filter ) {
+  *opt_filter = 1;
+}
+
+static ulong
+populate_allowed_fds( void * scratch,
+                      ulong  out_fds_cnt,
+                      int *  out_fds ) {
+  (void)scratch;
+  if( FD_UNLIKELY( out_fds_cnt < 2 ) ) FD_LOG_ERR(( "out_fds_cnt %lu", out_fds_cnt ));
+
+  ulong out_cnt = 0;
+  out_fds[ out_cnt++ ] = 2; /* stderr */
+  if( FD_LIKELY( -1!=fd_log_private_logfile_fd() ) )
+    out_fds[ out_cnt++ ] = fd_log_private_logfile_fd(); /* logfile */
+  return out_cnt;
+}
+
+fd_topo_run_tile_t fd_tile_blackhole = {
+  .name                     = "blackhole",
+  .mux_flags                = FD_MUX_FLAG_MANUAL_PUBLISH | FD_MUX_FLAG_COPY,
+  .burst                    = 1UL,
+  .mux_before_frag          = before_frag,
+  .populate_allowed_fds     = populate_allowed_fds,
+  .privileged_init          = NULL,
+};
diff --git a/src/app/fddev/main1.c b/src/app/fddev/main1.c
@@ -41,6 +41,7 @@ extern fd_topo_run_tile_t fd_tile_shred;
 extern fd_topo_run_tile_t fd_tile_store;
 extern fd_topo_run_tile_t fd_tile_sign;
 extern fd_topo_run_tile_t fd_tile_metric;
+extern fd_topo_run_tile_t fd_tile_blackhole;
 
 extern fd_topo_run_tile_t fd_tile_bencho;
 extern fd_topo_run_tile_t fd_tile_benchg;
@@ -59,6 +60,7 @@ fd_topo_run_tile_t * TILES[] = {
   &fd_tile_store,
   &fd_tile_sign,
   &fd_tile_metric,
+  &fd_tile_blackhole,
   &fd_tile_bencho,
   &fd_tile_benchg,
   &fd_tile_benchs,