- /** true if the last frame we processed was skipped (because it was already done) */
- bool _just_skipped;
- /** Index of the last frame to be processed */
- int _last_frame;
+
+ /** Mutex for _threads */
+ mutable boost::mutex _threads_mutex;
+ std::list<boost::thread *> _threads;
+ mutable boost::mutex _queue_mutex;
+ std::list<boost::shared_ptr<DCPVideo> > _queue;
+ /** condition to manage thread wakeups when we have nothing to do */
+ boost::condition _empty_condition;
+ /** condition to manage thread wakeups when we have too much to do */
+ boost::condition _full_condition;
+
+ boost::shared_ptr<Writer> _writer;
+ Waker _waker;
+
+ boost::shared_ptr<PlayerVideo> _last_player_video;
+
+ boost::signals2::scoped_connection _server_found_connection;