-/*\r
-* Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>\r
-*\r
-* This file is part of CasparCG (www.casparcg.com).\r
-*\r
-* CasparCG is free software: you can redistribute it and/or modify\r
-* it under the terms of the GNU General Public License as published by\r
-* the Free Software Foundation, either version 3 of the License, or\r
-* (at your option) any later version.\r
-*\r
-* CasparCG is distributed in the hope that it will be useful,\r
-* but WITHOUT ANY WARRANTY; without even the implied warranty of\r
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the\r
-* GNU General Public License for more details.\r
-*\r
-* You should have received a copy of the GNU General Public License\r
-* along with CasparCG. If not, see <http://www.gnu.org/licenses/>.\r
-*\r
-* Author: Robert Nagy, ronag89@gmail.com\r
-*/\r
-\r
-#include "../stdafx.h"\r
-\r
-#include "ffmpeg_producer.h"\r
-\r
-#include "../ffmpeg_error.h"\r
-\r
-#include "muxer/frame_muxer.h"\r
-#include "input/input.h"\r
-#include "util/util.h"\r
-#include "audio/audio_decoder.h"\r
-#include "video/video_decoder.h"\r
-\r
-#include <common/env.h>\r
-#include <common/log.h>\r
-#include <common/param.h>\r
-#include <common/diagnostics/graph.h>\r
-#include <common/future.h>\r
-\r
-#include <core/video_format.h>\r
-#include <core/producer/frame_producer.h>\r
-#include <core/frame/frame_factory.h>\r
-#include <core/frame/draw_frame.h>\r
-#include <core/frame/frame_transform.h>\r
-#include <core/monitor/monitor.h>\r
-\r
-#include <boost/algorithm/string.hpp>\r
-#include <common/assert.h>\r
-#include <boost/assign.hpp>\r
-#include <boost/timer.hpp>\r
-#include <boost/foreach.hpp>\r
-#include <boost/filesystem.hpp>\r
-#include <boost/range/algorithm/find_if.hpp>\r
-#include <boost/range/algorithm/find.hpp>\r
-#include <boost/property_tree/ptree.hpp>\r
-#include <boost/regex.hpp>\r
-#include <boost/thread/future.hpp>\r
-\r
-#include <tbb/parallel_invoke.h>\r
-\r
-#include <limits>\r
-#include <memory>\r
-#include <queue>\r
-\r
-namespace caspar { namespace ffmpeg {\r
- \r
-struct ffmpeg_producer : public core::frame_producer\r
-{\r
- monitor::basic_subject event_subject_;\r
- const std::wstring filename_;\r
- \r
- const spl::shared_ptr<diagnostics::graph> graph_;\r
- \r
- const spl::shared_ptr<core::frame_factory> frame_factory_;\r
- const core::video_format_desc format_desc_;\r
-\r
- input input_; \r
-\r
- tbb::atomic<bool> paused_;\r
- const double fps_;\r
- const uint32_t start_;\r
- \r
- video_decoder video_decoder_;\r
- audio_decoder audio_decoder_; \r
- frame_muxer muxer_;\r
-\r
- tbb::atomic<uint32_t> frame_number_;\r
-\r
- core::draw_frame last_frame_;\r
- \r
-public:\r
- explicit ffmpeg_producer(const spl::shared_ptr<core::frame_factory>& frame_factory, \r
- const core::video_format_desc& format_desc, \r
- const std::wstring& filename, \r
- const std::wstring& filter, \r
- bool loop, \r
- uint32_t start, \r
- uint32_t length) \r
- : filename_(filename)\r
- , frame_factory_(frame_factory) \r
- , format_desc_(format_desc)\r
- , input_(graph_, filename_, loop, start, length)\r
- , fps_(read_fps(*input_.context(), format_desc_.fps))\r
- , muxer_(fps_, frame_factory, format_desc_, filter)\r
- , start_(start)\r
- , last_frame_(core::draw_frame::empty())\r
- {\r
- paused_ = false;\r
- frame_number_ = 0;\r
-\r
- graph_->set_color("frame-time", diagnostics::color(0.1f, 1.0f, 0.1f));\r
- graph_->set_color("underflow", diagnostics::color(0.6f, 0.3f, 0.9f)); \r
- diagnostics::register_graph(graph_);\r
- \r
- try\r
- {\r
- video_decoder_ = video_decoder(input_.context());\r
- video_decoder_.subscribe(event_subject_);\r
- CASPAR_LOG(info) << print() << L" " << video_decoder_.print();\r
- }\r
- catch(averror_stream_not_found&)\r
- {\r
- //CASPAR_LOG(warning) << print() << " No video-stream found. Running without video."; \r
- }\r
- catch(...)\r
- {\r
- CASPAR_LOG_CURRENT_EXCEPTION();\r
- CASPAR_LOG(warning) << print() << "Failed to open video-stream. Running without video."; \r
- }\r
-\r
- try\r
- {\r
- audio_decoder_ = audio_decoder(input_.context(), format_desc_);\r
- audio_decoder_.subscribe(event_subject_);\r
- CASPAR_LOG(info) << print() << L" " << audio_decoder_.print();\r
- }\r
- catch(averror_stream_not_found&)\r
- {\r
- //CASPAR_LOG(warning) << print() << " No audio-stream found. Running without audio."; \r
- }\r
- catch(...)\r
- {\r
- CASPAR_LOG_CURRENT_EXCEPTION();\r
- CASPAR_LOG(warning) << print() << " Failed to open audio-stream. Running without audio."; \r
- } \r
- \r
- CASPAR_LOG(info) << print() << L" Initialized";\r
- }\r
-\r
- // frame_producer\r
- \r
- core::draw_frame receive() override\r
- { \r
- if(paused_)\r
- return last_frame();\r
-\r
- boost::timer frame_timer;\r
- \r
- decode_next_frame();\r
- \r
- auto frame = core::draw_frame::late(); \r
- if(!muxer_.empty())\r
- {\r
- frame = std::move(muxer_.front());\r
- muxer_.pop();\r
- }\r
- else\r
- {\r
- if(!input_.eof()) \r
- graph_->set_tag("underflow"); \r
- }\r
- \r
- graph_->set_value("frame-time", frame_timer.elapsed()*format_desc_.fps*0.5);\r
- event_subject_ << monitor::event("profiler/time") % frame_timer.elapsed() % (1.0/format_desc_.fps); \r
- \r
- graph_->set_text(print());\r
-\r
- if(frame != core::draw_frame::late()) \r
- ++frame_number_; \r
- \r
- event_subject_ << monitor::event("file/time") % monitor::duration(file_frame_number()/fps_) \r
- % monitor::duration(file_nb_frames()/fps_)\r
- << monitor::event("file/frame") % static_cast<int32_t>(file_frame_number())\r
- % static_cast<int32_t>(file_nb_frames())\r
- << monitor::event("file/fps") % fps_\r
- << monitor::event("file/path") % filename_\r
- << monitor::event("loop") % input_.loop();\r
- \r
- if(frame == core::draw_frame::late())\r
- return frame;\r
- else if(input_.eof())\r
- return last_frame();\r
- else\r
- return last_frame_ = frame;\r
- }\r
-\r
- core::draw_frame last_frame() const override\r
- {\r
- return core::draw_frame::still(last_frame_);\r
- }\r
-\r
- void paused(bool value)\r
- {\r
- paused_ = value;\r
- }\r
-\r
- uint32_t frame_number() const override\r
- {\r
- return frame_number_;\r
- }\r
- \r
- uint32_t nb_frames() const override\r
- {\r
- if(input_.loop())\r
- return std::numeric_limits<uint32_t>::max();\r
-\r
- uint32_t nb_frames = file_nb_frames();\r
-\r
- nb_frames = std::min(input_.length(), nb_frames);\r
- nb_frames = muxer_.calc_nb_frames(nb_frames);\r
- \r
- return nb_frames > start_ ? nb_frames - start_ : 0;\r
- }\r
-\r
- uint32_t file_nb_frames() const\r
- {\r
- uint32_t file_nb_frames = 0;\r
- file_nb_frames = std::max(file_nb_frames, video_decoder_.nb_frames());\r
- file_nb_frames = std::max(file_nb_frames, audio_decoder_.nb_frames());\r
- return file_nb_frames;\r
- }\r
-\r
- uint32_t file_frame_number() const\r
- {\r
- return video_decoder_.file_frame_number();\r
- }\r
- \r
- boost::unique_future<std::wstring> call(const std::wstring& param) override\r
- {\r
- static const boost::wregex loop_exp(L"LOOP\\s*(?<VALUE>\\d?)?", boost::regex::icase);\r
- static const boost::wregex seek_exp(L"SEEK\\s+(?<VALUE>\\d+)", boost::regex::icase);\r
- static const boost::wregex length_exp(L"LENGTH\\s+(?<VALUE>\\d+)?", boost::regex::icase);\r
- static const boost::wregex start_exp(L"START\\s+(?<VALUE>\\d+)?", boost::regex::icase);\r
- \r
- std::wstring result;\r
- \r
- boost::wsmatch what;\r
- if(boost::regex_match(param, what, loop_exp))\r
- {\r
- auto value = what["VALUE"].str();\r
- if(!value.empty())\r
- input_.loop(boost::lexical_cast<bool>(value));\r
- result = boost::lexical_cast<std::wstring>(loop());\r
- }\r
- else if(boost::regex_match(param, what, seek_exp))\r
- {\r
- auto value = what["VALUE"].str();\r
- seek(boost::lexical_cast<uint32_t>(value));\r
- }\r
- else if(boost::regex_match(param, what, length_exp))\r
- {\r
- auto value = what["VALUE"].str();\r
- if(!value.empty())\r
- length(boost::lexical_cast<uint32_t>(value)); \r
- result = boost::lexical_cast<std::wstring>(length());\r
- }\r
- else if(boost::regex_match(param, what, start_exp))\r
- {\r
- auto value = what["VALUE"].str();\r
- if(!value.empty())\r
- start(boost::lexical_cast<uint32_t>(value));\r
- result = boost::lexical_cast<std::wstring>(start());\r
- }\r
- else\r
- BOOST_THROW_EXCEPTION(invalid_argument());\r
-\r
- return async(launch::deferred, [=]{return result;});\r
- }\r
- \r
- std::wstring print() const override\r
- {\r
- return L"ffmpeg[" + boost::filesystem::path(filename_).filename().wstring() + L"|" \r
- + print_mode() + L"|" \r
- + boost::lexical_cast<std::wstring>(file_frame_number()) + L"/" + boost::lexical_cast<std::wstring>(file_nb_frames()) + L"]";\r
- }\r
-\r
- std::wstring name() const override\r
- {\r
- return L"ffmpeg";\r
- }\r
-\r
- boost::property_tree::wptree info() const override\r
- {\r
- boost::property_tree::wptree info;\r
- info.add(L"type", L"ffmpeg");\r
- info.add(L"filename", filename_);\r
- info.add(L"width", video_decoder_.width());\r
- info.add(L"height", video_decoder_.height());\r
- info.add(L"progressive", video_decoder_.is_progressive());\r
- info.add(L"fps", fps_);\r
- info.add(L"loop", input_.loop());\r
- info.add(L"frame-number", frame_number_);\r
- auto nb_frames2 = nb_frames();\r
- info.add(L"nb-frames", nb_frames2 == std::numeric_limits<int64_t>::max() ? -1 : nb_frames2);\r
- info.add(L"file-frame-number", file_frame_number());\r
- info.add(L"file-nb-frames", file_nb_frames());\r
- return info;\r
- }\r
- \r
- void subscribe(const monitor::observable::observer_ptr& o) override\r
- {\r
- event_subject_.subscribe(o);\r
- }\r
-\r
- void unsubscribe(const monitor::observable::observer_ptr& o) override\r
- {\r
- event_subject_.unsubscribe(o);\r
- }\r
-\r
- // ffmpeg_producer\r
- \r
- void loop(bool value)\r
- {\r
- input_.loop(value);\r
- }\r
-\r
- bool loop() const\r
- {\r
- return input_.loop();\r
- }\r
-\r
- void length(uint32_t value)\r
- {\r
- input_.length(value);\r
- }\r
-\r
- uint32_t length()\r
- {\r
- return input_.length();\r
- }\r
- \r
- void start(uint32_t value)\r
- {\r
- input_.start(value);\r
- }\r
-\r
- uint32_t start()\r
- {\r
- return input_.start();\r
- }\r
-\r
- void seek(uint32_t target)\r
- {\r
- muxer_.clear();\r
- video_decoder_.clear();\r
- audio_decoder_.clear();\r
- \r
- target = std::min(target, file_nb_frames()-3);\r
-\r
- input_.seek(target);\r
- \r
- decode_next_frame();\r
-\r
- for(int n = 0; n < 50 && video_decoder_.file_frame_number() != target+2 && !muxer_.empty(); ++n) // TODO: +2 since a frame can be stuck inside yadif filter.\r
- {\r
- muxer_.pop();\r
- decode_next_frame();\r
- }\r
- \r
- last_frame_ = !muxer_.empty() ? muxer_.front() : last_frame_; \r
- }\r
-\r
- std::wstring print_mode() const\r
- {\r
- return ffmpeg::print_mode(video_decoder_.width(), video_decoder_.height(), fps_, !video_decoder_.is_progressive());\r
- }\r
- \r
- void decode_next_frame()\r
- {\r
- for(int n = 0; n < 64 && muxer_.empty(); ++n)\r
- {\r
- std::shared_ptr<AVPacket> pkt;\r
- for(int n = 0; n < 32 && (!video_decoder_.ready() || !audio_decoder_.ready()) && input_.try_pop(pkt); ++n)\r
- {\r
- video_decoder_.push(pkt);\r
- audio_decoder_.push(pkt);\r
- }\r
- \r
- std::shared_ptr<AVFrame> video;\r
- std::shared_ptr<core::audio_buffer> audio;\r
-\r
- tbb::parallel_invoke\r
- (\r
- [&]\r
- {\r
- if(!muxer_.video_ready())\r
- video = video_decoder_.poll(); \r
- },\r
- [&]\r
- { \r
- if(!muxer_.audio_ready())\r
- audio = audio_decoder_.poll(); \r
- }\r
- );\r
- \r
- muxer_.push(video);\r
- muxer_.push(audio);\r
- }\r
- }\r
-};\r
-\r
-spl::shared_ptr<core::frame_producer> create_producer(const spl::shared_ptr<core::frame_factory>& frame_factory, const core::video_format_desc& format_desc, const std::vector<std::wstring>& params)\r
-{ \r
- auto filename = probe_stem(env::media_folder() + L"\\" + params.at(0));\r
-\r
- if(filename.empty())\r
- return core::frame_producer::empty();\r
- \r
- auto loop = boost::range::find(params, L"LOOP") != params.end();\r
- auto start = get_param(L"START", params, get_param(L"SEEK", params, static_cast<uint32_t>(0)));\r
- auto length = get_param(L"LENGTH", params, std::numeric_limits<uint32_t>::max());\r
- auto filter_str = get_param(L"FILTER", params, L""); \r
- \r
- boost::replace_all(filter_str, L"DEINTERLACE", L"YADIF=0:-1");\r
- boost::replace_all(filter_str, L"DEINTERLACE_BOB", L"YADIF=1:-1");\r
- \r
- return spl::make_shared_ptr(std::make_shared<ffmpeg_producer>(frame_factory, format_desc, filename, filter_str, loop, start, length));\r
-}\r
-\r
-}}
\ No newline at end of file
+/*
+* Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>
+*
+* This file is part of CasparCG (www.casparcg.com).
+*
+* CasparCG is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* CasparCG is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
+*
+* Author: Robert Nagy, ronag89@gmail.com
+*/
+
+#include "../StdAfx.h"
+
+#include "ffmpeg_producer.h"
+
+#include "../ffmpeg.h"
+#include "../ffmpeg_error.h"
+#include "util/util.h"
+#include "input/input.h"
+#include "audio/audio_decoder.h"
+#include "video/video_decoder.h"
+#include "muxer/frame_muxer.h"
+
+#include <common/param.h>
+#include <common/diagnostics/graph.h>
+#include <common/future.h>
+
+#include <core/frame/draw_frame.h>
+#include <core/help/help_repository.h>
+#include <core/help/help_sink.h>
+#include <core/producer/media_info/media_info.h>
+#include <core/producer/framerate/framerate_producer.h>
+#include <core/frame/frame_factory.h>
+
+#include <future>
+#include <queue>
+
+namespace caspar { namespace ffmpeg {
+struct seek_out_of_range : virtual user_error {};
+
+std::wstring get_relative_or_original(
+ const std::wstring& filename,
+ const boost::filesystem::path& relative_to)
+{
+ boost::filesystem::path file(filename);
+ auto result = file.filename().wstring();
+
+ boost::filesystem::path current_path = file;
+
+ while (true)
+ {
+ current_path = current_path.parent_path();
+
+ if (boost::filesystem::equivalent(current_path, relative_to))
+ break;
+
+ if (current_path.empty())
+ return filename;
+
+ result = current_path.filename().wstring() + L"/" + result;
+ }
+
+ return result;
+}
+
+struct ffmpeg_producer : public core::frame_producer_base
+{
+ spl::shared_ptr<core::monitor::subject> monitor_subject_;
+ const std::wstring filename_;
+ const std::wstring path_relative_to_media_ = get_relative_or_original(filename_, env::media_folder());
+
+ const spl::shared_ptr<diagnostics::graph> graph_;
+ timer frame_timer_;
+
+ const spl::shared_ptr<core::frame_factory> frame_factory_;
+
+ std::shared_ptr<void> initial_logger_disabler_;
+
+ core::constraints constraints_;
+
+ input input_;
+ std::unique_ptr<video_decoder> video_decoder_;
+ std::unique_ptr<audio_decoder> audio_decoder_;
+ std::unique_ptr<frame_muxer> muxer_;
+
+ const boost::rational<int> framerate_;
+ const uint32_t start_;
+ const uint32_t length_;
+ const bool thumbnail_mode_;
+
+ core::draw_frame last_frame_;
+
+ std::queue<std::pair<core::draw_frame, uint32_t>> frame_buffer_;
+
+ int64_t frame_number_ = 0;
+ uint32_t file_frame_number_ = 0;
+public:
+ explicit ffmpeg_producer(
+ const spl::shared_ptr<core::frame_factory>& frame_factory,
+ const core::video_format_desc& format_desc,
+ const std::wstring& url_or_file,
+ const std::wstring& filter,
+ bool loop,
+ uint32_t start,
+ uint32_t length,
+ bool thumbnail_mode,
+ const std::wstring& custom_channel_order,
+ const ffmpeg_options& vid_params)
+ : filename_(url_or_file)
+ , frame_factory_(frame_factory)
+ , initial_logger_disabler_(temporary_enable_quiet_logging_for_thread(thumbnail_mode))
+ , input_(graph_, url_or_file, loop, start, length, thumbnail_mode, vid_params)
+ , framerate_(read_framerate(*input_.context(), format_desc.framerate))
+ , start_(start)
+ , length_(length)
+ , thumbnail_mode_(thumbnail_mode)
+ , last_frame_(core::draw_frame::empty())
+ , frame_number_(0)
+ {
+ graph_->set_color("frame-time", diagnostics::color(0.1f, 1.0f, 0.1f));
+ graph_->set_color("underflow", diagnostics::color(0.6f, 0.3f, 0.9f));
+ diagnostics::register_graph(graph_);
+
+ try
+ {
+ video_decoder_.reset(new video_decoder(input_.context()));
+ if (!thumbnail_mode_)
+ CASPAR_LOG(info) << print() << L" " << video_decoder_->print();
+
+ constraints_.width.set(video_decoder_->width());
+ constraints_.height.set(video_decoder_->height());
+ }
+ catch (averror_stream_not_found&)
+ {
+ //CASPAR_LOG(warning) << print() << " No video-stream found. Running without video.";
+ }
+ catch (...)
+ {
+ if (!thumbnail_mode_)
+ {
+ CASPAR_LOG_CURRENT_EXCEPTION();
+ CASPAR_LOG(warning) << print() << "Failed to open video-stream. Running without video.";
+ }
+ }
+
+ auto channel_layout = core::audio_channel_layout::invalid();
+
+ if (!thumbnail_mode_)
+ {
+ try
+ {
+ audio_decoder_.reset(new audio_decoder(input_.context(), format_desc.audio_sample_rate));
+ channel_layout = get_audio_channel_layout(
+ audio_decoder_->num_channels(),
+ audio_decoder_->ffmpeg_channel_layout(),
+ custom_channel_order);
+ CASPAR_LOG(info) << print() << L" " << audio_decoder_->print();
+ }
+ catch (averror_stream_not_found&)
+ {
+ //CASPAR_LOG(warning) << print() << " No audio-stream found. Running without audio.";
+ }
+ catch (...)
+ {
+ CASPAR_LOG_CURRENT_EXCEPTION();
+ CASPAR_LOG(warning) << print() << " Failed to open audio-stream. Running without audio.";
+ }
+ }
+
+ if (!video_decoder_ && !audio_decoder_)
+ CASPAR_THROW_EXCEPTION(averror_stream_not_found() << msg_info("No streams found"));
+
+ muxer_.reset(new frame_muxer(framerate_, frame_factory, format_desc, channel_layout, filter, true));
+ }
+
+ // frame_producer
+
+ core::draw_frame receive_impl() override
+ {
+ return render_frame().first;
+ }
+
+ core::draw_frame last_frame() override
+ {
+ return core::draw_frame::still(last_frame_);
+ }
+
+ core::constraints& pixel_constraints() override
+ {
+ return constraints_;
+ }
+
+ double out_fps() const
+ {
+ auto out_framerate = muxer_->out_framerate();
+ auto fps = static_cast<double>(out_framerate.numerator()) / static_cast<double>(out_framerate.denominator());
+
+ return fps;
+ }
+
+ std::pair<core::draw_frame, uint32_t> render_frame()
+ {
+ frame_timer_.restart();
+ auto disable_logging = temporary_enable_quiet_logging_for_thread(thumbnail_mode_);
+
+ for (int n = 0; n < 16 && frame_buffer_.size() < 2; ++n)
+ try_decode_frame();
+
+ graph_->set_value("frame-time", frame_timer_.elapsed() * out_fps() *0.5);
+
+ if (frame_buffer_.empty())
+ {
+ if (input_.eof())
+ {
+ send_osc();
+ return std::make_pair(last_frame(), -1);
+ }
+ else if (!is_url())
+ {
+ graph_->set_tag(diagnostics::tag_severity::WARNING, "underflow");
+ send_osc();
+ return std::make_pair(last_frame_, -1);
+ }
+ else
+ {
+ send_osc();
+ return std::make_pair(last_frame_, -1);
+ }
+ }
+
+ auto frame = frame_buffer_.front();
+ frame_buffer_.pop();
+
+ ++frame_number_;
+ file_frame_number_ = frame.second;
+
+ graph_->set_text(print());
+
+ last_frame_ = frame.first;
+
+ send_osc();
+
+ return frame;
+ }
+
+ bool is_url() const
+ {
+ return boost::contains(filename_, L"://");
+ }
+
+ void send_osc()
+ {
+ double fps = static_cast<double>(framerate_.numerator()) / static_cast<double>(framerate_.denominator());
+
+ *monitor_subject_ << core::monitor::message("/profiler/time") % frame_timer_.elapsed() % (1.0/out_fps());
+
+ *monitor_subject_ << core::monitor::message("/file/time") % (file_frame_number()/fps)
+ % (file_nb_frames()/fps)
+ << core::monitor::message("/file/frame") % static_cast<int32_t>(file_frame_number())
+ % static_cast<int32_t>(file_nb_frames())
+ << core::monitor::message("/file/fps") % fps
+ << core::monitor::message("/file/path") % path_relative_to_media_
+ << core::monitor::message("/loop") % input_.loop();
+ }
+
+ core::draw_frame render_specific_frame(uint32_t file_position)
+ {
+ // Some trial and error and undeterministic stuff here
+ static const int NUM_RETRIES = 32;
+
+ if (file_position > 0) // Assume frames are requested in sequential order,
+ // therefore no seeking should be necessary for the first frame.
+ {
+ input_.seek(file_position > 1 ? file_position - 2: file_position).get();
+ boost::this_thread::sleep_for(boost::chrono::milliseconds(40));
+ }
+
+ for (int i = 0; i < NUM_RETRIES; ++i)
+ {
+ boost::this_thread::sleep_for(boost::chrono::milliseconds(40));
+
+ auto frame = render_frame();
+
+ if (frame.second == std::numeric_limits<uint32_t>::max())
+ {
+ // Retry
+ continue;
+ }
+ else if (frame.second == file_position + 1 || frame.second == file_position)
+ return frame.first;
+ else if (frame.second > file_position + 1)
+ {
+ CASPAR_LOG(trace) << print() << L" " << frame.second << L" received, wanted " << file_position + 1;
+ int64_t adjusted_seek = file_position - (frame.second - file_position + 1);
+
+ if (adjusted_seek > 1 && file_position > 0)
+ {
+ CASPAR_LOG(trace) << print() << L" adjusting to " << adjusted_seek;
+ input_.seek(static_cast<uint32_t>(adjusted_seek) - 1).get();
+ boost::this_thread::sleep_for(boost::chrono::milliseconds(40));
+ }
+ else
+ return frame.first;
+ }
+ }
+
+ CASPAR_LOG(trace) << print() << " Giving up finding frame at " << file_position;
+ return core::draw_frame::empty();
+ }
+
+ core::draw_frame create_thumbnail_frame()
+ {
+ auto total_frames = nb_frames();
+ auto grid = env::properties().get(L"configuration.thumbnails.video-grid", 2);
+
+ if (grid < 1)
+ {
+ CASPAR_LOG(error) << L"configuration/thumbnails/video-grid cannot be less than 1";
+ CASPAR_THROW_EXCEPTION(caspar_exception() << msg_info("configuration/thumbnails/video-grid cannot be less than 1"));
+ }
+
+ if (grid == 1)
+ {
+ return render_specific_frame(total_frames / 2);
+ }
+
+ auto num_snapshots = grid * grid;
+
+ std::vector<core::draw_frame> frames;
+
+ for (int i = 0; i < num_snapshots; ++i)
+ {
+ int x = i % grid;
+ int y = i / grid;
+ int desired_frame;
+
+ if (i == 0)
+ desired_frame = 0; // first
+ else if (i == num_snapshots - 1)
+ desired_frame = total_frames - 1; // last
+ else
+ // evenly distributed across the file.
+ desired_frame = total_frames * i / (num_snapshots - 1);
+
+ auto frame = render_specific_frame(desired_frame);
+ frame.transform().image_transform.fill_scale[0] = 1.0 / static_cast<double>(grid);
+ frame.transform().image_transform.fill_scale[1] = 1.0 / static_cast<double>(grid);
+ frame.transform().image_transform.fill_translation[0] = 1.0 / static_cast<double>(grid) * x;
+ frame.transform().image_transform.fill_translation[1] = 1.0 / static_cast<double>(grid) * y;
+
+ frames.push_back(frame);
+ }
+
+ return core::draw_frame(frames);
+ }
+
+ uint32_t file_frame_number() const
+ {
+ return video_decoder_ ? video_decoder_->file_frame_number() : 0;
+ }
+
+ uint32_t nb_frames() const override
+ {
+ if (is_url() || input_.loop())
+ return std::numeric_limits<uint32_t>::max();
+
+ uint32_t nb_frames = file_nb_frames();
+
+ nb_frames = std::min(length_, nb_frames - start_);
+ nb_frames = muxer_->calc_nb_frames(nb_frames);
+
+ return nb_frames;
+ }
+
+ uint32_t file_nb_frames() const
+ {
+ uint32_t file_nb_frames = 0;
+ file_nb_frames = std::max(file_nb_frames, video_decoder_ ? video_decoder_->nb_frames() : 0);
+ return file_nb_frames;
+ }
+
+ std::future<std::wstring> call(const std::vector<std::wstring>& params) override
+ {
+ static const boost::wregex loop_exp(LR"(LOOP\s*(?<VALUE>\d?)?)", boost::regex::icase);
+ static const boost::wregex seek_exp(LR"(SEEK\s+(?<VALUE>\d+))", boost::regex::icase);
+ static const boost::wregex length_exp(LR"(LENGTH\s+(?<VALUE>\d+)?)", boost::regex::icase);
+ static const boost::wregex start_exp(LR"(START\\s+(?<VALUE>\\d+)?)", boost::regex::icase);
+
+ auto param = boost::algorithm::join(params, L" ");
+
+ std::wstring result;
+
+ boost::wsmatch what;
+ if(boost::regex_match(param, what, loop_exp))
+ {
+ auto value = what["VALUE"].str();
+ if (!value.empty())
+ input_.loop(boost::lexical_cast<bool>(value));
+ result = boost::lexical_cast<std::wstring>(input_.loop());
+ }
+ else if(boost::regex_match(param, what, seek_exp))
+ {
+ auto value = what["VALUE"].str();
+ input_.seek(boost::lexical_cast<uint32_t>(value));
+ }
+ else if(boost::regex_match(param, what, length_exp))
+ {
+ auto value = what["VALUE"].str();
+ if(!value.empty())
+ input_.length(boost::lexical_cast<uint32_t>(value));
+ result = boost::lexical_cast<std::wstring>(input_.length());
+ }
+ else if(boost::regex_match(param, what, start_exp))
+ {
+ auto value = what["VALUE"].str();
+ if(!value.empty())
+ input_.start(boost::lexical_cast<uint32_t>(value));
+ result = boost::lexical_cast<std::wstring>(input_.start());
+ }
+ else
+ CASPAR_THROW_EXCEPTION(invalid_argument());
+
+ return make_ready_future(std::move(result));
+ }
+
+ std::wstring print() const override
+ {
+ return L"ffmpeg[" + (is_url() ? filename_ : boost::filesystem::path(filename_).filename().wstring()) + L"|"
+ + print_mode() + L"|"
+ + boost::lexical_cast<std::wstring>(file_frame_number_) + L"/" + boost::lexical_cast<std::wstring>(file_nb_frames()) + L"]";
+ }
+
+ std::wstring name() const override
+ {
+ return L"ffmpeg";
+ }
+
+ boost::property_tree::wptree info() const override
+ {
+ boost::property_tree::wptree info;
+ info.add(L"type", L"ffmpeg-producer");
+ info.add(L"filename", filename_);
+ info.add(L"width", video_decoder_ ? video_decoder_->width() : 0);
+ info.add(L"height", video_decoder_ ? video_decoder_->height() : 0);
+ info.add(L"progressive", video_decoder_ ? video_decoder_->is_progressive() : false);
+ info.add(L"fps", static_cast<double>(framerate_.numerator()) / static_cast<double>(framerate_.denominator()));
+ info.add(L"loop", input_.loop());
+ info.add(L"frame-number", frame_number_);
+ auto nb_frames2 = nb_frames();
+ info.add(L"nb-frames", nb_frames2 == std::numeric_limits<int64_t>::max() ? -1 : nb_frames2);
+ info.add(L"file-frame-number", file_frame_number_);
+ info.add(L"file-nb-frames", file_nb_frames());
+ return info;
+ }
+
+ core::monitor::subject& monitor_output()
+ {
+ return *monitor_subject_;
+ }
+
+ // ffmpeg_producer
+
+ std::wstring print_mode() const
+ {
+ return video_decoder_ ? ffmpeg::print_mode(
+ video_decoder_->width(),
+ video_decoder_->height(),
+ static_cast<double>(framerate_.numerator()) / static_cast<double>(framerate_.denominator()),
+ !video_decoder_->is_progressive()) : L"";
+ }
+
+ void try_decode_frame()
+ {
+ std::shared_ptr<AVPacket> pkt;
+
+ for (int n = 0; n < 32 && ((video_decoder_ && !video_decoder_->ready()) || (audio_decoder_ && !audio_decoder_->ready())) && input_.try_pop(pkt); ++n)
+ {
+ if (video_decoder_)
+ video_decoder_->push(pkt);
+ if (audio_decoder_)
+ audio_decoder_->push(pkt);
+ }
+
+ std::shared_ptr<AVFrame> video;
+ std::shared_ptr<core::mutable_audio_buffer> audio;
+
+ tbb::parallel_invoke(
+ [&]
+ {
+ if (!muxer_->video_ready() && video_decoder_)
+ video = video_decoder_->poll();
+ },
+ [&]
+ {
+ if (!muxer_->audio_ready() && audio_decoder_)
+ audio = audio_decoder_->poll();
+ });
+
+ muxer_->push(video);
+ muxer_->push(audio);
+
+ if (!audio_decoder_)
+ {
+ if(video == flush_video())
+ muxer_->push(flush_audio());
+ else if(!muxer_->audio_ready())
+ muxer_->push(empty_audio());
+ }
+
+ if (!video_decoder_)
+ {
+ if(audio == flush_audio())
+ muxer_->push(flush_video());
+ else if(!muxer_->video_ready())
+ muxer_->push(empty_video());
+ }
+
+ uint32_t file_frame_number = 0;
+ file_frame_number = std::max(file_frame_number, video_decoder_ ? video_decoder_->file_frame_number() : 0);
+ //file_frame_number = std::max(file_frame_number, audio_decoder_ ? audio_decoder_->file_frame_number() : 0);
+
+ for (auto frame = muxer_->poll(); frame != core::draw_frame::empty(); frame = muxer_->poll())
+ frame_buffer_.push(std::make_pair(frame, file_frame_number));
+ }
+
+ bool audio_only() const
+ {
+ return !video_decoder_;
+ }
+
+ boost::rational<int> get_out_framerate() const
+ {
+ return muxer_->out_framerate();
+ }
+};
+
+void describe_producer(core::help_sink& sink, const core::help_repository& repo)
+{
+ sink.short_description(L"A producer for playing media files supported by FFmpeg.");
+ sink.syntax(L"[clip,url:string] {[loop:LOOP]} {SEEK [start:int]} {LENGTH [start:int]} {FILTER [filter:string]} {CHANNEL_LAYOUT [channel_layout:string]}");
+ sink.para()
+ ->text(L"The FFmpeg Producer can play all media that FFmpeg can play, which includes many ")
+ ->text(L"QuickTime video codec such as Animation, PNG, PhotoJPEG, MotionJPEG, as well as ")
+ ->text(L"H.264, FLV, WMV and several audio codecs as well as uncompressed audio.");
+ sink.definitions()
+ ->item(L"clip", L"The file without the file extension to play. It should reside under the media folder.")
+ ->item(L"url", L"If clip contains :// it is instead treated as the URL parameter. The URL can either be any streaming protocol supported by FFmpeg or dshow://video={webcam_name}.")
+ ->item(L"loop", L"Will cause the media file to loop between start and start + length")
+ ->item(L"start", L"Optionally sets the start frame. 0 by default. If loop is specified this will be the frame where it starts over again.")
+ ->item(L"length", L"Optionally sets the length of the clip. If not specified the clip will be played to the end. If loop is specified the file will jump to start position once this number of frames has been played.")
+ ->item(L"filter", L"If specified, will be used as an FFmpeg video filter.")
+ ->item(L"channel_layout",
+ L"Optionally override the automatically deduced audio channel layout. "
+ L"Either a named layout as specified in casparcg.config or in the format [type:string]:[channel_order:string] for a custom layout.");
+ sink.para()->text(L"Examples:");
+ sink.example(L">> PLAY 1-10 folder/clip", L"to play all frames in a clip and stop at the last frame.");
+ sink.example(L">> PLAY 1-10 folder/clip LOOP", L"to loop a clip between the first frame and the last frame.");
+ sink.example(L">> PLAY 1-10 folder/clip LOOP SEEK 10", L"to loop a clip between frame 10 and the last frame.");
+ sink.example(L">> PLAY 1-10 folder/clip LOOP SEEK 10 LENGTH 50", L"to loop a clip between frame 10 and frame 60.");
+ sink.example(L">> PLAY 1-10 folder/clip SEEK 10 LENGTH 50", L"to play frames 10-60 in a clip and stop.");
+ sink.example(L">> PLAY 1-10 folder/clip FILTER yadif=1,-1", L"to deinterlace the video.");
+ sink.example(L">> PLAY 1-10 folder/clip CHANNEL_LAYOUT film", L"given the defaults in casparcg.config this will specifies that the clip has 6 audio channels of the type 5.1 and that they are in the order FL FC FR BL BR LFE regardless of what ffmpeg says.");
+ sink.example(L">> PLAY 1-10 folder/clip CHANNEL_LAYOUT \"5.1:LFE FL FC FR BL BR\"", L"specifies that the clip has 6 audio channels of the type 5.1 and that they are in the specified order regardless of what ffmpeg says.");
+ sink.example(L">> PLAY 1-10 rtmp://example.com/live/stream", L"to play an RTMP stream.");
+ sink.example(L">> PLAY 1-10 \"dshow://video=Live! Cam Chat HD VF0790\"", L"to use a web camera as video input.");
+ sink.para()->text(L"The FFmpeg producer also supports changing some of the settings via ")->code(L"CALL")->text(L":");
+ sink.example(L">> CALL 1-10 LOOP 1");
+ sink.example(L">> CALL 1-10 START 10");
+ sink.example(L">> CALL 1-10 LENGTH 50");
+ sink.example(L">> CALL 1-10 SEEK 30");
+ core::describe_framerate_producer(sink);
+}
+
+spl::shared_ptr<core::frame_producer> create_producer(
+ const core::frame_producer_dependencies& dependencies,
+ const std::vector<std::wstring>& params,
+ const spl::shared_ptr<core::media_info_repository>& info_repo)
+{
+ auto file_or_url = params.at(0);
+
+ if (!boost::contains(file_or_url, L"://"))
+ {
+ // File
+ file_or_url = probe_stem(env::media_folder() + L"/" + file_or_url, false);
+ }
+
+ if (file_or_url.empty())
+ return core::frame_producer::empty();
+
+ auto loop = contains_param(L"LOOP", params);
+ auto start = get_param(L"SEEK", params, static_cast<uint32_t>(0));
+ auto length = get_param(L"LENGTH", params, std::numeric_limits<uint32_t>::max());
+ auto filter_str = get_param(L"FILTER", params, L"");
+ auto custom_channel_order = get_param(L"CHANNEL_LAYOUT", params, L"");
+
+ boost::ireplace_all(filter_str, L"DEINTERLACE_BOB", L"YADIF=1:-1");
+ boost::ireplace_all(filter_str, L"DEINTERLACE_LQ", L"SEPARATEFIELDS");
+ boost::ireplace_all(filter_str, L"DEINTERLACE", L"YADIF=0:-1");
+
+ ffmpeg_options vid_params;
+ bool haveFFMPEGStartIndicator = false;
+ for (size_t i = 0; i < params.size() - 1; ++i)
+ {
+ if (!haveFFMPEGStartIndicator && params[i] == L"--")
+ {
+ haveFFMPEGStartIndicator = true;
+ continue;
+ }
+ if (haveFFMPEGStartIndicator)
+ {
+ auto name = u8(params.at(i++)).substr(1);
+ auto value = u8(params.at(i));
+ vid_params.push_back(std::make_pair(name, value));
+ }
+ }
+
+ auto producer = spl::make_shared<ffmpeg_producer>(
+ dependencies.frame_factory,
+ dependencies.format_desc,
+ file_or_url,
+ filter_str,
+ loop,
+ start,
+ length,
+ false,
+ custom_channel_order,
+ vid_params);
+
+ if (producer->audio_only())
+ return core::create_destroy_proxy(producer);
+
+ auto get_source_framerate = [=] { return producer->get_out_framerate(); };
+ auto target_framerate = dependencies.format_desc.framerate;
+
+ return core::create_destroy_proxy(core::create_framerate_producer(
+ producer,
+ get_source_framerate,
+ target_framerate,
+ dependencies.format_desc.field_mode,
+ dependencies.format_desc.audio_cadence));
+}
+
+core::draw_frame create_thumbnail_frame(
+ const core::frame_producer_dependencies& dependencies,
+ const std::wstring& media_file,
+ const spl::shared_ptr<core::media_info_repository>& info_repo)
+{
+ auto quiet_logging = temporary_enable_quiet_logging_for_thread(true);
+ auto filename = probe_stem(env::media_folder() + L"/" + media_file, true);
+
+ if (filename.empty())
+ return core::draw_frame::empty();
+
+ auto loop = false;
+ auto start = 0;
+ auto length = std::numeric_limits<uint32_t>::max();
+ auto filter_str = L"";
+
+ ffmpeg_options vid_params;
+ auto producer = spl::make_shared<ffmpeg_producer>(
+ dependencies.frame_factory,
+ dependencies.format_desc,
+ filename,
+ filter_str,
+ loop,
+ start,
+ length,
+ true,
+ L"",
+ vid_params);
+
+ return producer->create_thumbnail_frame();
+}
+}}
projects / casparcg / blobdiff