DtProcessImageTask.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 2018 VT-MAK Technologies, Inc. 
** All rights reserved. 
******************************************************************************/ 


#pragma once
#include <vrvVideoStream/DtReadFramebufferProcessData.h>
#include <vrvVideoStream/vrvVideoStream.h>
#include <vrvVideoStream/DtVideoStream.h>
#include <vrvVideoStream/DtLocklessQueue.h>

#include <vlutil/vlRunnable.h>
#include <vlutil/vlThread.h>
#include <vlutil/vlTime.h>

#include <osg/Image>

#include <vector>

class DtThread;

namespace makVrv
{
   class DtMetadataPublisher;
   class DtImageTaskElement;
   class DtVideoFrameBuffer;

   

   class DT_DLL_VRVVIDEOSTREAM DtProcessImageTask 
      : protected DtRunnable
   {
   public: 
      DtProcessImageTask( DtDe& de, const DtVideoStream& stream );

      virtual ~DtProcessImageTask();

      virtual bool initialize(
         const makArchives::DtVideoStreamRecord::ImageTaskRecords& taskList,
         const makArchives::DtMetadataPublisherRecord& metadataConfig );

     virtual void process(const DtReadFramebufferProcessData& data);

      const DtVideoStream& stream();

   protected:

      virtual DtImageTaskElement* buildPipeline( 
         const makArchives::DtVideoStreamRecord::ImageTaskRecords& taskList );

      virtual void setElementFromRecord( DtImageTaskElement* element, 
         const makArchives::DtImageTaskRecord& taskRecord );

      virtual bool configureElement( DtImageTaskElement* element );

      // --  virtual void workerThread();

   private:

      DtProcessImageTask();

      DtProcessImageTask( const DtProcessImageTask& orig );

      DtProcessImageTask& operator=( const DtProcessImageTask& rhs );

      virtual void run();

   protected:
      DtDe& myDe;
      const DtVideoStream& myStream;
      DtImageTaskElement* myPipeline;
      DtLocklessQueue<DtVideoFrameBuffer*> myImageQueue;

      DtThreadStartSP myStart;
      DtThread* myThread;

      DtMetadataPublisher* myMetadataPublisher;
      double myFrequency;

      DtLocklessQueue<DtVideoFrameBuffer*> myVideoFrameBufferPool;

      DtTime myLastUpdateTime;
   };
}