work

Author: asiegel-jt

src/discof/rpcserver/fd_rpc_service.h

@@ -4,6 +4,8 @@
 #include "../replay/fd_replay_notif.h"
 #include "../../flamenco/leaders/fd_multi_epoch_leaders.h"
 #include "../../waltz/http/fd_http_server.h"
+#include "../../disco/store/fd_store.h"
+#include "../../discof/reasm/fd_reasm.h"
 
 #include <netinet/in.h>
 
@@ -12,6 +14,7 @@ typedef struct fd_rpc_ctx fd_rpc_ctx_t;
 struct fd_rpcserver_args {
   int                        offline;
   fd_funk_t                  funk[1];
+  fd_store_t *               store;
   ushort                     port;
   fd_http_server_params_t    params;
   struct sockaddr_in         tpu_addr;

src/discof/rpcserver/fd_rpcserv_tile.c

@@ -233,6 +233,10 @@ unprivileged_init( fd_topo_t *      topo,
   if( FD_UNLIKELY( !fd_funk_join( args->funk, fd_topo_obj_laddr( topo, tile->rpcserv.funk_obj_id ) ) ) ) {
     FD_LOG_ERR(( "Failed to join database cache" ));
   }
+
+  args->store = fd_store_join( fd_topo_obj_laddr( topo, tile->rpcserv.store_obj_id ) );
+  FD_TEST( args->store->magic == FD_STORE_MAGIC );
+
   fd_rpc_start_service( args, ctx->ctx );
 }