sanpwc commented on code in PR #5407:
URL: https://github.com/apache/ignite-3/pull/5407#discussion_r1995641150
##########
modules/table/src/testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java:
##########
@@ -836,6 +845,210 @@ private static String extractConsistentId(ClusterService
nodeService) {
return nodeService.topologyService().localMember().name();
}
+ /**
+ * If colocation is enabled given method creates zone raft listener for
specific zone partition if it wasn't created previously and
+ * populate it with table raft processor. If colocation is disabled given
method will create table raft listener.
+ */
+ // TODO https://issues.apache.org/jira/browse/IGNITE-24798 Simplify after
switching main towards colocation.
+ private RaftGroupListener getOrCreateAndPopulateRaftGroupListener(
+ String assignment,
+ int zoneId,
+ int partId,
+ int tableId,
+ PartitionDataStorage partitionDataStorage,
+ StorageUpdateHandler storageUpdateHandler,
+ TxStatePartitionStorage txStateStorage,
+ SafeTimeValuesTracker safeTimeTracker,
+ PendingComparableValuesTracker<Long, Void> storageIndexTracker,
+ CatalogService catalogService,
+ SchemaRegistry schemaRegistry
+ ) {
+ if (enabledColocation()) {
+ ZonePartitionId zonePartitionId = new ZonePartitionId(zoneId,
partId);
+
+ var nodeSpecificZonePartitionRaftGroupListeners =
zonePartitionRaftGroupListeners.computeIfAbsent(assignment,
Review Comment:
Done.
--
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]
