aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/tests/storageserver/communicationmanagertest.cpp
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@verizonmedia.com>2020-09-09 13:46:35 +0000
committerTor Brede Vekterli <vekterli@verizonmedia.com>2020-09-14 13:22:14 +0000
commit2bfdf23737dbe5291d5552cd6f43f0cb5a751889 (patch)
tree24cb091c242a754d2e6d7e184bba48559f0a5044 /storage/src/tests/storageserver/communicationmanagertest.cpp
parent42459a49b016d89c1b538284b7acd9b45415955b (diff)
Support message dispatch explicitly as sync or async
Delete now unused `MessageEnqueuer` class.
Diffstat (limited to 'storage/src/tests/storageserver/communicationmanagertest.cpp')
-rw-r--r--storage/src/tests/storageserver/communicationmanagertest.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/storage/src/tests/storageserver/communicationmanagertest.cpp b/storage/src/tests/storageserver/communicationmanagertest.cpp
index 0f95f7e7ece..1431c49559c 100644
--- a/storage/src/tests/storageserver/communicationmanagertest.cpp
+++ b/storage/src/tests/storageserver/communicationmanagertest.cpp
@@ -167,7 +167,7 @@ TEST_F(CommunicationManagerTest, commands_are_dequeued_in_fifo_order) {
// Lower number == higher priority.
std::vector<api::StorageMessage::Priority> pris{200, 0, 255, 128};
for (auto pri : pris) {
- storage.enqueue(createDummyCommand(pri));
+ storage.dispatch_async(createDummyCommand(pri));
}
storageLink->waitForMessages(pris.size(), MESSAGE_WAIT_TIME_SEC);
@@ -195,7 +195,7 @@ TEST_F(CommunicationManagerTest, replies_are_dequeued_in_fifo_order) {
std::vector<api::StorageMessage::Priority> pris{200, 0, 255, 128};
for (auto pri : pris) {
- storage.enqueue(createDummyCommand(pri)->makeReply());
+ storage.dispatch_async(createDummyCommand(pri)->makeReply());
}
storageLink->waitForMessages(pris.size(), MESSAGE_WAIT_TIME_SEC);