| 17 | ) |
| 18 | |
| 19 | func createSstorage(shardIdxList []uint64, cfg storage.StorageConfig, lg log.Logger) { |
| 20 | files := make([]string, 0) |
| 21 | for _, shardIdx := range shardIdxList { |
| 22 | fileName := fmt.Sprintf(".\\ss%d.dat", shardIdx) |
| 23 | files = append(files, fileName) |
| 24 | chunkPerfile := cfg.KvSize / cfg.ChunkSize |
| 25 | startChunkId := shardIdx * cfg.KvEntriesPerShard * chunkPerfile |
| 26 | _, err := ethstorage.Create(fileName, startChunkId, chunkPerfile*cfg.KvEntriesPerShard, 0, cfg.KvSize, |
| 27 | ethstorage.ENCODE_ETHASH, cfg.Miner, cfg.ChunkSize) |
| 28 | if err != nil { |
| 29 | lg.Crit("Open failed", "error", err) |
| 30 | } |
| 31 | } |
| 32 | cfg.Filenames = files |
| 33 | } |
| 34 | |
| 35 | func test_InitDB(test *testing.T, dataDir string) { |
| 36 | var ( |