Bound time to a clock, does not work too well

GstreamerHelper/GstreamerHelper.vcxproj

@@ -168,6 +168,7 @@
     <ClInclude Include="GstreamerVideoStream.h" />
     <ClInclude Include="stdafx.h" />
     <ClInclude Include="targetver.h" />
+    <ClInclude Include="VocaluxeClock.h" />
   </ItemGroup>
   <ItemGroup>
     <ClCompile Include="dllmain.cpp">
@@ -194,6 +195,7 @@
       <PrecompiledHeader Condition="'$(Configuration)|$(Platform)'=='ReleaseWin|Win32'">Create</PrecompiledHeader>
       <PrecompiledHeader Condition="'$(Configuration)|$(Platform)'=='ReleaseWin|x64'">Create</PrecompiledHeader>
     </ClCompile>
+    <ClCompile Include="VocaluxeClock.cpp" />
   </ItemGroup>
   <Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />
   <ImportGroup Label="ExtensionTargets">

GstreamerHelper/GstreamerHelper.vcxproj.filters

@@ -33,6 +33,9 @@
     <ClInclude Include="GstreamerVideoStream.h">
       <Filter>Headerdateien</Filter>
     </ClInclude>
+    <ClInclude Include="VocaluxeClock.h">
+      <Filter>Headerdateien</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <ClCompile Include="stdafx.cpp">
@@ -53,5 +56,8 @@
     <ClCompile Include="GstreamerVideoStream.cpp">
       <Filter>Quelldateien</Filter>
     </ClCompile>
+    <ClCompile Include="VocaluxeClock.cpp">
+      <Filter>Quelldateien</Filter>
+    </ClCompile>
   </ItemGroup>
 </Project>

GstreamerHelper/GstreamerVideoStream.cpp

@@ -20,6 +20,7 @@ GstreamerVideoStream::GstreamerVideoStream(int ID)
 	this->ID = ID;
 
 	g_main_loop_new(Context, false);
+	Clock = vocaluxe_clock_new("external");
 
 	Loop = false;
 
@@ -65,8 +66,9 @@ int GstreamerVideoStream::LoadVideo(const wchar_t* Filename)
 		NULL);
 
 	gst_app_sink_set_caps(Appsink, caps);
-	gst_app_sink_set_max_buffers(Appsink, 1);
+	gst_app_sink_set_max_buffers(Appsink, 5);
 
+	gst_pipeline_use_clock((GstPipeline *)Element, (GstClock*) Clock);
 	gst_element_set_state(Element, GST_STATE_PLAYING);
 	gst_element_set_state((GstElement*)Appsink, GST_STATE_PLAYING);
 	gst_bus_timed_pop_filtered(Bus, -1, GST_MESSAGE_ASYNC_DONE);
@@ -115,11 +117,13 @@ GstFlowReturn GstreamerVideoStream::NewBufferRecieved(GstAppSink *sink)
 			gst_object_unref(BufferStructure);
 	}
 
+	Mutex.lock();
 	Frame.buffer = Mapinfo.data;
 	Frame.height = Height;
 	Frame.width = Width;
 	Frame.size = Size;
 	Frame.videotime = VideoTime;
+	Mutex.unlock();
 
 	return GST_FLOW_OK;
 }
@@ -172,6 +176,10 @@ bool GstreamerVideoStream::Skip(float Start, float Gap)
 
 void GstreamerVideoStream::SetVideoLoop(bool Loop)
 {
+	if(Loop)
+		gst_pipeline_auto_clock((GstPipeline *)Element);
+	else
+		gst_pipeline_use_clock((GstPipeline *)Element, (GstClock*) Clock);
 	this->Loop = Loop;
 }
 

GstreamerHelper/GstreamerVideoStream.h

@@ -3,6 +3,7 @@
 #include "gst/gst.h"
 #include "GstreamerVideo.h"
 #include "gst\app\gstappsink.h"
+#include "VocaluxeClock.h"
 
 	using namespace std;
 
@@ -31,9 +32,9 @@ public:
     bool IsFinished();
 
 private:
-
 	GMainLoop *MainLoop;
 	GMainContext *Context;
+	VocaluxeClock *Clock;
 
 	GstAppSink *Appsink;
 	GstElement *Element;

