save

cl/antiquary/state_antiquary.go

@@ -357,6 +357,7 @@ func (s *Antiquary) IncrementBeaconState(ctx context.Context, to uint64) error {
 		return err
 	}
 	defer rwTx.Rollback()
+
 	start = time.Now()
 	// We now need to store the state
 	if err := stateAntiquaryCollector.flush(ctx, rwTx); err != nil {
@@ -392,6 +393,7 @@ func (s *Antiquary) IncrementBeaconState(ctx context.Context, to uint64) error {
 	if err != nil {
 		return err
 	}
+	//s.validatorsTable.SetSlot(s.currentState.Slot())
 	log.Info("Historical states antiquated", "slot", s.currentState.Slot(), "root", libcommon.Hash(stateRoot), "latency", endTime)
 	return nil
 }
@@ -473,6 +475,5 @@ func computeSlotToBeRequested(tx kv.Tx, cfg *clparams.BeaconChainConfig, genesis
 	if targetSlot > clparams.SlotsPerDump*backoffStep {
 		return findNearestSlotBackwards(tx, cfg, targetSlot-clparams.SlotsPerDump*backoffStep)
 	}
-	fmt.Println(genesisSlot)
 	return genesisSlot, nil
 }

cl/persistence/state/historical_states_reader/historical_states_reader_test.go

@@ -2,6 +2,7 @@ package historical_states_reader_test
 
 import (
 	"context"
+	"fmt"
 	"testing"
 
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
@@ -41,6 +42,7 @@ func runTest(t *testing.T, blocks []*cltypes.SignedBeaconBlock, preState, postSt
 	require.NoError(t, err)
 	_, err = postState.HashSSZ()
 	require.NoError(t, err)
+	fmt.Println(s.Validators().Get(0).PublicKey(), postState.Validators().Get(0).PublicKey())
 	require.Equal(t, libcommon.Hash(postHash), blocks[len(blocks)-1].Block.StateRoot)
 }
 

cl/persistence/state/static_validator_table.go

@@ -421,7 +421,9 @@ func (s *StaticValidatorTable) GetStaticValidator(validatorIndex uint64) *Static
 func (s *StaticValidatorTable) SetSlot(slot uint64) {
 	s.sync.Lock()
 	defer s.sync.Unlock()
-	s.resetTable(slot)
+	if slot <= s.slot && s.slot != 0 {
+		return
+	}
 	s.slot = slot
 }