diff options
| author | Tor Egge <Tor.Egge@oath.com> | 2017-11-24 11:21:35 +0000 |
|---|---|---|
| committer | Tor Egge <Tor.Egge@oath.com> | 2017-11-24 11:41:27 +0000 |
| commit | fe86f187aafd0c4955789a2aac5a72f08091082f (patch) | |
| tree | dd299c775a27235bbbdda21233d84d463f09ea9e | |
| parent | 567fb911e741ec773f8ae8edf654a89650918275 (diff) | |
Remove unused code from StorageLinkQueued.
| -rw-r--r-- | storage/src/vespa/storage/common/storagelinkqueued.h | 5 | ||||
| -rw-r--r-- | storage/src/vespa/storage/common/storagelinkqueued.hpp | 8 |
2 files changed, 0 insertions, 13 deletions
diff --git a/storage/src/vespa/storage/common/storagelinkqueued.h b/storage/src/vespa/storage/common/storagelinkqueued.h index b7891cc48dc..570ff262901 100644 --- a/storage/src/vespa/storage/common/storagelinkqueued.h +++ b/storage/src/vespa/storage/common/storagelinkqueued.h @@ -92,11 +92,6 @@ private: void add(const std::shared_ptr<Message>&); void flush(); - // You can use the given functions if you need to keep the - // dispatcher thread locked while you process a message. Bucket - // manager does this during bucket dumps - vespalib::Monitor& getMonitor() { return _sync; } - void addWithoutLocking(const std::shared_ptr<Message>&); virtual void send(const std::shared_ptr<Message> & ) = 0; }; diff --git a/storage/src/vespa/storage/common/storagelinkqueued.hpp b/storage/src/vespa/storage/common/storagelinkqueued.hpp index b34ce58bbb7..1210603980a 100644 --- a/storage/src/vespa/storage/common/storagelinkqueued.hpp +++ b/storage/src/vespa/storage/common/storagelinkqueued.hpp @@ -69,14 +69,6 @@ void StorageLinkQueued::Dispatcher<Message>::add( } template<typename Message> -void StorageLinkQueued::Dispatcher<Message>::addWithoutLocking( - const std::shared_ptr<Message>& m) -{ - if (_thread.get() == 0) start(); - _messages.push_back(m); -} - -template<typename Message> void StorageLinkQueued::Dispatcher<Message>::run(framework::ThreadHandle& h) { while (!h.interrupted()) { |