mirror of
https://github.com/scylladb/scylladb.git
synced 2026-06-04 14:03:06 +00:00
The call chain is: storage_service::on_change() -> storage_service::handle_state_removing() -> storage_service::restore_replica_count() -> streamer->stream_async() Listeners run as part of gossip message processing, which is serialized. This means we won't be processing any gossip messages until streaming completes. In fact, there is no need to wait for restore_replica_count to complete which can take a long time, since when it completes, this node will send notification to tell the removal_coordinator that the restore process is finished on this node. This node will be removed from _replicating_nodes on the removal_coordinator. Tested with update_cluster_layout_tests.py Fixes #2886 Message-Id: <8b4fe637dfea6c56167ddde3ca86fefb8438ce96.1516088237.git.asias@scylladb.com>