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: Add TRUNCATE verb handler

Browse Source
This commit is contained in:
Calle Wilund
2015-09-28 13:59:01 +02:00
committed by Calle Wilund
parent 37131fcc05
commit 80ade2e2d3
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

@@ -2529,6 +2529,11 @@ void storage_proxy::init_messaging_service() {
return p->query_singular_local_digest(cmd, pr);
});
});
ms.register_truncate([](sstring ksname, sstring cfname) {
return get_storage_proxy().invoke_on_all([ksname, cfname](storage_proxy& sp) {
return sp._db.local().truncate(ksname, cfname);
});
});
}
void storage_proxy::uninit_messaging_service() {
@@ -2540,6 +2545,7 @@ void storage_proxy::uninit_messaging_service() {
ms.unregister_read_data();
ms.unregister_read_mutation_data();
ms.unregister_read_digest();
ms.unregister_truncate();
}
// Merges reconcilable_result:s from different shards into one