output_recorder.h

Go to the documentation of this file.

#pragma once
#include <adtfucom3/adtf_ucom3.h>
#include <adtfstreaming3/named_graph_object_intf.h>
#include <adtfstreaming3/streamtype_intf.h>
#include <adtfstreaming3/sample_intf.h>
#include <adtfstreaming3/streamingrequests_intf.h>
 
#include <string>
#include <memory>
#include <map>
#include <unordered_map>
#include <utility>
 
namespace adtf
{
 
namespace filter
{
 
namespace testing
{
 
namespace giant
{

class cOutputRecorder
{
    public:
        cOutputRecorder(const ucom::ant::iobject_ptr<ucom::ant::IObject>& pObject,
                        const char* strPinName);

        cOutputRecorder(cOutputRecorder&& oOther);

        ~cOutputRecorder();

        cOutputRecorder& operator=(cOutputRecorder&& oOther);

        bool WaitForTrigger(adtf::base::flash::tNanoSeconds tmTimeout = base::flash::tNanoSeconds{-1});

        class cOutput
        {
            public:
                typedef std::multimap<base::flash::tNanoSeconds,
                                      std::vector<std::pair<ucom::ant::object_ptr<const streaming::ant::IStreamType>,
                                                            ucom::ant::object_ptr<const streaming::ant::ISample>>>> tTriggerData;
            public:
                std::vector<ucom::ant::object_ptr<const streaming::ant::IStreamType>> GetTypes() const;
                std::vector<ucom::ant::object_ptr<const streaming::ant::ISample>> GetSamples() const;
 
                const tTriggerData& GetTrigger() const;
 
            private:
                friend class cOutputRecorder;
                tTriggerData m_oTrigger;
        };

        cOutput GetCurrentOutput(bool bClear = true);

        ucom::ant::object_ptr<const streaming::ant::IStreamType> GetCurrentType() const;

        void RequestSamples(const char* strSubStreamName,
                             const std::unordered_map<std::string, std::string>& oProperties = {});

        void RequestSamplesOfAllSubStreams(const std::unordered_map<std::string, std::string>& mapProperties = {});

        tResult UnrequestSamples(const char* strSubStreamName);

        tResult UnrequestSamplesOfAllSubStreams();
 
        std::vector<const streaming::IStreamingRequest*> GetStreamingRequests() const;
 
        cOutputRecorder(const cOutputRecorder&) = delete;
        cOutputRecorder& operator=(const cOutputRecorder&) = delete;
 
    private:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
}
 
using giant::cOutputRecorder;
 
}
}
}