git.sesse.net Git - casparcg/blob - core/producer/layer.cpp

   1 #include "../stdafx.h"\r
   2 \r
   3 #include "layer.h"\r
   4 \r
   5 #include <mixer/frame/draw_frame.h>\r
   6 #include <mixer/image/image_mixer.h>\r
   7 #include <mixer/audio/audio_mixer.h>\r
   8 #include <mixer/audio/audio_transform.h>\r
   9 #include "../producer/frame_producer.h"\r
  10 \r
  11 #include "../video_format.h"\r
  12 \r
  13 #include <common/utility/assert.h>\r
  14 \r
  15 namespace caspar { namespace core {\r
  16 \r
  17 struct layer::implementation : boost::noncopyable\r
  18 {                                       \r
  19         safe_ptr<frame_producer>        foreground_;\r
  20         safe_ptr<frame_producer>        background_;\r
  21         safe_ptr<draw_frame>            last_frame_;\r
  22         bool                                            is_paused_;\r
  23 \r
  24 public:\r
  25         implementation() \r
  26                 : foreground_(frame_producer::empty())\r
  27                 , background_(frame_producer::empty())\r
  28                 , last_frame_(draw_frame::empty())\r
  29                 , is_paused_(false){}\r
  30         \r
  31         void load(const safe_ptr<frame_producer>& frame_producer, bool play_on_load)\r
  32         {                       \r
  33                 background_ = frame_producer;\r
  34                 if(play_on_load)\r
  35                         play();                 \r
  36         }\r
  37 \r
  38         void preview(const safe_ptr<frame_producer>& frame_producer)\r
  39         {\r
  40                 stop();\r
  41                 foreground_ = frame_producer;\r
  42                 background_ = frame_producer::empty();\r
  43                 try\r
  44                 {\r
  45                         last_frame_ = frame_producer->receive();\r
  46                 }\r
  47                 catch(...)\r
  48                 {\r
  49                         CASPAR_LOG_CURRENT_EXCEPTION();\r
  50                         clear();\r
  51                 }\r
  52         }\r
  53         \r
  54         void play()\r
  55         {                       \r
  56                 if(is_paused_)                  \r
  57                         is_paused_ = false;\r
  58                 else\r
  59                 {\r
  60                         background_->set_leading_producer(foreground_);\r
  61                         foreground_ = background_;\r
  62                         background_ = frame_producer::empty();\r
  63                 }\r
  64         }\r
  65 \r
  66         void pause()\r
  67         {\r
  68                 is_paused_ = true;\r
  69         }\r
  70 \r
  71         void stop()\r
  72         {\r
  73                 pause();\r
  74                 last_frame_ = draw_frame::empty();\r
  75                 foreground_ = frame_producer::empty();\r
  76         }\r
  77 \r
  78         void clear()\r
  79         {\r
  80                 stop();\r
  81                 background_ = frame_producer::empty();\r
  82         }\r
  83         \r
  84         safe_ptr<draw_frame> receive()\r
  85         {               \r
  86                 if(is_paused_)\r
  87                 {\r
  88                         last_frame_->get_audio_transform().set_gain(0.0);\r
  89                         return last_frame_;\r
  90                 }\r
  91 \r
  92                 try\r
  93                 {\r
  94                         last_frame_ = foreground_->receive(); \r
  95                         if(last_frame_ == draw_frame::eof())\r
  96                         {\r
  97                                 CASPAR_ASSERT(foreground_ != frame_producer::empty());\r
  98 \r
  99                                 auto following = foreground_->get_following_producer();\r
 100                                 following->set_leading_producer(foreground_);\r
 101                                 foreground_ = following;\r
 102 \r
 103                                 last_frame_ = receive();\r
 104                         }\r
 105                 }\r
 106                 catch(...)\r
 107                 {\r
 108                         CASPAR_LOG_CURRENT_EXCEPTION();\r
 109                         stop();\r
 110                 }\r
 111 \r
 112                 return last_frame_;\r
 113         }\r
 114 };\r
 115 \r
 116 layer::layer() \r
 117 {\r
 118         impl_ = new implementation();\r
 119 }\r
 120 layer::layer(layer&& other) \r
 121 {\r
 122         impl_ = other.impl_.compare_and_swap(nullptr, other.impl_);\r
 123 }\r
 124 layer::~layer()\r
 125 {\r
 126         delete impl_.fetch_and_store(nullptr);\r
 127 }\r
 128 layer& layer::operator=(layer&& other)\r
 129 {\r
 130         impl_ = other.impl_.compare_and_swap(nullptr, other.impl_);\r
 131         return *this;\r
 132 }\r
 133 void layer::swap(layer& other)\r
 134 {\r
 135         impl_ = other.impl_.compare_and_swap(impl_, other.impl_);\r
 136 }\r
 137 void layer::load(const safe_ptr<frame_producer>& frame_producer, bool play_on_load){return impl_->load(frame_producer, play_on_load);}  \r
 138 void layer::preview(const safe_ptr<frame_producer>& frame_producer){return impl_->preview(frame_producer);}     \r
 139 void layer::play(){impl_->play();}\r
 140 void layer::pause(){impl_->pause();}\r
 141 void layer::stop(){impl_->stop();}\r
 142 void layer::clear(){impl_->clear();}\r
 143 safe_ptr<draw_frame> layer::receive() {return impl_->receive();}\r
 144 safe_ptr<frame_producer> layer::foreground() const { return impl_->foreground_;}\r
 145 safe_ptr<frame_producer> layer::background() const { return impl_->background_;}\r
 146 }}