summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@verizonmedia.com>2020-07-15 13:27:55 +0000
committerTor Brede Vekterli <vekterli@verizonmedia.com>2020-07-16 08:49:00 +0000
commit024f64334264d747a437637c6618e1bc8a6fa733 (patch)
treef6ddcd596e91e5d029738675963ed783c8202e4d
parent2e887caba90b4de71444ffa5fb2dcc9c482759cf (diff)
Fix typo in function name
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.cpp8
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.h2
2 files changed, 5 insertions, 5 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
index d0d1056d4fd..c0adb01ad47 100644
--- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp
+++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
@@ -46,7 +46,7 @@ void
CommunicationManager::receiveStorageReply(const std::shared_ptr<api::StorageReply>& reply)
{
assert(reply);
- enque_or_process(reply);
+ enqueue_or_process(reply);
}
namespace {
@@ -101,7 +101,7 @@ CommunicationManager::handleMessage(std::unique_ptr<mbus::Message> msg)
cmd->setTrace(docMsgPtr->getTrace());
cmd->setTransportContext(std::make_unique<StorageTransportContext>(std::move(docMsgPtr)));
- enque_or_process(std::move(cmd));
+ enqueue_or_process(std::move(cmd));
} else if (protocolName == mbusprot::StorageProtocol::NAME) {
std::unique_ptr<mbusprot::StorageCommand> storMsgPtr(static_cast<mbusprot::StorageCommand*>(msg.release()));
@@ -113,7 +113,7 @@ CommunicationManager::handleMessage(std::unique_ptr<mbus::Message> msg)
cmd->setTrace(storMsgPtr->getTrace());
cmd->setTransportContext(std::make_unique<StorageTransportContext>(std::move(storMsgPtr)));
- enque_or_process(std::move(cmd));
+ enqueue_or_process(std::move(cmd));
} else {
LOGBM(warning, "Received unsupported message type %d for protocol '%s'",
msg->getType(), msg->getProtocol().c_str());
@@ -443,7 +443,7 @@ CommunicationManager::process(const std::shared_ptr<api::StorageMessage>& msg)
}
void
-CommunicationManager::enque_or_process(std::shared_ptr<api::StorageMessage> msg)
+CommunicationManager::enqueue_or_process(std::shared_ptr<api::StorageMessage> msg)
{
assert(msg);
if (_skip_thread) {
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.h b/storage/src/vespa/storage/storageserver/communicationmanager.h
index c2d5ea7039d..23b59f5a42a 100644
--- a/storage/src/vespa/storage/storageserver/communicationmanager.h
+++ b/storage/src/vespa/storage/storageserver/communicationmanager.h
@@ -114,7 +114,7 @@ private:
bool _skip_thread;
void updateMetrics(const MetricLockGuard &) override;
- void enque_or_process(std::shared_ptr<api::StorageMessage> msg);
+ void enqueue_or_process(std::shared_ptr<api::StorageMessage> msg);
// Test needs access to configure() for live reconfig testing.
friend struct CommunicationManagerTest;