2 * Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>
4 * This file is part of CasparCG (www.casparcg.com).
6 * CasparCG is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
11 * CasparCG is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
19 * Author: Robert Nagy, ronag89@gmail.com
24 #include "consumer/ffmpeg_consumer.h"
25 #include "producer/ffmpeg_producer.h"
27 #include <common/log.h>
29 #include <core/consumer/frame_consumer.h>
30 #include <core/producer/frame_producer.h>
32 #include <tbb/recursive_mutex.h>
35 #pragma warning (disable : 4244)
36 #pragma warning (disable : 4603)
37 #pragma warning (disable : 4996)
42 #define __STDC_CONSTANT_MACROS
43 #define __STDC_LIMIT_MACROS
44 #include <libavformat/avformat.h>
45 #include <libswscale/swscale.h>
46 #include <libavutil/avutil.h>
47 #include <libavfilter/avfilter.h>
50 namespace caspar { namespace ffmpeg {
52 int ffmpeg_lock_callback(void **mutex, enum AVLockOp op)
57 auto my_mutex = reinterpret_cast<tbb::recursive_mutex*>(*mutex);
63 *mutex = new tbb::recursive_mutex();
88 static void sanitize(uint8_t *line)
92 if(*line < 0x08 || (*line > 0x0D && *line < 0x20))
98 void log_callback(void* ptr, int level, const char* fmt, va_list vl)
100 static int print_prefix=1;
102 static char prev[1024];
104 //static int is_atty;
105 AVClass* avc= ptr ? *(AVClass**)ptr : NULL;
106 if(level > av_log_get_level())
111 if(print_prefix && avc)
113 if (avc->parent_log_context_offset)
115 AVClass** parent= *(AVClass***)(((uint8_t*)ptr) + avc->parent_log_context_offset);
116 if(parent && *parent)
117 std::sprintf(line, "[%s @ %p] ", (*parent)->item_name(parent), parent);
119 std::sprintf(line + strlen(line), "[%s @ %p] ", avc->item_name(ptr), ptr);
122 std::vsprintf(line + strlen(line), fmt, vl);
124 print_prefix = strlen(line) && line[strlen(line)-1] == '\n';
126 //if(print_prefix && !strcmp(line, prev)){
129 // fprintf(stderr, " Last message repeated %d times\r", count);
133 // fprintf(stderr, " Last message repeated %d times\n", count);
137 sanitize((uint8_t*)line);
139 auto len = strlen(line);
143 if(level == AV_LOG_DEBUG)
144 CASPAR_LOG(debug) << L"[ffmpeg] " << line;
145 else if(level == AV_LOG_INFO)
146 CASPAR_LOG(info) << L"[ffmpeg] " << line;
147 else if(level == AV_LOG_WARNING)
148 CASPAR_LOG(warning) << L"[ffmpeg] " << line;
149 else if(level == AV_LOG_ERROR)
150 CASPAR_LOG(error) << L"[ffmpeg] " << line;
151 else if(level == AV_LOG_FATAL)
152 CASPAR_LOG(fatal) << L"[ffmpeg] " << line;
154 CASPAR_LOG(trace) << L"[ffmpeg] " << line;
156 //colored_fputs(av_clip(level>>3, 0, 6), line);
159 //static int query_yadif_formats(AVFilterContext *ctx)
161 // static const int pix_fmts[] = {
171 // AV_NE( PIX_FMT_GRAY16BE, PIX_FMT_GRAY16LE ),
174 // AV_NE( PIX_FMT_YUV444P16BE, PIX_FMT_YUV444P16LE ),
175 // AV_NE( PIX_FMT_YUV422P16BE, PIX_FMT_YUV422P16LE ),
176 // AV_NE( PIX_FMT_YUV420P16BE, PIX_FMT_YUV420P16LE ),
180 // avfilter_set_common_pixel_formats(ctx, avfilter_make_format_list(pix_fmts));
185 //#pragma warning (push)
186 //#pragma warning (disable : 4706)
187 //void fix_yadif_filter_format_query()
189 // AVFilter** filter = nullptr;
190 // while((filter = av_filter_next(filter)) && *filter)
192 // if(strstr((*filter)->name, "yadif") != 0)
193 // (*filter)->query_formats = query_yadif_formats;
196 //#pragma warning (pop)
200 av_lockmgr_register(ffmpeg_lock_callback);
201 av_log_set_callback(log_callback);
203 avfilter_register_all();
204 //fix_yadif_filter_format_query();
206 avformat_network_init();
207 avcodec_register_all();
209 core::register_consumer_factory([](const std::vector<std::wstring>& params){return create_consumer(params);});
210 core::register_producer_factory(create_producer);
216 avformat_network_deinit();
217 av_lockmgr_register(nullptr);
220 std::wstring make_version(unsigned int ver)
222 std::wstringstream str;
223 str << ((ver >> 16) & 0xFF) << L"." << ((ver >> 8) & 0xFF) << L"." << ((ver >> 0) & 0xFF);
227 std::wstring avcodec_version()
229 return make_version(::avcodec_version());
232 std::wstring avformat_version()
234 return make_version(::avformat_version());
237 std::wstring avutil_version()
239 return make_version(::avutil_version());
242 std::wstring avfilter_version()
244 return make_version(::avfilter_version());
247 std::wstring swscale_version()
249 return make_version(::swscale_version());