summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2021-10-21 06:56:17 +0000
committerArne H Juul <arnej@yahooinc.com>2021-10-21 06:56:17 +0000
commit95bc5d408d9e8ff1383373d61ff69a0682535bcc (patch)
treefd45017dad8324dbd504d92f5b1922c9c6a94091
parentc32dbc49fc180281abc095a3f127596cf857a7b0 (diff)
log unhandled issues
-rw-r--r--searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp4
-rw-r--r--searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp4
2 files changed, 8 insertions, 0 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp b/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp
index a6c1b6b1f72..5ad4a7ed52b 100644
--- a/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp
+++ b/searchcore/src/vespa/searchcore/proton/matchengine/matchengine.cpp
@@ -149,6 +149,10 @@ MatchEngine::performSearch(search::engine::SearchRequest::Source req)
ret->request = req.release();
if (_forward_issues) {
ret->my_issues = std::move(my_issues);
+ } else {
+ my_issues->for_each_message([](const auto &msg){
+ LOG(warning, "unhandled issue: %s", msg.c_str());
+ });
}
ret->setDistributionKey(_distributionKey);
if ((ret->request->trace().getLevel() > 0) && ret->request->trace().hasTrace()) {
diff --git a/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp b/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp
index 1e488fd6dfe..95643c7d1a8 100644
--- a/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp
+++ b/searchcore/src/vespa/searchcore/proton/summaryengine/summaryengine.cpp
@@ -148,6 +148,10 @@ SummaryEngine::getDocsums(DocsumRequest::UP req)
reply->setRequest(std::move(req));
if (_forward_issues) {
reply->setIssues(std::move(my_issues));
+ } else {
+ my_issues->for_each_message([](const auto &msg){
+ LOG(warning, "unhandled issue: %s", msg.c_str());
+ });
}
return reply;
}