aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/vespa/storage/common/storagelinkqueued.cpp
diff options
context:
space:
mode:
authorbjormel <bjormel@yahooinc.com>2023-10-26 13:59:28 +0000
committerbjormel <bjormel@yahooinc.com>2023-10-26 13:59:28 +0000
commit567be9a1f6353cec41c23bfd1fcd46b4b2a4d2d7 (patch)
tree4664a743e166a5e11aee7b9acd70ad8ee2617612 /storage/src/vespa/storage/common/storagelinkqueued.cpp
parente9058b555d4dfea2f6c872d9a677e8678b569569 (diff)
parentbce3b8e926bf9da880172acbe1ba4b12d5e026d6 (diff)
Merge branch 'master' into bjormel/aws-main-controllerbjormel/aws-main-controller
Diffstat (limited to 'storage/src/vespa/storage/common/storagelinkqueued.cpp')
-rw-r--r--storage/src/vespa/storage/common/storagelinkqueued.cpp20
1 files changed, 1 insertions, 19 deletions
diff --git a/storage/src/vespa/storage/common/storagelinkqueued.cpp b/storage/src/vespa/storage/common/storagelinkqueued.cpp
index 2f116738c28..c08eedd8ff0 100644
--- a/storage/src/vespa/storage/common/storagelinkqueued.cpp
+++ b/storage/src/vespa/storage/common/storagelinkqueued.cpp
@@ -1,4 +1,4 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "storagelinkqueued.hpp"
#include <vespa/log/log.h>
@@ -10,7 +10,6 @@ StorageLinkQueued::StorageLinkQueued(const std::string& name, framework::Compone
: StorageLink(name),
_compReg(cr),
_replyDispatcher(*this),
- _commandDispatcher(*this),
_closeState(0)
{ }
@@ -25,23 +24,6 @@ StorageLinkQueued::~StorageLinkQueued()
}
}
-void StorageLinkQueued::dispatchDown(
- const std::shared_ptr<api::StorageMessage>& msg)
-{
- // Verify acceptable state to send messages down
- switch(getState()) {
- case OPENED:
- case CLOSING:
- case FLUSHINGDOWN:
- break;
- default:
- LOG(error, "Link %s trying to dispatch %s down while in state %u",
- toString().c_str(), msg->toString().c_str(), getState());
- assert(false);
- }
- _commandDispatcher.add(msg);
-}
-
void StorageLinkQueued::dispatchUp(
const std::shared_ptr<api::StorageMessage>& msg)
{