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 <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 = {});
 
        tResult UnrequestSamples(const char* strSubStreamName);
 
        cOutputRecorder(const cOutputRecorder&) = delete;
        cOutputRecorder& operator=(const cOutputRecorder&) = delete;
 
    private:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
}
 
using giant::cOutputRecorder;
 
}
}
}