gstreamerhelper/VocaluxeClock.cpp

@@ -0,0 +1,81 @@
+#include "stdafx.h"
+#include "VocaluxeClock.h"
+
+static void vocaluxe_clock_class_init (VocaluxeClockClass * klass);
+static void vocaluxe_clock_init (VocaluxeClock * clock);
+
+static GstClockTime vocaluxe_clock_get_internal_time (GstClock * clock);
+
+static GstSystemClockClass *parent_class = NULL;
+
+GType
+vocaluxe_clock_get_type (void)
+{
+  static GType clock_type = 0;
+
+  if (!clock_type) {
+    static const GTypeInfo clock_info = {
+      sizeof (VocaluxeClockClass),
+      NULL,
+      NULL,
+      (GClassInitFunc) vocaluxe_clock_class_init,
+      NULL,
+      NULL,
+      sizeof (VocaluxeClock),
+      4,
+      (GInstanceInitFunc) vocaluxe_clock_init,
+      NULL
+    };
+
+    clock_type = g_type_register_static (GST_TYPE_SYSTEM_CLOCK, "VocaluxeClock",
+        &clock_info, (GTypeFlags) 0);
+  }
+  return clock_type;
+}
+
+
+static void
+vocaluxe_clock_class_init (VocaluxeClockClass * klass)
+{
+  GstClockClass *gstclock_class;
+
+  gstclock_class = (GstClockClass *) klass;
+
+  parent_class = (GstSystemClockClass*) g_type_class_peek_parent (klass);
+
+  gstclock_class->get_internal_time = vocaluxe_clock_get_internal_time;
+}
+
+static void
+vocaluxe_clock_init (VocaluxeClock * clock)
+{
+  clock->last_time = 0;
+  GST_OBJECT_FLAG_SET (clock, GST_CLOCK_FLAG_CAN_SET_MASTER);
+}
+
+VocaluxeClock *
+vocaluxe_clock_new (const gchar * name)
+{
+  VocaluxeClock *_vocaluxeclock =
+      VOCALUXE_CLOCK (g_object_new (GST_TYPE_VOCALUXE_CLOCK, "name", name, NULL));
+
+  return _vocaluxeclock;
+}
+
+static GstClockTime
+vocaluxe_clock_get_internal_time (GstClock * clock)
+{
+  VocaluxeClock *_vocaluxeclock;
+  GstClockTime result;
+
+  _vocaluxeclock = GST_VOCALUXE_CLOCK_CAST (clock);
+
+  result = _vocaluxeclock->time * GST_SECOND;
+  return result;
+}
+
+void
+vocaluxe_clock_set_time (VocaluxeClock * clock, float time)
+{
+  clock->time = time;
+}

gstreamerhelper/VocaluxeClock.h

@@ -0,0 +1,42 @@
+#pragma once
+
+#include <gst/gst.h>
+#include <gst/gstsystemclock.h>
+
+G_BEGIN_DECLS
+
+#define GST_TYPE_VOCALUXE_CLOCK \
+  (vocaluxe_clock_get_type())
+#define VOCALUXE_CLOCK(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_VOCALUXE_CLOCK,VocaluxeClock))
+#define VOCALUXE_CLOCK_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_VOCALUXE_CLOCK,VocaluxeClockClass))
+#define GST_IS_VOCALUXE_CLOCK(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_VOCALUXE_CLOCK))
+#define GST_IS_VOCALUXE_CLOCK_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_VOCALUXE_CLOCK))
+#define GST_VOCALUXE_CLOCK_CAST(obj) \
+  ((VocaluxeClock*)(obj))
+
+typedef struct _VocaluxeClock VocaluxeClock;
+typedef struct _VocaluxeClockClass VocaluxeClockClass;
+
+struct _VocaluxeClock {
+  GstSystemClock clock;
+
+  GstClockTime last_time;
+  gfloat time;
+};
+
+struct _VocaluxeClockClass {
+  GstSystemClockClass parent_class;
+
+  /*< private >*/
+  gpointer _gst_reserved[GST_PADDING];
+};
+
+GType          vocaluxe_clock_get_type        (void);
+VocaluxeClock*   vocaluxe_clock_new             (const gchar *name);
+void            vocaluxe_clock_set_time      (VocaluxeClock *clock, float time);
+
+}