Method WriteWith

ethstorage/data_shard.go:360–381

Write a value of the KV to the store using a customized encoder.

(kvIdx uint64, b []byte, commit common.Hash, encoder func([]byte, uint64) []byte)

// Write a value of the KV to the store using a customized encoder.
func (ds *DataShard) WriteWith(kvIdx uint64, b []byte, commit common.Hash, encoder func([]byte, uint64) []byte) error {
	if !ds.Contains(kvIdx) {
		return fmt.Errorf("kv not found")
	}

	if uint64(len(b)) > ds.kvSize {
		return fmt.Errorf("write data too large")
	}
	cb := make([]byte, ds.kvSize)
	copy(cb, b)
	for i := uint64(0); i < ds.chunksPerKv; i++ {
		chunkIdx := kvIdx*ds.chunksPerKv + i
		encodedChunk := encoder(cb[int(i*ds.chunkSize):int((i+1)*ds.chunkSize)], chunkIdx)
		err := ds.writeChunk(chunkIdx, encodedChunk)

		if err != nil {
			return err
		}
	}
	// This is not atomic, but we should get error since we already pre-allocate the space
	return ds.WriteMeta(kvIdx, commit[:])
}

// Write a value of the KV to the store. The value will be encoded with kvIdx and SP address.
func (ds *DataShard) Write(kvIdx uint64, b []byte, commit common.Hash) error {