From 56e55cd2728ef13a23e423eeb513ca5c7aadd09e Mon Sep 17 00:00:00 2001 From: Asias He Date: Wed, 21 Oct 2015 15:36:52 +0800 Subject: [PATCH] storage_proxy: Register replication_finished verb handler --- service/storage_proxy.cc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/service/storage_proxy.cc b/service/storage_proxy.cc index 9e76aff56a..7cb3b34abd 100644 --- a/service/storage_proxy.cc +++ b/service/storage_proxy.cc @@ -2517,6 +2517,11 @@ void storage_proxy::init_messaging_service() { return sp._db.local().truncate(truncated_at, ksname, cfname); }); }); + + ms.register_replication_finished([] (gms::inet_address from) { + get_local_storage_service().confirm_replication(from); + return make_ready_future<>(); + }); } void storage_proxy::uninit_messaging_service() { @@ -2529,6 +2534,7 @@ void storage_proxy::uninit_messaging_service() { ms.unregister_read_mutation_data(); ms.unregister_read_digest(); ms.unregister_truncate(); + ms.unregister_replication_finished(); } // Merges reconcilable_result:s from different shards into one