(df *DataFile)
| 121 | } |
| 122 | |
| 123 | func (sm *ShardManager) AddDataFile(df *DataFile) error { |
| 124 | shardIdx := df.chunkIdxStart / sm.chunksPerKv / sm.kvEntries |
| 125 | var ds *DataShard |
| 126 | var ok bool |
| 127 | if ds, ok = sm.shardMap[shardIdx]; !ok { |
| 128 | return fmt.Errorf("data shard not found") |
| 129 | } |
| 130 | |
| 131 | return ds.AddDataFile(df) |
| 132 | } |
| 133 | |
| 134 | func (sm *ShardManager) AddDataFileAndShard(df *DataFile) error { |
| 135 | shardIdx := df.chunkIdxStart / sm.chunksPerKv / sm.kvEntries |