denis-chudov commented on code in PR #2036:
URL: https://github.com/apache/ignite-3/pull/2036#discussion_r1189567735
##########
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java:
##########
@@ -222,6 +267,30 @@ private void
onPlacementDriverMessageReceived(NetworkMessage msg0, String sender
}
}
+ /**
+ * Sends stop lease prolongation message to all participants of placement
driver group.
+ *
+ * @param groupId Replication group id.
+ * @param redirectNodeId Node consistent id to redirect.
+ */
+ private void stopLeaseProlongation(ReplicationGroupId groupId, String
redirectNodeId) {
+ LOG.info("The replica does not meet the requirements for the
leaseholder [groupId={}, redirectNodeId={}]", groupId, redirectNodeId);
+
+ msNodes.thenAccept(nodeIds -> {
+ for (String nodeId : nodeIds) {
+ ClusterNode node =
clusterNetSvc.topologyService().getByConsistentId(nodeId);
+
+ if (node != null) {
+ //TODO: IGNITE-19441 Stop lease prolongation message might
send severa times.
Review Comment:
```suggestion
//TODO: IGNITE-19441 Stop lease prolongation message
might be sent several times.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
