Skip to content

Conversation

@tezc
Copy link
Owner

@tezc tezc commented Jun 29, 2025

Changes:

  • Initial implementation for filtered repl stream delivery to destination node
  • Initial write pause
  • Fixes for crashes & code refactor

TODO:

  • Write pause time limit
  • Tests

@tezc tezc changed the title Cluster asm pause Add basic filtered replication and write pause Jun 29, 2025
@tezc tezc marked this pull request as ready for review June 30, 2025 00:27
@tezc tezc requested a review from ShooterIT June 30, 2025 00:28
Copy link
Collaborator

@ShooterIT ShooterIT left a comment

Choose a reason for hiding this comment

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

excellent work!

/* Add main channel client to the list of slaves */
client *main_ch_client = task->main_channel_client;
main_ch_client->flags |= CLIENT_SLAVE;
main_ch_client->flags |= (CLIENT_SLAVE | CLIENT_REPL_MIGRATION_DEST);
Copy link
Collaborator

Choose a reason for hiding this comment

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

for your approach, maybe we don't mark this client as slave, so can revert my several changes, let me try it later

Copy link
Owner Author

Choose a reason for hiding this comment

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

yes, I initially did it that way. Either approach is possible but not sure which one is better. In one sense, this is a slave and makes sense to mark as SLAVE. Though, it causes some problems when you don't want to forward from replication backlog directly and had to mitigate this way.

Copy link
Collaborator

Choose a reason for hiding this comment

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

OK, i see, we can decide later

@tezc tezc merged commit 5f7889a into cluster-asm Jun 30, 2025
30 checks passed
@tezc tezc deleted the cluster-asm-pause branch June 30, 2025 23:30
tezc added a commit that referenced this pull request Sep 10, 2025
Add basic filtered replication and write pause

Changes:

Initial implementation for filtered repl stream delivery to destination node
Initial write pause
Fixes for crashes & code refactor
TODO:

Write pause time limit
Tests
tezc added a commit that referenced this pull request Sep 16, 2025
Add basic filtered replication and write pause

Changes:

Initial implementation for filtered repl stream delivery to destination node
Initial write pause
Fixes for crashes & code refactor
TODO:

Write pause time limit
Tests
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.

3 participants