Test for ADTF2 Video Decompressor Filter Plugin

Description

This examples test the ADTF2 Video Decompressor Filter Plugin

Location

./src/examples/src/adtf/filters/deserializer/adtf2_video_decompressor_filter/test/

Build Environment

To see how to set up the build environment have a look at ADTF CMake Environment

this implementation shows:

• how to use our ADTF Testing SDK
• how to test a Filter
• how to set up a test system with adtf::system::testing::giant::cSessionTestSystem

Implementation

 
#include <adtftesting/adtf_testing.h>
#include <adtfsystemsdk/testing/test_system.h>
#include <adtffiltersdk/adtf_filtersdk.h>
#include <plugins/player_intf.h>
#include "../stream_meta_type_compressed_video.h"
 
#include <vector>
#include <chrono>
 
using namespace adtf_file::adtf2::compressed_video;
using namespace adtf::system::testing;
using namespace adtf::streaming::testing;
using namespace adtf::filter::testing;
using namespace adtf::ucom;
using namespace adtf::streaming;
using namespace adtf::services;
using namespace adtf::base;
using namespace adtf::util;
 
struct cMySessionTestSystem : cSessionTestSystem
{
    cMySessionTestSystem()
    {
        CreateSession(ADTF_TESTING_SOURCE_DIR "/test_compressed_video_project"
                      "/adtfsessions/demo_video_decompressor_filter_test.adtfsession");
        SetRunLevel(tADTFRunLevel::RL_FilterGraph);
    }
};
 
TEST_CASE_METHOD(cMySessionTestSystem, "Deserialization of compressed video", "[req:ACORE-8497],[req:ACORE-8498]")
{
    object_ptr<adtf::services::IPlayer> pPlayer;
    REQUIRE_OK(_runtime->GetObject(pPlayer));
 
    auto pPlaybackInput = GetGraphObject("compressed_video_player");
    cOutputRecorder oPlaybackRecorder(pPlaybackInput, "compressed_video");
 
    auto pDecompressorFilter = GetGraphObject("demo_video_decompressor_filter_test_filter_graph.video_decompressor_filter");
    cOutputRecorder oDecomopressorRecorder(pDecompressorFilter, "decompressed_video");
 
    SetRunLevel(tADTFRunLevel::RL_Running);
 
    while (pPlayer->GetCurrentState() == IPlayer::tState::Streaming)
    {
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
 
    auto oInputTypes = oPlaybackRecorder.GetCurrentOutput().GetTypes();
    REQUIRE(!oInputTypes.empty());
 
    cString strMetaTypeName;
 
    REQUIRE_OK(oInputTypes.front()->GetMetaTypeName(adtf_string_intf(strMetaTypeName)));
    REQUIRE(strMetaTypeName == cString(stream_meta_type_video_compressed::MetaTypeName));
 
    auto oDecompressorFilterOutput = oDecomopressorRecorder.GetCurrentOutput();
 
    auto oDecompressorTypes = oDecompressorFilterOutput.GetTypes();
    REQUIRE(!oDecompressorTypes.empty());
 
    REQUIRE_OK(oDecompressorTypes.front()->GetMetaTypeName(adtf_string_intf(strMetaTypeName)));
    REQUIRE(strMetaTypeName == cString(stream_meta_type_image::MetaTypeName));
 
    auto oDecompressorSamples = oDecompressorFilterOutput.GetSamples();
 
    REQUIRE(149 == oDecompressorSamples.size());
    for (auto sample : oDecompressorSamples)
    {
        object_ptr_shared_locked<const ISampleBuffer> buffer;
        REQUIRE_OK(sample->Lock(buffer));
        REQUIRE(0x12C00 == buffer->GetSize());
    }
}