1 files changed, 6 insertions, 19 deletions
diff --git a/src/mov_encoder_writer.h b/src/mov_encoder_writer.h
index e653223..3146bf8 100644
--- a/src/mov_encoder_writer.h
+++ b/src/mov_encoder_writer.h
@@ -33,6 +33,8 @@
 #include "file.h"
 #include "info.h"
 
+#include "threadsafe_queue_priority.h"
+
 #include <string>
 using namespace std;
 
@@ -42,8 +44,8 @@ using namespace std;
 class MovEncoderWriter : public Thread {
 public:
   MovEncoderWriter(const char* cpr,
-                   FramePriorityQueue *video_queue, pthread_mutex_t *video_mutex, sem_t *video_sem, 
-                   FramePriorityQueue *audio_queue, pthread_mutex_t *audio_mutex, sem_t *audio_sem, 
+                   ThreadSafeQueuePriority *video_queue,
+                   ThreadSafeQueuePriority *audio_queue,
                    Info *info);
   ~MovEncoderWriter();
 
@@ -56,23 +58,8 @@ private:
 
   File *file;
 
-  FramePriorityQueue *video_queue;
-  FramePriorityQueue *audio_queue;
-  pthread_mutex_t *video_mutex;
-  pthread_mutex_t *audio_mutex;
-  sem_t *video_sem;
-  sem_t *audio_sem;
-
-  unsigned int video_frame_number;
-  unsigned int audio_frame_number;
-
-  //  Timecode_struc SCR;
-  //  double timestamp;
-
-//  void write_audio_header(unsigned short int packetsize);
-//  void write_video_header(unsigned short int packetsize);
-//  void write_system_header(unsigned int audio_size, unsigned int video_size);
-//  void write_packet_header(unsigned int audio_size, unsigned int video_size);
+  ThreadSafeQueuePriority *video_queue;
+  ThreadSafeQueuePriority *audio_queue;
 };