summaryrefslogtreecommitdiffstats
path: root/searchcore/src/vespa/searchcore/proton/matching/match_master.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchcore/src/vespa/searchcore/proton/matching/match_master.cpp')
-rw-r--r--searchcore/src/vespa/searchcore/proton/matching/match_master.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/matching/match_master.cpp b/searchcore/src/vespa/searchcore/proton/matching/match_master.cpp
index eefb8411df2..063666e9cad 100644
--- a/searchcore/src/vespa/searchcore/proton/matching/match_master.cpp
+++ b/searchcore/src/vespa/searchcore/proton/matching/match_master.cpp
@@ -103,7 +103,6 @@ MatchMaster::match(search::engine::Trace & trace,
DocidRangeScheduler::UP scheduler = createScheduler(threadBundle.size(), numSearchPartitions, params.numDocs);
std::vector<MatchThread::UP> threadState;
- std::vector<vespalib::Runnable*> targets;
for (size_t i = 0; i < threadBundle.size(); ++i) {
IMatchLoopCommunicator &com = (i == 0)
? static_cast<IMatchLoopCommunicator&>(timedCommunicator)
@@ -111,10 +110,9 @@ MatchMaster::match(search::engine::Trace & trace,
threadState.emplace_back(std::make_unique<MatchThread>(i, threadBundle.size(), params, mtf, com, *scheduler,
resultProcessor, mergeDirector, distributionKey,
trace.getRelativeTime(), trace.getLevel(), trace.getProfileDepth()));
- targets.push_back(threadState.back().get());
}
resultProcessor.prepareThreadContextCreation(threadBundle.size());
- threadBundle.run(targets);
+ threadBundle.run(threadState);
auto reply = make_reply(mtf, resultProcessor, threadBundle, threadState[0]->extract_result());
double query_time_s = vespalib::to_s(query_latency_time.elapsed());
double rerank_time_s = vespalib::to_s(timedCommunicator.elapsed);