work

Author: asiegel-jt

src/discof/rpcserver/fd_rpc_history.c

@@ -313,6 +313,7 @@ fd_rpc_history_save_shred(fd_rpc_history_t * hist, fd_shred_t * shred) {
     shred_map->head = shred->slot+1;
     shred_map->tail = shred->slot;
   }
+  if( shred->slot < shred_map->tail ) return; /* Do not go backwards */
   while( shred->slot >= shred_map->tail + FD_SHRED_MAP_COL_CNT ) {
     FD_TEST( shred_map->tail < shred_map->head );
     fd_rpc_history_discard_column( shred_map, shred_pool, shred_map->tail++ );
@@ -324,6 +325,7 @@ fd_rpc_history_save_shred(fd_rpc_history_t * hist, fd_shred_t * shred) {
     col->used_cnt = 0;
     col->end_found = 0;
   }
+  FD_TEST( shred->slot >= shred_map->tail && shred->slot < shred_map->head && shred_map->head - shred_map->tail <= FD_SHRED_MAP_COL_CNT );
 
   ulong col_idx = shred->slot & (FD_SHRED_MAP_COL_CNT - 1);
   struct fd_rpc_shred_map_column * col = &shred_map->cols[col_idx];