(shardIdx uint64)
| 111 | } |
| 112 | |
| 113 | func (sm *ShardManager) AddDataShard(shardIdx uint64) error { |
| 114 | if _, ok := sm.shardMap[shardIdx]; !ok { |
| 115 | ds := NewDataShard(shardIdx, sm.kvSize, sm.kvEntries, sm.chunkSize) |
| 116 | sm.shardMap[shardIdx] = ds |
| 117 | return nil |
| 118 | } else { |
| 119 | return fmt.Errorf("data shard already exists") |
| 120 | } |
| 121 | } |
| 122 | |
| 123 | func (sm *ShardManager) AddDataFile(df *DataFile) error { |
| 124 | shardIdx := df.chunkIdxStart / sm.chunksPerKv / sm.kvEntries |