mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-09 16:33:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage_proxy: Register replication_finished verb handler

Browse Source
This commit is contained in:
Asias He
2015-10-21 15:36:52 +08:00
parent ffce7a7af8
commit 56e55cd272
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
service/storage_proxy.cc
View File

@@ -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