Method updateLocalMetas

ethstorage/storage_manager.go:512–526

This function is only called by DownloadFinished which already uses s.mu to protect the s.blobMetas, so we don't need to lock in this function

(kvIndices []uint64, commits []common.Hash)

// This function is only called by DownloadFinished which already uses s.mu to protect the s.blobMetas, so
// we don't need to lock in this function
func (s *StorageManager) updateLocalMetas(kvIndices []uint64, commits []common.Hash) {
	for i, idx := range kvIndices {
		meta := [32]byte{}
		new(big.Int).SetInt64(int64(idx)).FillBytes(meta[0:5])
		copy(meta[32-HashSizeInContract:32], commits[i][0:HashSizeInContract])

		s.blobMetas[idx] = meta
	}

	// In case the kvEntryCount is smaller than old kvEntryCount because of removal, we need to remove those metas
	LocalMetaLen := len(s.blobMetas)
	for i := int(s.kvEntryCount); i < LocalMetaLen; i++ {
		delete(s.blobMetas, uint64(i))
	}
}

// Please note that the caller function must uses s.mu to protect the s.blobMetas reading in this function
func (s *StorageManager) getKvMetas(kvIndices []uint64) ([][32]byte, error) {