From 20d28e80a5c861a9d5f449ea911ab75b4f37ad0d Mon Sep 17 00:00:00 2001
From: Jef <jef@targetspot.com>
Date: Tue, 24 Sep 2024 14:54:57 +0200
Subject: Initial community commit

---
 Src/Plugins/Input/in_wmvdrm/MediaThread.h | 56 +++++++++++++++++++++++++++++++
 1 file changed, 56 insertions(+)
 create mode 100644 Src/Plugins/Input/in_wmvdrm/MediaThread.h

(limited to 'Src/Plugins/Input/in_wmvdrm/MediaThread.h')

diff --git a/Src/Plugins/Input/in_wmvdrm/MediaThread.h b/Src/Plugins/Input/in_wmvdrm/MediaThread.h
new file mode 100644
index 00000000..3dd3fdcb
--- /dev/null
+++ b/Src/Plugins/Input/in_wmvdrm/MediaThread.h
@@ -0,0 +1,56 @@
+#ifndef NULLSOFT_MEDIATHREADH
+#define NULLSOFT_MEDIATHREADH
+
+#include <deque> 
+#include <wmsdk.h>
+#include <vector>
+
+VOID CALLBACK MediaThread_StartAPC(ULONG_PTR param);
+VOID CALLBACK MediaThread_AddAPC(ULONG_PTR param);
+struct MediaBuffer
+{
+	MediaBuffer(INSSBuffer *b, QWORD t, unsigned long f, bool d) : buffer(b), timestamp(t), flags(f), drmProtected(d) {}
+	INSSBuffer *buffer;
+	QWORD timestamp;
+	unsigned long flags;
+	bool drmProtected;
+};
+struct MediaBufferAPC;
+
+class MediaThread
+{
+public:
+	MediaThread();
+	~MediaThread();
+
+	bool AddBuffer(INSSBuffer *buff, QWORD ts, unsigned long flags, bool drmProtected);
+
+	void Stop();
+	void SignalStop();
+	void WaitForStop();
+	void Kill();
+
+public:
+	void StopAPC();
+	void StartAPC();
+
+	virtual void AddAPC(MediaBuffer *buffer)=0;
+
+protected:
+	void OrderedInsert(MediaBuffer *buffer);
+
+protected:
+	int wait;
+	HANDLE thread;
+	HANDLE killEvent, stopped, bufferFreed;
+
+	typedef std::vector<MediaBuffer*> BufferList;
+	BufferList buffers;
+};
+
+struct MediaBufferAPC
+{
+	MediaBuffer *buffer;
+	MediaThread *thread;
+};
+#endif
\ No newline at end of file
-- 
cgit