storage_proxy: Enforce partition_limit

This patch enforces the partition_limit at the
mutation_result_merger.

Ref #693

Signed-off-by: Duarte Nunes <duarte@scylladb.com>
Message-Id: <1470065526-3174-1-git-send-email-duarte@scylladb.com>
This commit is contained in:
Duarte Nunes
2016-08-01 15:32:06 +00:00
committed by Paweł Dziepak
parent 9f35e4d328
commit 141ea49e05

View File

@@ -3434,7 +3434,7 @@ public:
_runs.pop_back();
}
}
if (_runs.empty() || row_count >= _cmd->row_limit) {
if (_runs.empty() || row_count >= _cmd->row_limit || partitions.size() >= _cmd->partition_limit) {
ret = reconcilable_result(row_count, std::move(partitions));
}
return make_ready_future<std::experimental::optional<reconcilable_result>>(std::move(ret));