Avoided the crash due to later messages for a removed query.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/07b28b19 Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/07b28b19 Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/07b28b19 Branch: refs/heads/unordered_msg_bug_fix Commit: 07b28b19224d48c1f6a08ee03b53d17dc7d349e0 Parents: 266b9b9 Author: Zuyu Zhang <zu...@apache.org> Authored: Wed Feb 8 18:04:49 2017 -0800 Committer: Zuyu Zhang <zu...@apache.org> Committed: Wed Feb 8 18:04:49 2017 -0800 ---------------------------------------------------------------------- query_execution/PolicyEnforcerDistributed.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/07b28b19/query_execution/PolicyEnforcerDistributed.cpp ---------------------------------------------------------------------- diff --git a/query_execution/PolicyEnforcerDistributed.cpp b/query_execution/PolicyEnforcerDistributed.cpp index ef5abb0..7e1958c 100644 --- a/query_execution/PolicyEnforcerDistributed.cpp +++ b/query_execution/PolicyEnforcerDistributed.cpp @@ -142,7 +142,9 @@ void PolicyEnforcerDistributed::processInitiateRebuildResponseMessage(const tmb: CHECK(proto.ParseFromArray(tagged_message.message(), tagged_message.message_bytes())); const std::size_t query_id = proto.query_id(); - DCHECK(admitted_queries_.find(query_id) != admitted_queries_.end()); + if (admitted_queries_.find(query_id) == admitted_queries_.end()) { + return; + } QueryManagerDistributed *query_manager = static_cast<QueryManagerDistributed*>(admitted_queries_[query_id].get());
