diff options
| author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2023-08-15 14:12:15 +0000 |
|---|---|---|
| committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2023-08-16 11:12:35 +0000 |
| commit | 08508031f459dfe313581b2506d581977b171be0 (patch) | |
| tree | cf73bb40cc38f140c4a39defd1ec4ae41fbf31c1 /storage | |
| parent | 270252b868c371c45f5c90c0b400b6b9622471cb (diff) | |
Take existing map size into account when resizing up
Diffstat (limited to 'storage')
| -rw-r--r-- | storage/src/vespa/storage/distributor/messagetracker.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/storage/src/vespa/storage/distributor/messagetracker.cpp b/storage/src/vespa/storage/distributor/messagetracker.cpp index 28fbaad4619..842238aa24c 100644 --- a/storage/src/vespa/storage/distributor/messagetracker.cpp +++ b/storage/src/vespa/storage/distributor/messagetracker.cpp @@ -20,7 +20,7 @@ MessageTracker::~MessageTracker() = default; void MessageTracker::flushQueue(MessageSender& sender) { - _sentMessages.resize(_commandQueue.size()); + _sentMessages.resize(_sentMessages.size() + _commandQueue.size()); for (const auto & toSend : _commandQueue) { toSend._msg->setAddress(api::StorageMessageAddress::create(_cluster_ctx.cluster_name_ptr(), lib::NodeType::STORAGE, toSend._target)); _sentMessages[toSend._msg->getMsgId()] = toSend._target; |