431
ackTaskID int64,
432
ackTimestamp time.Time,
434
>
clusterID, shardID := ReplicationReaderIDToClusterShardID(readerID)
435
>
clusterName, _, ok := clusterNameInfoFromClusterID(s.clusterMetadata.GetAllClusterInfo(), clusterID)
436
>
if !ok {
437
// cluster is not present in cluster metadata map
438
return serviceerror.NewInternalf("unknown cluster ID: %v", clusterID)
439
}
440
442
>
defer s.wUnlock()
443
>
444
>
remoteClusterInfo := s.getOrUpdateRemoteClusterInfoLocked(clusterName)
445
>
remoteClusterInfo.AckedReplicationTaskIDs[shardID] = ackTaskID
446
>
remoteClusterInfo.AckedReplicationTimestamps[shardID] = ackTimestamp
447
>
return nil
448
}
449