diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-08-18 10:21:21 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-08-18 10:21:21 +0000 |
commit | a27df474c8079e3f29f7d9bf67ca5d20cb31413c (patch) | |
tree | ac3d5a01a72bdfc870510bb06194298e70861d69 | |
parent | 5c51af58b98c987975e3db62d9ed09d72b8188d8 (diff) |
Unify code layout
-rw-r--r-- | storage/src/vespa/storage/storageserver/communicationmanager.cpp | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp index 362717f70e6..95ed9188422 100644 --- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp +++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp @@ -272,7 +272,8 @@ CommunicationManager::~CommunicationManager() LOG(debug, "Deleting link %s.", toString().c_str()); } -void CommunicationManager::onClose() +void +CommunicationManager::onClose() { // Avoid getting config during shutdown _configFetcher.reset(); @@ -328,7 +329,8 @@ CommunicationManager::configureMessageBusLimits(const CommunicationManagerConfig : cfg.mbusContentNodeMaxPendingSize); } -void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig> config) +void +CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig> config) { // Only allow dynamic (live) reconfiguration of message bus limits. if (_mbus) { @@ -494,8 +496,7 @@ CommunicationManager::sendMessageBusMessage(const std::shared_ptr<api::StorageCo } bool -CommunicationManager::sendCommand( - const std::shared_ptr<api::StorageCommand> & msg) +CommunicationManager::sendCommand(const std::shared_ptr<api::StorageCommand> & msg) { if (!msg->getAddress()) { LOGBP(warning, "Got command without address of type %s in CommunicationManager::sendCommand", @@ -570,9 +571,8 @@ CommunicationManager::serializeNodeState(const api::GetNodeStateReply& gns, std: } void -CommunicationManager::sendDirectRPCReply( - RPCRequestWrapper& request, - const std::shared_ptr<api::StorageReply>& reply) +CommunicationManager::sendDirectRPCReply(RPCRequestWrapper& request, + const std::shared_ptr<api::StorageReply>& reply) { std::string_view requestName(request.getMethodName()); // TODO non-name based dispatch // TODO rework this entire dispatch mechanism :D @@ -616,9 +616,8 @@ CommunicationManager::sendDirectRPCReply( } void -CommunicationManager::sendMessageBusReply( - StorageTransportContext& context, - const std::shared_ptr<api::StorageReply>& reply) +CommunicationManager::sendMessageBusReply(StorageTransportContext& context, + const std::shared_ptr<api::StorageReply>& reply) { // Using messagebus for communication. mbus::Reply::UP replyUP; @@ -653,8 +652,7 @@ CommunicationManager::sendMessageBusReply( } bool -CommunicationManager::sendReply( - const std::shared_ptr<api::StorageReply>& reply) +CommunicationManager::sendReply(const std::shared_ptr<api::StorageReply>& reply) { // Relaxed load since we're not doing any dependent reads that aren't // already covered by some other form of explicit synchronization. |