Skip to content

Commit 92e67e0

Browse files
committed
revert
1 parent 2a8a43a commit 92e67e0

File tree

1 file changed

+3
-12
lines changed

1 file changed

+3
-12
lines changed

src/app/firedancer/topology.c

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -294,10 +294,7 @@ fd_topo_initialize( config_t * config ) {
294294
fd_topob_wksp( topo, "replay_manif" );
295295

296296
fd_topob_wksp( topo, "slot_fseqs" ); /* fseqs for marked slots eg. turbine slot */
297-
if( enable_rpc ) {
298-
fd_topob_wksp( topo, "rpcsrv" );
299-
fd_topob_wksp( topo, "shred_rpcsrv" );
300-
}
297+
if( enable_rpc ) fd_topob_wksp( topo, "rpcsrv" );
301298

302299
#define FOR(cnt) for( ulong i=0UL; i<cnt; i++ )
303300

@@ -373,10 +370,6 @@ fd_topo_initialize( config_t * config ) {
373370
/**/ fd_topob_link( topo, "snapdc_rd", "snapdc_rd", 128UL, 0UL, 1UL );
374371
/**/ fd_topob_link( topo, "snapin_rd", "snapin_rd", 128UL, 0UL, 1UL );
375372

376-
if( enable_rpc ) {
377-
FOR(shred_tile_cnt) fd_topob_link( topo, "shred_rpcsrv", "shred_rpcsrv", pending_fec_shreds_depth, FD_SHRED_REPAIR_MTU, 2UL /* at most 2 msgs per after_frag */ );
378-
}
379-
380373
/* Replay decoded manifest dcache topo obj */
381374
fd_topo_obj_t * replay_manifest_dcache = fd_topob_obj( topo, "dcache", "replay_manif" );
382375
fd_pod_insertf_ulong( topo->props, 2UL << 30UL, "obj.%lu.data_sz", replay_manifest_dcache->id );
@@ -784,10 +777,8 @@ fd_topo_initialize( config_t * config ) {
784777
/**/ fd_topob_tile_out( topo, "replay", 0UL, "replay_notif", 0UL );
785778

786779
if( enable_rpc ) {
787-
fd_topob_tile_in( topo, "rpcsrv", 0UL, "metric_in", "replay_notif", 0UL, FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED );
788-
fd_topob_tile_in( topo, "rpcsrv", 0UL, "metric_in", "stake_out", 0UL, FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED );
789-
FOR(shred_tile_cnt) fd_topob_tile_in( topo, "rpcsrv", 0UL, "metric_in", "shred_rpcsrv", i, FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED );
790-
FOR(shred_tile_cnt) fd_topob_tile_out( topo, "shred", i, "shred_rpcsrv", i );
780+
fd_topob_tile_in( topo, "rpcsrv", 0UL, "metric_in", "replay_notif", 0UL, FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED );
781+
fd_topob_tile_in( topo, "rpcsrv", 0UL, "metric_in", "stake_out", 0UL, FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED );
791782
}
792783

793784
/* For now the only plugin consumer is the GUI */

0 commit comments

Comments
 (0)