Function TestReadWrite

ethstorage/p2p/protocol/sync_test.go:735–767

TestReadWrite tests a basic eth storage read/write

(t *testing.T)

// TestReadWrite tests a basic eth storage read/write
func TestReadWrite(t *testing.T) {
	var (
		kvSize    = defaultChunkSize
		kvEntries = uint64(16)
		val       = make([]byte, kvSize)
	)
	shards, files := createEthStorage(contract, []uint64{0}, defaultChunkSize, kvSize, kvEntries, common.Address{}, defaultEncodeType)
	if shards == nil {
		t.Fatalf("createEthStorage failed")
	}

	defer func(files []string) {
		for _, file := range files {
			os.Remove(file)
		}
	}(files)

	val[0] = 1
	root, _ := prover.GetRoot(val, 1, 1)
	commit := generateMetadata(root)
	sm := ethstorage.ContractToShardManager[contract]
	success, err := sm.TryWrite(0, val, commit)
	if !success || err != nil {
		t.Fatalf("failed to write")
	}
	rdata, success, err := sm.TryRead(0, 1, commit)
	if !success || err != nil {
		t.Fatalf("failed to read")
	}
	if !bytes.Equal([]byte{1}, rdata) {
		t.Fatalf("failed to compare")
	}
}

// testSync sync test with a general process:
// 1. create a storage manager and a local node, then start the sync client;