409
ackTaskID int64,
410
ackTimestamp time.Time,
412
>
s.wLock()
413
>
defer s.wUnlock()
414
>
415
>
clusterInfo := s.clusterMetadata.GetAllClusterInfo()
416
>
remoteClusterInfo := s.getOrUpdateRemoteClusterInfoLocked(clusterName)
417
>
for _, remoteShardID := range common.MapShardID(
418
>
clusterInfo[s.clusterMetadata.GetCurrentClusterName()].ShardCount,
419
>
clusterInfo[clusterName].ShardCount,
420
>
s.shardID,
421
>
) {
422
>
remoteClusterInfo.AckedReplicationTaskIDs[remoteShardID] = ackTaskID
423
>
remoteClusterInfo.AckedReplicationTimestamps[remoteShardID] = ackTimestamp
424
>
}
425
}
426