Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

IGNITE-22621 Implement transaction storage for the zone replica listener #5187

Merged
merged 28 commits into from
Feb 11, 2025

Conversation

rpuch
Copy link
Contributor

@rpuch rpuch commented Feb 6, 2025

@rpuch rpuch marked this pull request as draft February 7, 2025 06:34
@rpuch rpuch force-pushed the ignite-22621 branch 6 times, most recently from 824c6ac to fd09468 Compare February 7, 2025 11:56
@rpuch rpuch marked this pull request as ready for review February 7, 2025 12:24
@@ -460,37 +460,44 @@ void txFinishCommandGetsReplicated(boolean commit) throws Exception {
));
}

List<CountExpectation> expectations = new ArrayList<>();
List<Executable> assertions = new ArrayList<>();
for (int i = 0; i < cluster.size(); i++) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

You can use IntStream.range().collect(toList()) here instead of a cycle, this will save some code, like finalI. Current approach is also fine.

@@ -526,24 +537,45 @@ private CompletableFuture<?> createZonePartitionReplicationNode(
rebalanceRetryDelayConfiguration
);

var safeTimeTracker = new SafeTimeValuesTracker(HybridTimestamp.MIN_VALUE);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Shall we move all this stuff inside the Supplier as well?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why not? Its only used inside it

@rpuch rpuch merged commit 9e3d7c4 into apache:main Feb 11, 2025
1 check passed
@rpuch rpuch deleted the ignite-22621 branch February 11, 2025 10:34
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants