testPendingReplies.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_ocm_libdaq_test
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Tests for PendingReplies and related
 */
#include <daq/pendingReplies.hpp>
 
#include <gtest/gtest.h>
#include <gmock/gmock.h>
 
using namespace ::testing;
using namespace ::daq;
 
/**
 * Test fixture for PendingReplies tests.
 *
 * @ingroup daq_ocm_libdaq_test
 */
class TestPendingReplies : public ::testing::Test {
public:
    void SetUp() override {
        pending = PendingReplies::Create();
    }
    void TearDown() override {
    }
protected:
    std::shared_ptr<PendingReplies> pending;
};
 
TEST_F(TestPendingReplies, DeletedReplyTokenReleasesPendingReply) {
    EXPECT_FALSE(pending->HasPendingReplies());
    {
        auto token = pending->Acquire("id", "req");
        EXPECT_TRUE(pending->HasPendingReplies());
    }
    EXPECT_FALSE(pending->HasPendingReplies());
}
 
TEST_F(TestPendingReplies, PendingReplyReleasesTheCorrectToken) {
    EXPECT_FALSE(pending->HasPendingReplies());
    {
        auto token = pending->Acquire("1", "req");
        {
            auto token2 = pending->Acquire("2", "req");
        }
        auto token3 = pending->Acquire("3", "req");
        auto pending_vec = pending->GetPendingReplies();
 
        ASSERT_EQ(2u, pending_vec.size());
        std::vector<PendingReplies::PendingReply> expected = {{"1", "req"}, {"3", "req"}};
        //EXPECT_THAT(pending_vec, UnorderedElementsAre(expected));
    }
    EXPECT_FALSE(pending->HasPendingReplies());
}