lgrGStreamerPipeline.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved. 
******************************************************************************/ 


#pragma once
#ifdef GST_ENABLED

#include <lgrCore/lgrCore.h>
#include <lgrUtil/virtualConstructor.h>

#include <vlutil/vlString.h>
#include <vlutil/vlTime.h>

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

namespace MAKLogger
{

   class DtLgrPlaybackDriver;
   class DT_DLL_LGRCORE DtLgrGStreamerPipeline
   {
   public: 

      DT_VIRTUAL_CTR(DtLgrGStreamerPipeline,())

      
      virtual ~DtLgrGStreamerPipeline();

      virtual bool initializePipeline(const DtString& pipelineConfigurationToUse);

      virtual void setPipeline(GstElement* pipeline);

      virtual bool startPipeline();

      virtual const DtString& pipelineConfiguration() const;

      void destroyPipeline();

      virtual void tick(double currentTime);

      virtual bool isStarted() const;

      virtual void pause();

      virtual void unpause();

      virtual bool isPaused();

      virtual void setSpeed(double speed);

      virtual bool jumpToPosition(double position);

      virtual double position() const;

      virtual double duration() const;

      virtual void sendEos(bool waitForSignal) const;

      virtual void overlayVideoSink();

      virtual void exposeWindow();

      virtual void switchToInterVideoSink(const char* channel=0);

   public:


      static void setMediaSpeedFactor(double mediaSpeedFactor);
      static double mediaSpeedFactor();


      static void setMediaWindowHandle(void* windowHandle);
      static void* mediaWindowHandle();


      virtual void setDriver(DtLgrPlaybackDriver* driver);

   protected:

      virtual bool isPipelineReady();

      virtual bool sendSpeedEvent(double speed);

      virtual bool sendJumpToPosition(double position);

      virtual void printMessage(const DtString& label, GstMessage *message) const;

   protected:

      static GstBusSyncReply overlayWindowHandle(GstBus *bus, GstMessage *message, gpointer user_data);

   protected:

      DtString myPipelineConfiguration;

      bool myOkToPushBuffers;

      GstBus* myBus;
      GstElement* myPipeline;

      double mySpeed;
      double myResendSpeedTime;
      DtClock myClock;

      bool myOverlayVideoSink;
      bool myPaused;
      bool myStarted;

      int myGraphId;

      DtLgrPlaybackDriver* myDriver;

   protected:
      static double theMediaSpeedFactor;
      static bool theGsInitialized;
      static void* theMediaWindowHandle;
   };
}

#endif   // GST_ENABLED