logging

Author: asiegel-jt

src/discof/rpcserver/fd_rpcserv_tile.c

@@ -26,6 +26,7 @@ typedef union {
     ulong       chunk0;
     ulong       wmark;
     ulong       mtu;
+    ulong       last_seq;
   };
 } fd_rpcserv_in_ctx_t;
 
@@ -125,13 +126,18 @@ after_frag( fd_rpcserv_tile_ctx_t * ctx,
             ulong                  tsorig,
             ulong                  tspub,
             fd_stem_context_t *    stem ) {
-  (void)seq;
   (void)sig;
   (void)sz;
   (void)tsorig;
   (void)tspub;
   (void)stem;
 
+  ulong * last_seq = &ctx->in_links[ in_idx ].last_seq;
+  if( seq != *last_seq + 1 ) {
+    FD_LOG_NOTICE(( "seq jump from %lu to %lu on input %lu", *last_seq, seq, in_idx ));
+  }
+  *last_seq = seq;
+
   uchar kind = ctx->in_kind[ in_idx ];
   if( FD_UNLIKELY( kind==IN_KIND_REPLAY_NOTIF ) ) {
     fd_rpc_replay_after_frag( ctx->ctx, &ctx->replay_notif_in_state );
@@ -223,6 +229,7 @@ unprivileged_init( fd_topo_t *      topo,
     ctx->in_links[ in_idx ].chunk0 = fd_dcache_compact_chunk0( ctx->in_links[ in_idx ].mem, link->dcache );
     ctx->in_links[ in_idx ].wmark  = fd_dcache_compact_wmark ( ctx->in_links[ in_idx ].mem, link->dcache, link->mtu );
     ctx->in_links[ in_idx ].mtu    = link->mtu;
+    ctx->in_links[ in_idx ].last_seq = 0;
     FD_TEST( fd_dcache_compact_is_safe( ctx->in_links[in_idx].mem, link->dcache, link->mtu, link->depth ) );
    }