Method readWith

ethstorage/data_shard.go:190–216

readWith read the encoded data from storage with a decoder.

(kvIdx uint64, readLen int, decoder func([]byte, uint64) []byte)

// readWith read the encoded data from storage with a decoder.
func (ds *DataShard) readWith(kvIdx uint64, readLen int, decoder func([]byte, uint64) []byte) ([]byte, error) {
	if !ds.Contains(kvIdx) {
		return nil, fmt.Errorf("kv not found")
	}
	if readLen > int(ds.kvSize) {
		return nil, fmt.Errorf("read len too large")
	}
	var data []byte
	for i := uint64(0); i < ds.chunksPerKv; i++ {
		if readLen == 0 {
			break
		}

		chunkReadLen := min(readLen, int(ds.chunkSize))
		readLen = readLen - chunkReadLen

		chunkIdx := kvIdx*ds.chunksPerKv + i
		cdata, err := ds.readChunk(chunkIdx, chunkReadLen)
		if err != nil {
			return nil, err
		}

		cdata = decoder(cdata, chunkIdx)
		data = append(data, cdata...)
	}
	return data, nil
}

func (ds *DataShard) ReadSample(sampleIdx uint64) (common.Hash, error) {