2343
) *persistencespb.ShardInfo {
2344
if shardInfo.QueueStates != nil && shardInfo.QueueStates[int32(tasks.CategoryIDReplication)] != nil {
2345
>
for readerID := range shardInfo.QueueStates[int32(tasks.CategoryIDReplication)].ReaderStates {
context_impl.go
2346
>
clusterID, _ := ReplicationReaderIDToClusterShardID(readerID)
2347
>
_, clusterInfo, found := clusterNameInfoFromClusterID(allClusterInfo, clusterID)
2348
>
if !found || !cluster.IsReplicationEnabledForCluster(clusterInfo, cfg.EnableSeparateReplicationEnableFlag()) {
2349
>
delete(shardInfo.QueueStates[int32(tasks.CategoryIDReplication)].ReaderStates, readerID)
2350
>
}
2351
}
2352
>
if len(shardInfo.QueueStates[int32(tasks.CategoryIDReplication)].ReaderStates) == 0 {
context_impl.go
2353
>
delete(shardInfo.QueueStates, int32(tasks.CategoryIDReplication))
2354
>
}
2355
}
2356
return shardInfo