diff options
author | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2016-09-02 15:53:39 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2016-09-02 15:53:39 +0200 |
commit | 9fbea00993c77b86967892d97016194fe9246bc6 (patch) | |
tree | 816acbd80ac0705b2314d7f8bd3e1360f07ada65 /storage | |
parent | eb35f0570d17e3d5b68b7ba42e212444f4c6093b (diff) |
Use correct thread count for visitor config propagation
We do not support live reconfig of thread counts. When the old code
attempted to index into the thread array based on the new config's
thread count, bad things unsurprisingly happened.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/visiting/visitormanager.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/storage/src/vespa/storage/visiting/visitormanager.cpp b/storage/src/vespa/storage/visiting/visitormanager.cpp index 3ef64c5c177..066d8c7c101 100644 --- a/storage/src/vespa/storage/visiting/visitormanager.cpp +++ b/storage/src/vespa/storage/visiting/visitormanager.cpp @@ -207,10 +207,10 @@ VisitorManager::configure(std::unique_ptr<vespa::config::content::core::StorVisi _maxFixedConcurrentVisitors = maxConcurrentVisitorsFixed; _maxVariableConcurrentVisitors = maxConcurrentVisitorsVariable; _maxVisitorQueueSize = config->maxvisitorqueuesize; - std::shared_ptr<PropagateVisitorConfig> cmd( - new PropagateVisitorConfig(*config)); - for (int32_t i=0; i<config->visitorthreads; ++i) { - _visitorThread[i].first->processMessage(0, cmd); + + auto cmd = std::make_shared<PropagateVisitorConfig>(*config); + for (auto& thread : _visitorThread) { + thread.first->processMessage(0, cmd); } } |