Method initStorageManager

ethstorage/node/node.go:236–266

(ctx context.Context, cfg *Config)

}

func (n *EsNode) initStorageManager(ctx context.Context, cfg *Config) error {
	shardManager := ethstorage.NewShardManager(cfg.Storage.L1Contract, cfg.Storage.KvSize, cfg.Storage.KvEntriesPerShard, cfg.Storage.ChunkSize)
	for _, filename := range cfg.Storage.Filenames {
		var err error
		var df *ethstorage.DataFile
		df, err = ethstorage.OpenDataFile(filename)
		if err != nil {
			return fmt.Errorf("open failed: %w", err)
		}
		if df.Miner() != cfg.Storage.Miner {
			n.lg.Error("Miners mismatch", "fromDataFile", df.Miner(), "fromConfig", cfg.Storage.Miner)
			return fmt.Errorf("miner mismatches datafile")
		}
		shardManager.AddDataFileAndShard(df)
	}

	if shardManager.IsComplete() != nil {
		return fmt.Errorf("shard is not completed")
	}

	n.lg.Info("Initialized storage",
		"miner", cfg.Storage.Miner,
		"l1contract", cfg.Storage.L1Contract,
		"kvSize", shardManager.MaxKvSize(),
		"chunkSize", shardManager.ChunkSize(),
		"kvsPerShard", shardManager.KvEntries(),
		"shards", shardManager.ShardIds())

	n.storageManager = ethstorage.NewStorageManager(shardManager, n.l1Source, n.lg)
	return nil
}

func (n *EsNode) initRPCServer(ctx context.Context, cfg *Config) error {
	server, err := newRPCServer(ctx, &cfg.RPC, cfg.ChainID, n.storageManager, n.downloader, n.lg, n.appVersion)