diff options
author | Geir Storli <geirst@verizonmedia.com> | 2020-11-25 12:56:50 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2020-11-25 12:56:50 +0000 |
commit | c090dda709692c07ca492b698af9db3e1a76d8e1 (patch) | |
tree | e56a9ffc11f4b8d2fc3856faf1bdf7b925ff4196 /storage | |
parent | aa903bfbf23d3b855d50de185a15d8061825c778 (diff) |
Create the mbus::Route on demand instead of storing it inside StorageMessageAddress.
Creating and deleting the route is expensive and not used with RPC for Storage API communication.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/storageserver/communicationmanager.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp index 940bffdbcc6..09fe0512b6b 100644 --- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp +++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp @@ -584,7 +584,7 @@ CommunicationManager::sendCommand( cmd->setRetryEnabled(false); cmd->setTimeRemaining(msg->getTimeout()); cmd->setTrace(msg->steal_trace()); - sendMessageBusMessage(msg, std::move(cmd), address.getRoute()); + sendMessageBusMessage(msg, std::move(cmd), address.to_mbus_route()); } break; } @@ -603,7 +603,7 @@ CommunicationManager::sendCommand( std::lock_guard lock(_messageBusSentLock); _messageBusSent[msg->getMsgId()] = msg; } - sendMessageBusMessage(msg, std::move(mbusMsg), address.getRoute()); + sendMessageBusMessage(msg, std::move(mbusMsg), address.to_mbus_route()); break; } else { LOGBM(warning, "This type of message can't be sent via messagebus"); |