Repair & Sign: async repair requests

Author: npatel-jump

src/discof/repair/fd_repair_tile.c

@@ -130,6 +130,8 @@ struct fd_repair_tile_ctx {
 
   fd_wksp_t * wksp;
 
+  fd_stem_context_t * stem;
+
   uchar              in_kind[ MAX_IN_LINKS ];
   fd_repair_in_ctx_t in_links[ MAX_IN_LINKS ];
 
@@ -670,7 +672,7 @@ during_frag( fd_repair_tile_ctx_t * ctx,
   fd_memcpy( ctx->buffer, dcache_entry, dcache_entry_sz );
 }
 
-static ulong
+static ulong FD_FN_UNUSED
 fd_repair_send_ping( fd_repair_tile_ctx_t        * repair_tile_ctx,
                      fd_repair_t                 * glob,
                      fd_pinged_elem_t            * val,
@@ -697,7 +699,7 @@ fd_repair_send_ping( fd_repair_tile_ctx_t        * repair_tile_ctx,
   return (ulong)((uchar*)ctx.data - buf);
 }
 
-static void
+static void FD_FN_UNUSED
 fd_repair_recv_pong(fd_repair_t * glob, fd_gossip_ping_t const * pong, fd_gossip_peer_addr_t const * from) {
   fd_pinged_elem_t * val = fd_pinged_table_query(glob->pinged, from, NULL);
   if( val == NULL || !fd_pubkey_eq( &val->id, &pong->from ) )
@@ -747,6 +749,8 @@ after_frag( fd_repair_tile_ctx_t * ctx,
 
   if( FD_UNLIKELY( ctx->skip_frag ) ) return;
 
+  ctx->stem = stem;
+
   uint in_kind = ctx->in_kind[ in_idx ];
   // FD_LOG_INFO(( "in_idx: %lu, in_kind: %u", in_idx, in_kind ));
   if( FD_UNLIKELY( in_kind==IN_KIND_CONTACT ) ) {
@@ -768,7 +772,7 @@ after_frag( fd_repair_tile_ctx_t * ctx,
        sign tile will be returned. Since the repair_sign links are
        reliable, the incoming sign_repair fragments represent a complete
        set of the previously sent outgoing messages. However, with
-       multiple sign tiles, the responses may not arrive in order. But, 
+       multiple sign tiles, the responses may not arrive in order. But,
        we can safely process them sequentially as we encounter them in
        the deque. */
     while( !fd_repair_pending_sign_req_deque_empty( ctx->pending_sign_req_deque ) ) {