DtGStreamerTaskElement.h

Go to the documentation of this file.

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


#pragma once

#include <vrvGStreamer/vrvGStreamer.h>

#include <vrvVideoStream/DtImageTaskElement.h>

#include <string>

#include <gst/gstelement.h>
#include <gst/app/gstappsrc.h>

namespace makVrv
{
   class DtVideoFrameBuffer;

   class DT_DLL_VRVGSTREAMER DtGStreamerTaskElement : public DtImageTaskElement
   {
   public: 
      friend class DtGStreamerTaskElementCreator;

      virtual ~DtGStreamerTaskElement();

      virtual std::string pipelineConfiguration() const;

      virtual void setPipelineConfiguration( const std::string& config );

      virtual void setFromRecord( 
         const makArchives::DtImageTaskRecord& config );

      virtual bool configure();

   protected:
      DtGStreamerTaskElement( DtDe& de, DtProcessImageTask* owningTask );

      void handleProcessFrame(DtVideoFrameBuffer* frame);

      bool buildPipeline();

      void destroyPipeline();

      GstCaps* genCaps();

   protected:
      static void need_data( GstAppSrc *src, guint length, gpointer user_data );

      static void enough_data( GstAppSrc *src, gpointer user_data );

   protected:
      static int theClassCount;

   protected:

      std::string myPipelineConfiguration;

      bool myOkToPushFrames;

      GstElement* myPipeline;
      GstElement* myVideoAppSrc;
      GstElement* myMetadataAppSrc;
      GstAppSrcCallbacks myGstCallbacks;

      int myWidth;
      int myHeight;
      int myPixelFormat;
      int myRowLength;
   };
   class DT_DLL_VRVGSTREAMER DtGStreamerTaskElementCreator 
      : public DtImageTaskElementCreator
   {
   public:
      friend class DtVideoStreamManager;

      DtGStreamerTaskElementCreator();

      virtual ~DtGStreamerTaskElementCreator();

   protected:
      virtual DtImageTaskElement* create(DtDe& de, 
         DtProcessImageTask* owningTask);
   };
}