()
| 318 | } |
| 319 | |
| 320 | func (sm *ShardManager) IsComplete() error { |
| 321 | for _, ds := range sm.shardMap { |
| 322 | if !ds.IsComplete() { |
| 323 | return fmt.Errorf("shard %d is not complete", ds.shardIdx) |
| 324 | } |
| 325 | } |
| 326 | return nil |
| 327 | } |
| 328 | |
| 329 | func (sm *ShardManager) Close() error { |
| 330 | for _, ds := range sm.shardMap { |
no outgoing calls