Function TestFillEmpty

ethstorage/p2p/protocol/sync_test.go:1211–1264

(t *testing.T)

}

func TestFillEmpty(t *testing.T) {
	var (
		kvSize      = defaultChunkSize
		kvEntries   = uint64(256)
		lastKvIndex = uint64(12)
		db          = rawdb.NewMemoryDatabase()
		mux         = new(event.Feed)
		shards      = []uint64{0}
		shardMap    = make(map[common.Address][]uint64)
		m           = metrics.NewMetrics("sync_test")
		chainID     = new(big.Int).SetUint64(3333)
	)

	metafile, err := CreateMetaFile(metafileName, int64(kvEntries))
	if err != nil {
		t.Error("Create metafileName fail", err.Error())
	}
	defer metafile.Close()

	shardMap[contract] = shards
	shardManager, files := createEthStorage(contract, shards, defaultChunkSize, kvSize, kvEntries, common.Address{}, defaultEncodeType)
	if shardManager == nil {
		t.Fatalf("createEthStorage failed")
	}
	defer func(files []string) {
		for _, file := range files {
			os.Remove(file)
		}
	}(files)

	makeKVStorage(contract, shards, defaultChunkSize, kvSize, kvEntries, lastKvIndex, common.Address{}, defaultEncodeType, metafile)

	l1 := NewMockL1Source(lastKvIndex, metafileName)
	sm := ethstorage.NewStorageManager(shardManager, l1, lg)
	sm.Reset(0)
	_, syncCl := createLocalHostAndSyncClient(t, chainID, db, sm, m, mux)
	syncCl.Start()
	for i := 0; i < 4; i++ {
		time.Sleep(500 * time.Millisecond)
		l1.lastBlobIndex = l1.lastBlobIndex + rand.Uint64()%(kvEntries/4)
		sm.Reset(1)
	}
	time.Sleep(8 * time.Second)

	if len(syncCl.tasks[0].SubEmptyTasks) > 0 {
		t.Fatalf("fill empty should be done")
	}
	if syncCl.tasks[0].state.EmptyToFill != 0 {
		t.Fatalf("emptyBlobsToFill should be 0, value %d", syncCl.tasks[0].state.EmptyToFill)
	}
	if syncCl.tasks[0].state.EmptyFilled != (kvEntries - lastKvIndex) {
		t.Fatalf("emptyBlobsFilled is wrong, expect %d, value %d", kvEntries-lastKvIndex, syncCl.tasks[0].state.EmptyFilled)
	}
}