Function TestReadWriteBlocks

cmd/cql-fuse/block_test.go:460–568

(t *testing.T)

}

func TestReadWriteBlocks(t *testing.T) {

	id := uint64(10)
	rng, _ := NewPseudoRand()
	length := BlockSize*3 + 500
	part1 := RandBytes(rng, length)

	if err := write(db, id, 0, 0, part1); err != nil {
		log.Fatal(err)
	}

	readData, err := read(db, id, 0, uint64(length))
	if err != nil {
		log.Fatal(err)
	}
	if !bytes.Equal(part1, readData) {
		t.Errorf("bytes differ. lengths: %d, expected %d", len(readData), len(part1))
	}

	verboseData, err := getAllBlocks(db, id)
	if err != nil {
		log.Fatal(err)
	}
	if !bytes.Equal(verboseData, part1) {
		t.Errorf("bytes differ. lengths: %d, expected %d", len(verboseData), len(part1))
	}

	// Write with hole in the middle.
	part2 := make([]byte, BlockSize*2+250, BlockSize*2+250)
	fullData := append(part1, part2...)
	part3 := RandBytes(rng, BlockSize+123)
	if err := write(db, id, uint64(len(part1)), uint64(len(fullData)), part3); err != nil {
		log.Fatal(err)
	}
	fullData = append(fullData, part3...)
	readData, err = read(db, id, 0, uint64(len(fullData)))
	if err != nil {
		log.Fatal(err)
	}
	if !bytes.Equal(fullData, readData) {
		t.Errorf("bytes differ. lengths: %d, expected %d", len(readData), len(fullData))
	}

	verboseData, err = getAllBlocks(db, id)
	if err != nil {
		log.Fatal(err)
	}
	if !bytes.Equal(verboseData, fullData) {
		t.Errorf("bytes differ. lengths: %d, expected %d", len(verboseData), len(fullData))
	}

	// Now write into the middle of the file.
	part2 = RandBytes(rng, len(part2))
	if err := write(db, id, uint64(len(fullData)), uint64(len(part1)), part2); err != nil {
		log.Fatal(err)
	}
	fullData = append(part1, part2...)
	fullData = append(fullData, part3...)