mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-23 04:03:49 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

eth: divide test cases and verify with exact values (#4691)

Browse Source
This commit is contained in:
nanevardanyan 2022-07-11 15:56:00 +04:00 committed by GitHub
parent 8a75033b98
commit d8b2077aef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 39 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
eth/stagedsync/stage_log_index_test.go
View File

@ -90,8 +90,8 @@ func genReceipts(t *testing.T, tx kv.RwTx, blocks uint64) (map[common.Address]ui
return expectAddrs, expectTopics
}
func TestLogIndex(t *testing.T) {
require, tmpDir, ctx := require.New(t), t.TempDir(), context.Background()
func TestPromoteLogIndex(t *testing.T) {
require, ctx := require.New(t), context.Background()
_, tx := memdb.NewTestTx(t)
expectAddrs, expectTopics := genReceipts(t, tx, 100)
@ -100,6 +100,7 @@ func TestLogIndex(t *testing.T) {
cfgCopy := cfg
cfgCopy.bufLimit = 10
cfgCopy.flushEvery = time.Nanosecond
err := promoteLogIndex("logPrefix", tx, 0, cfgCopy, ctx)
require.NoError(err)
@ -114,6 +115,20 @@ func TestLogIndex(t *testing.T) {
require.NoError(err)
require.Equal(expect, m.GetCardinality())
}
}
func TestPruneLogIndex(t *testing.T) {
require, tmpDir, ctx := require.New(t), t.TempDir(), context.Background()
_, tx := memdb.NewTestTx(t)
_, _ = genReceipts(t, tx, 100)
cfg := StageLogIndexCfg(nil, prune.DefaultMode, "")
cfgCopy := cfg
cfgCopy.bufLimit = 10
cfgCopy.flushEvery = time.Nanosecond
err := promoteLogIndex("logPrefix", tx, 0, cfgCopy, ctx)
require.NoError(err)
// Mode test
err = pruneLogIndex("", tx, tmpDir, 50, ctx)
@ -122,23 +137,41 @@ func TestLogIndex(t *testing.T) {
{
total := 0
err = tx.ForEach(kv.LogAddressIndex, nil, func(k, v []byte) error {
require.True(binary.BigEndian.Uint32(k[length.Addr:]) >= 50)
require.True(binary.BigEndian.Uint32(k[length.Addr:]) == 4294967295)
total++
return nil
})
require.NoError(err)
require.True(total > 0)
require.True(total == 3)
}
{
total := 0
err = tx.ForEach(kv.LogTopicIndex, nil, func(k, v []byte) error {
require.True(binary.BigEndian.Uint32(k[length.Hash:]) >= 50)
require.True(binary.BigEndian.Uint32(k[length.Hash:]) == 4294967295)
total++
return nil
})
require.NoError(err)
require.True(total > 0)
require.True(total == 3)
}
}
func TestUnwindLogIndex(t *testing.T) {
require, tmpDir, ctx := require.New(t), t.TempDir(), context.Background()
_, tx := memdb.NewTestTx(t)
expectAddrs, expectTopics := genReceipts(t, tx, 100)
cfg := StageLogIndexCfg(nil, prune.DefaultMode, "")
cfgCopy := cfg
cfgCopy.bufLimit = 10
cfgCopy.flushEvery = time.Nanosecond
err := promoteLogIndex("logPrefix", tx, 0, cfgCopy, ctx)
require.NoError(err)
// Mode test
err = pruneLogIndex("", tx, tmpDir, 50, ctx)
require.NoError(err)
// Unwind test
err = unwindLogIndex("logPrefix", tx, 70, cfg, nil)