mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

repair: Make send_repair_checksum_range timeout

Browse Source 
If the verb never returns the repair will hangs forever. Make it use the
timeout version of the send_message.

Fixes #2662
This commit is contained in:
Asias He
2017-08-02 15:28:58 +08:00
parent a548eee28c
commit 98757069a5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
message/messaging_service.cc
View File

@@ -964,8 +964,8 @@ void messaging_service::unregister_repair_checksum_range() {
future<partition_checksum> messaging_service::send_repair_checksum_range(
msg_addr id, sstring keyspace, sstring cf, ::dht::token_range range, repair_checksum hash_version)
{
return send_message<partition_checksum>(this,
messaging_verb::REPAIR_CHECKSUM_RANGE, std::move(id),
return send_message_timeout<partition_checksum>(this,
messaging_verb::REPAIR_CHECKSUM_RANGE, std::move(id), streaming_timeout,
std::move(keyspace), std::move(cf), std::move(range), hash_version);
}