You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

772 lines
23KB

  1. /*
  2. * Copyright (c) 2017 Paul B Mahol
  3. *
  4. * This file is part of FFmpeg.
  5. *
  6. * FFmpeg is free software; you can redistribute it and/or
  7. * modify it under the terms of the GNU Lesser General Public
  8. * License as published by the Free Software Foundation; either
  9. * version 2.1 of the License, or (at your option) any later version.
  10. *
  11. * FFmpeg 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 GNU
  14. * Lesser General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU Lesser General Public
  17. * License along with FFmpeg; if not, write to the Free Software
  18. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  19. */
  20. /**
  21. * @file
  22. * An arbitrary audio FIR filter
  23. */
  24. #include <float.h>
  25. #include "libavutil/common.h"
  26. #include "libavutil/float_dsp.h"
  27. #include "libavutil/intreadwrite.h"
  28. #include "libavutil/opt.h"
  29. #include "libavutil/xga_font_data.h"
  30. #include "libavcodec/avfft.h"
  31. #include "audio.h"
  32. #include "avfilter.h"
  33. #include "filters.h"
  34. #include "formats.h"
  35. #include "internal.h"
  36. #include "af_afir.h"
  37. static void fcmul_add_c(float *sum, const float *t, const float *c, ptrdiff_t len)
  38. {
  39. int n;
  40. for (n = 0; n < len; n++) {
  41. const float cre = c[2 * n ];
  42. const float cim = c[2 * n + 1];
  43. const float tre = t[2 * n ];
  44. const float tim = t[2 * n + 1];
  45. sum[2 * n ] += tre * cre - tim * cim;
  46. sum[2 * n + 1] += tre * cim + tim * cre;
  47. }
  48. sum[2 * n] += t[2 * n] * c[2 * n];
  49. }
  50. static int fir_channel(AVFilterContext *ctx, void *arg, int ch, int nb_jobs)
  51. {
  52. AudioFIRContext *s = ctx->priv;
  53. const float *src = (const float *)s->in[0]->extended_data[ch];
  54. int index1 = (s->index + 1) % 3;
  55. int index2 = (s->index + 2) % 3;
  56. float *sum = s->sum[ch];
  57. AVFrame *out = arg;
  58. float *block;
  59. float *dst;
  60. int n, i, j;
  61. memset(sum, 0, sizeof(*sum) * s->fft_length);
  62. block = s->block[ch] + s->part_index * s->block_size;
  63. memset(block, 0, sizeof(*block) * s->fft_length);
  64. s->fdsp->vector_fmul_scalar(block + s->part_size, src, s->dry_gain, FFALIGN(s->nb_samples, 4));
  65. emms_c();
  66. av_rdft_calc(s->rdft[ch], block);
  67. block[2 * s->part_size] = block[1];
  68. block[1] = 0;
  69. j = s->part_index;
  70. for (i = 0; i < s->nb_partitions; i++) {
  71. const int coffset = i * s->coeff_size;
  72. const FFTComplex *coeff = s->coeff[ch * !s->one2many] + coffset;
  73. block = s->block[ch] + j * s->block_size;
  74. s->fcmul_add(sum, block, (const float *)coeff, s->part_size);
  75. if (j == 0)
  76. j = s->nb_partitions;
  77. j--;
  78. }
  79. sum[1] = sum[2 * s->part_size];
  80. av_rdft_calc(s->irdft[ch], sum);
  81. dst = (float *)s->buffer->extended_data[ch] + index1 * s->part_size;
  82. for (n = 0; n < s->part_size; n++) {
  83. dst[n] += sum[n];
  84. }
  85. dst = (float *)s->buffer->extended_data[ch] + index2 * s->part_size;
  86. memcpy(dst, sum + s->part_size, s->part_size * sizeof(*dst));
  87. dst = (float *)s->buffer->extended_data[ch] + s->index * s->part_size;
  88. if (out) {
  89. float *ptr = (float *)out->extended_data[ch];
  90. s->fdsp->vector_fmul_scalar(ptr, dst, s->wet_gain, FFALIGN(out->nb_samples, 4));
  91. emms_c();
  92. }
  93. return 0;
  94. }
  95. static int fir_frame(AudioFIRContext *s, AVFrame *in, AVFilterLink *outlink)
  96. {
  97. AVFilterContext *ctx = outlink->src;
  98. AVFrame *out = NULL;
  99. int ret;
  100. s->nb_samples = in->nb_samples;
  101. if (!s->want_skip) {
  102. out = ff_get_audio_buffer(outlink, s->nb_samples);
  103. if (!out)
  104. return AVERROR(ENOMEM);
  105. }
  106. if (s->pts == AV_NOPTS_VALUE)
  107. s->pts = in->pts;
  108. s->in[0] = in;
  109. ctx->internal->execute(ctx, fir_channel, out, NULL, outlink->channels);
  110. s->part_index = (s->part_index + 1) % s->nb_partitions;
  111. if (!s->want_skip) {
  112. out->pts = s->pts;
  113. if (s->pts != AV_NOPTS_VALUE)
  114. s->pts += av_rescale_q(out->nb_samples, (AVRational){1, outlink->sample_rate}, outlink->time_base);
  115. }
  116. s->index++;
  117. if (s->index == 3)
  118. s->index = 0;
  119. av_frame_free(&in);
  120. if (s->want_skip == 1) {
  121. s->want_skip = 0;
  122. ret = 0;
  123. } else {
  124. ret = ff_filter_frame(outlink, out);
  125. }
  126. return ret;
  127. }
  128. static void drawtext(AVFrame *pic, int x, int y, const char *txt, uint32_t color)
  129. {
  130. const uint8_t *font;
  131. int font_height;
  132. int i;
  133. font = avpriv_cga_font, font_height = 8;
  134. for (i = 0; txt[i]; i++) {
  135. int char_y, mask;
  136. uint8_t *p = pic->data[0] + y * pic->linesize[0] + (x + i * 8) * 4;
  137. for (char_y = 0; char_y < font_height; char_y++) {
  138. for (mask = 0x80; mask; mask >>= 1) {
  139. if (font[txt[i] * font_height + char_y] & mask)
  140. AV_WL32(p, color);
  141. p += 4;
  142. }
  143. p += pic->linesize[0] - 8 * 4;
  144. }
  145. }
  146. }
  147. static void draw_line(AVFrame *out, int x0, int y0, int x1, int y1, uint32_t color)
  148. {
  149. int dx = FFABS(x1-x0);
  150. int dy = FFABS(y1-y0), sy = y0 < y1 ? 1 : -1;
  151. int err = (dx>dy ? dx : -dy) / 2, e2;
  152. for (;;) {
  153. AV_WL32(out->data[0] + y0 * out->linesize[0] + x0 * 4, color);
  154. if (x0 == x1 && y0 == y1)
  155. break;
  156. e2 = err;
  157. if (e2 >-dx) {
  158. err -= dy;
  159. x0--;
  160. }
  161. if (e2 < dy) {
  162. err += dx;
  163. y0 += sy;
  164. }
  165. }
  166. }
  167. static void draw_response(AVFilterContext *ctx, AVFrame *out)
  168. {
  169. AudioFIRContext *s = ctx->priv;
  170. float *mag, *phase, min = FLT_MAX, max = FLT_MIN;
  171. int prev_ymag = -1, prev_yphase = -1;
  172. char text[32];
  173. int channel, i, x;
  174. memset(out->data[0], 0, s->h * out->linesize[0]);
  175. phase = av_malloc_array(s->w, sizeof(*phase));
  176. mag = av_malloc_array(s->w, sizeof(*mag));
  177. if (!mag || !phase)
  178. goto end;
  179. channel = av_clip(s->ir_channel, 0, s->in[1]->channels - 1);
  180. for (i = 0; i < s->w; i++) {
  181. const float *src = (const float *)s->in[1]->extended_data[channel];
  182. double w = i * M_PI / (s->w - 1);
  183. double real = 0.;
  184. double imag = 0.;
  185. for (x = 0; x < s->nb_taps; x++) {
  186. real += cos(-x * w) * src[x];
  187. imag += sin(-x * w) * src[x];
  188. }
  189. mag[i] = hypot(real, imag);
  190. phase[i] = atan2(imag, real);
  191. min = fminf(min, mag[i]);
  192. max = fmaxf(max, mag[i]);
  193. }
  194. for (i = 0; i < s->w; i++) {
  195. int ymag = mag[i] / max * (s->h - 1);
  196. int yphase = (0.5 * (1. + phase[i] / M_PI)) * (s->h - 1);
  197. ymag = s->h - 1 - av_clip(ymag, 0, s->h - 1);
  198. yphase = s->h - 1 - av_clip(yphase, 0, s->h - 1);
  199. if (prev_ymag < 0)
  200. prev_ymag = ymag;
  201. if (prev_yphase < 0)
  202. prev_yphase = yphase;
  203. draw_line(out, i, ymag, FFMAX(i - 1, 0), prev_ymag, 0xFFFF00FF);
  204. draw_line(out, i, yphase, FFMAX(i - 1, 0), prev_yphase, 0xFF00FF00);
  205. prev_ymag = ymag;
  206. prev_yphase = yphase;
  207. }
  208. if (s->w > 400 && s->h > 100) {
  209. drawtext(out, 2, 2, "Max Magnitude:", 0xDDDDDDDD);
  210. snprintf(text, sizeof(text), "%.2f", max);
  211. drawtext(out, 15 * 8 + 2, 2, text, 0xDDDDDDDD);
  212. drawtext(out, 2, 12, "Min Magnitude:", 0xDDDDDDDD);
  213. snprintf(text, sizeof(text), "%.2f", min);
  214. drawtext(out, 15 * 8 + 2, 12, text, 0xDDDDDDDD);
  215. }
  216. end:
  217. av_free(phase);
  218. av_free(mag);
  219. }
  220. static int convert_coeffs(AVFilterContext *ctx)
  221. {
  222. AudioFIRContext *s = ctx->priv;
  223. int ret, i, ch, n, N;
  224. float power = 0;
  225. s->nb_taps = ff_inlink_queued_samples(ctx->inputs[1]);
  226. if (s->nb_taps <= 0)
  227. return AVERROR(EINVAL);
  228. for (n = 4; (1 << n) < s->nb_taps; n++);
  229. N = FFMIN(n, 16);
  230. s->ir_length = 1 << n;
  231. s->fft_length = (1 << (N + 1)) + 1;
  232. s->part_size = 1 << (N - 1);
  233. s->block_size = FFALIGN(s->fft_length, 32);
  234. s->coeff_size = FFALIGN(s->part_size + 1, 32);
  235. s->nb_partitions = (s->nb_taps + s->part_size - 1) / s->part_size;
  236. s->nb_coeffs = s->ir_length + s->nb_partitions;
  237. for (ch = 0; ch < ctx->inputs[0]->channels; ch++) {
  238. s->sum[ch] = av_calloc(s->fft_length, sizeof(**s->sum));
  239. if (!s->sum[ch])
  240. return AVERROR(ENOMEM);
  241. }
  242. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  243. s->coeff[ch] = av_calloc(s->nb_partitions * s->coeff_size, sizeof(**s->coeff));
  244. if (!s->coeff[ch])
  245. return AVERROR(ENOMEM);
  246. }
  247. for (ch = 0; ch < ctx->inputs[0]->channels; ch++) {
  248. s->block[ch] = av_calloc(s->nb_partitions * s->block_size, sizeof(**s->block));
  249. if (!s->block[ch])
  250. return AVERROR(ENOMEM);
  251. }
  252. for (ch = 0; ch < ctx->inputs[0]->channels; ch++) {
  253. s->rdft[ch] = av_rdft_init(N, DFT_R2C);
  254. s->irdft[ch] = av_rdft_init(N, IDFT_C2R);
  255. if (!s->rdft[ch] || !s->irdft[ch])
  256. return AVERROR(ENOMEM);
  257. }
  258. s->buffer = ff_get_audio_buffer(ctx->inputs[0], s->part_size * 3);
  259. if (!s->buffer)
  260. return AVERROR(ENOMEM);
  261. ret = ff_inlink_consume_samples(ctx->inputs[1], s->nb_taps, s->nb_taps, &s->in[1]);
  262. if (ret < 0)
  263. return ret;
  264. if (ret == 0)
  265. return AVERROR_BUG;
  266. if (s->response)
  267. draw_response(ctx, s->video);
  268. s->gain = 1;
  269. if (s->again) {
  270. switch (s->gtype) {
  271. case 0:
  272. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  273. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  274. for (i = 0; i < s->nb_taps; i++)
  275. power += FFABS(time[i]);
  276. }
  277. s->gain = ctx->inputs[1]->channels / power;
  278. break;
  279. case 1:
  280. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  281. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  282. for (i = 0; i < s->nb_taps; i++)
  283. power += time[i];
  284. }
  285. s->gain = ctx->inputs[1]->channels / power;
  286. break;
  287. case 2:
  288. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  289. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  290. for (i = 0; i < s->nb_taps; i++)
  291. power += time[i] * time[i];
  292. }
  293. s->gain = sqrtf(ch / power);
  294. break;
  295. default:
  296. return AVERROR_BUG;
  297. }
  298. }
  299. s->gain = FFMIN(s->gain * s->ir_gain, 1.f);
  300. av_log(ctx, AV_LOG_DEBUG, "power %f, gain %f\n", power, s->gain);
  301. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  302. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  303. s->fdsp->vector_fmul_scalar(time, time, s->gain, FFALIGN(s->nb_taps, 4));
  304. }
  305. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  306. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  307. float *block = s->block[ch];
  308. FFTComplex *coeff = s->coeff[ch];
  309. for (i = FFMAX(1, s->length * s->nb_taps); i < s->nb_taps; i++)
  310. time[i] = 0;
  311. for (i = 0; i < s->nb_partitions; i++) {
  312. const float scale = 1.f / s->part_size;
  313. const int toffset = i * s->part_size;
  314. const int coffset = i * s->coeff_size;
  315. const int boffset = s->part_size;
  316. const int remaining = s->nb_taps - (i * s->part_size);
  317. const int size = remaining >= s->part_size ? s->part_size : remaining;
  318. memset(block, 0, sizeof(*block) * s->fft_length);
  319. memcpy(block + boffset, time + toffset, size * sizeof(*block));
  320. av_rdft_calc(s->rdft[0], block);
  321. coeff[coffset].re = block[0] * scale;
  322. coeff[coffset].im = 0;
  323. for (n = 1; n < s->part_size; n++) {
  324. coeff[coffset + n].re = block[2 * n] * scale;
  325. coeff[coffset + n].im = block[2 * n + 1] * scale;
  326. }
  327. coeff[coffset + s->part_size].re = block[1] * scale;
  328. coeff[coffset + s->part_size].im = 0;
  329. }
  330. }
  331. av_frame_free(&s->in[1]);
  332. av_log(ctx, AV_LOG_DEBUG, "nb_taps: %d\n", s->nb_taps);
  333. av_log(ctx, AV_LOG_DEBUG, "nb_partitions: %d\n", s->nb_partitions);
  334. av_log(ctx, AV_LOG_DEBUG, "partition size: %d\n", s->part_size);
  335. av_log(ctx, AV_LOG_DEBUG, "ir_length: %d\n", s->ir_length);
  336. s->have_coeffs = 1;
  337. return 0;
  338. }
  339. static int check_ir(AVFilterLink *link, AVFrame *frame)
  340. {
  341. AVFilterContext *ctx = link->dst;
  342. AudioFIRContext *s = ctx->priv;
  343. int nb_taps, max_nb_taps;
  344. nb_taps = ff_inlink_queued_samples(link);
  345. max_nb_taps = s->max_ir_len * ctx->outputs[0]->sample_rate;
  346. if (nb_taps > max_nb_taps) {
  347. av_log(ctx, AV_LOG_ERROR, "Too big number of coefficients: %d > %d.\n", nb_taps, max_nb_taps);
  348. return AVERROR(EINVAL);
  349. }
  350. return 0;
  351. }
  352. static int activate(AVFilterContext *ctx)
  353. {
  354. AudioFIRContext *s = ctx->priv;
  355. AVFilterLink *outlink = ctx->outputs[0];
  356. AVFrame *in = NULL;
  357. int ret, status;
  358. int64_t pts;
  359. FF_FILTER_FORWARD_STATUS_BACK_ALL(ctx->outputs[0], ctx);
  360. if (s->response)
  361. FF_FILTER_FORWARD_STATUS_BACK_ALL(ctx->outputs[1], ctx);
  362. if (!s->eof_coeffs) {
  363. AVFrame *ir = NULL;
  364. ret = check_ir(ctx->inputs[1], ir);
  365. if (ret < 0)
  366. return ret;
  367. if (ff_outlink_get_status(ctx->inputs[1]) == AVERROR_EOF)
  368. s->eof_coeffs = 1;
  369. if (!s->eof_coeffs) {
  370. if (ff_outlink_frame_wanted(ctx->outputs[0]))
  371. ff_inlink_request_frame(ctx->inputs[1]);
  372. return 0;
  373. }
  374. }
  375. if (!s->have_coeffs && s->eof_coeffs) {
  376. ret = convert_coeffs(ctx);
  377. if (ret < 0)
  378. return ret;
  379. }
  380. if (s->need_padding) {
  381. in = ff_get_audio_buffer(outlink, s->part_size);
  382. if (!in)
  383. return AVERROR(ENOMEM);
  384. s->need_padding = 0;
  385. ret = 1;
  386. } else {
  387. ret = ff_inlink_consume_samples(ctx->inputs[0], s->part_size, s->part_size, &in);
  388. }
  389. if (ret > 0) {
  390. ret = fir_frame(s, in, outlink);
  391. if (ret < 0)
  392. return ret;
  393. }
  394. if (ret < 0)
  395. return ret;
  396. if (s->response && s->have_coeffs) {
  397. if (ff_outlink_frame_wanted(ctx->outputs[1])) {
  398. s->video->pts = s->pts;
  399. ret = ff_filter_frame(ctx->outputs[1], av_frame_clone(s->video));
  400. if (ret < 0)
  401. return ret;
  402. }
  403. }
  404. if (ff_inlink_acknowledge_status(ctx->inputs[0], &status, &pts)) {
  405. if (status == AVERROR_EOF) {
  406. ff_outlink_set_status(ctx->outputs[0], status, pts);
  407. if (s->response)
  408. ff_outlink_set_status(ctx->outputs[1], status, pts);
  409. return 0;
  410. }
  411. }
  412. if (ff_outlink_frame_wanted(ctx->outputs[0])) {
  413. ff_inlink_request_frame(ctx->inputs[0]);
  414. return 0;
  415. }
  416. if (s->response && ff_outlink_frame_wanted(ctx->outputs[1])) {
  417. ff_inlink_request_frame(ctx->inputs[0]);
  418. return 0;
  419. }
  420. return 0;
  421. }
  422. static int query_formats(AVFilterContext *ctx)
  423. {
  424. AudioFIRContext *s = ctx->priv;
  425. AVFilterFormats *formats;
  426. AVFilterChannelLayouts *layouts;
  427. static const enum AVSampleFormat sample_fmts[] = {
  428. AV_SAMPLE_FMT_FLTP,
  429. AV_SAMPLE_FMT_NONE
  430. };
  431. static const enum AVPixelFormat pix_fmts[] = {
  432. AV_PIX_FMT_RGB0,
  433. AV_PIX_FMT_NONE
  434. };
  435. int ret;
  436. if (s->response) {
  437. AVFilterLink *videolink = ctx->outputs[1];
  438. formats = ff_make_format_list(pix_fmts);
  439. if ((ret = ff_formats_ref(formats, &videolink->in_formats)) < 0)
  440. return ret;
  441. }
  442. layouts = ff_all_channel_counts();
  443. if (!layouts)
  444. return AVERROR(ENOMEM);
  445. if (s->ir_format) {
  446. ret = ff_set_common_channel_layouts(ctx, layouts);
  447. if (ret < 0)
  448. return ret;
  449. } else {
  450. AVFilterChannelLayouts *mono = NULL;
  451. ret = ff_add_channel_layout(&mono, AV_CH_LAYOUT_MONO);
  452. if (ret)
  453. return ret;
  454. if ((ret = ff_channel_layouts_ref(layouts, &ctx->inputs[0]->out_channel_layouts)) < 0)
  455. return ret;
  456. if ((ret = ff_channel_layouts_ref(layouts, &ctx->outputs[0]->in_channel_layouts)) < 0)
  457. return ret;
  458. if ((ret = ff_channel_layouts_ref(mono, &ctx->inputs[1]->out_channel_layouts)) < 0)
  459. return ret;
  460. }
  461. formats = ff_make_format_list(sample_fmts);
  462. if ((ret = ff_set_common_formats(ctx, formats)) < 0)
  463. return ret;
  464. formats = ff_all_samplerates();
  465. return ff_set_common_samplerates(ctx, formats);
  466. }
  467. static int config_output(AVFilterLink *outlink)
  468. {
  469. AVFilterContext *ctx = outlink->src;
  470. AudioFIRContext *s = ctx->priv;
  471. s->one2many = ctx->inputs[1]->channels == 1;
  472. outlink->sample_rate = ctx->inputs[0]->sample_rate;
  473. outlink->time_base = ctx->inputs[0]->time_base;
  474. outlink->channel_layout = ctx->inputs[0]->channel_layout;
  475. outlink->channels = ctx->inputs[0]->channels;
  476. s->sum = av_calloc(outlink->channels, sizeof(*s->sum));
  477. s->coeff = av_calloc(ctx->inputs[1]->channels, sizeof(*s->coeff));
  478. s->block = av_calloc(ctx->inputs[0]->channels, sizeof(*s->block));
  479. s->rdft = av_calloc(outlink->channels, sizeof(*s->rdft));
  480. s->irdft = av_calloc(outlink->channels, sizeof(*s->irdft));
  481. if (!s->sum || !s->coeff || !s->block || !s->rdft || !s->irdft)
  482. return AVERROR(ENOMEM);
  483. s->nb_channels = outlink->channels;
  484. s->nb_coef_channels = ctx->inputs[1]->channels;
  485. s->want_skip = 1;
  486. s->need_padding = 1;
  487. s->pts = AV_NOPTS_VALUE;
  488. return 0;
  489. }
  490. static av_cold void uninit(AVFilterContext *ctx)
  491. {
  492. AudioFIRContext *s = ctx->priv;
  493. int ch;
  494. if (s->sum) {
  495. for (ch = 0; ch < s->nb_channels; ch++) {
  496. av_freep(&s->sum[ch]);
  497. }
  498. }
  499. av_freep(&s->sum);
  500. if (s->coeff) {
  501. for (ch = 0; ch < s->nb_coef_channels; ch++) {
  502. av_freep(&s->coeff[ch]);
  503. }
  504. }
  505. av_freep(&s->coeff);
  506. if (s->block) {
  507. for (ch = 0; ch < s->nb_channels; ch++) {
  508. av_freep(&s->block[ch]);
  509. }
  510. }
  511. av_freep(&s->block);
  512. if (s->rdft) {
  513. for (ch = 0; ch < s->nb_channels; ch++) {
  514. av_rdft_end(s->rdft[ch]);
  515. }
  516. }
  517. av_freep(&s->rdft);
  518. if (s->irdft) {
  519. for (ch = 0; ch < s->nb_channels; ch++) {
  520. av_rdft_end(s->irdft[ch]);
  521. }
  522. }
  523. av_freep(&s->irdft);
  524. av_frame_free(&s->in[1]);
  525. av_frame_free(&s->buffer);
  526. av_freep(&s->fdsp);
  527. for (int i = 0; i < ctx->nb_outputs; i++)
  528. av_freep(&ctx->output_pads[i].name);
  529. av_frame_free(&s->video);
  530. }
  531. static int config_video(AVFilterLink *outlink)
  532. {
  533. AVFilterContext *ctx = outlink->src;
  534. AudioFIRContext *s = ctx->priv;
  535. outlink->sample_aspect_ratio = (AVRational){1,1};
  536. outlink->w = s->w;
  537. outlink->h = s->h;
  538. av_frame_free(&s->video);
  539. s->video = ff_get_video_buffer(outlink, outlink->w, outlink->h);
  540. if (!s->video)
  541. return AVERROR(ENOMEM);
  542. return 0;
  543. }
  544. static av_cold int init(AVFilterContext *ctx)
  545. {
  546. AudioFIRContext *s = ctx->priv;
  547. AVFilterPad pad, vpad;
  548. int ret;
  549. pad = (AVFilterPad){
  550. .name = av_strdup("default"),
  551. .type = AVMEDIA_TYPE_AUDIO,
  552. .config_props = config_output,
  553. };
  554. if (!pad.name)
  555. return AVERROR(ENOMEM);
  556. if (s->response) {
  557. vpad = (AVFilterPad){
  558. .name = av_strdup("filter_response"),
  559. .type = AVMEDIA_TYPE_VIDEO,
  560. .config_props = config_video,
  561. };
  562. if (!vpad.name)
  563. return AVERROR(ENOMEM);
  564. }
  565. ret = ff_insert_outpad(ctx, 0, &pad);
  566. if (ret < 0) {
  567. av_freep(&pad.name);
  568. return ret;
  569. }
  570. if (s->response) {
  571. ret = ff_insert_outpad(ctx, 1, &vpad);
  572. if (ret < 0) {
  573. av_freep(&vpad.name);
  574. return ret;
  575. }
  576. }
  577. s->fcmul_add = fcmul_add_c;
  578. s->fdsp = avpriv_float_dsp_alloc(0);
  579. if (!s->fdsp)
  580. return AVERROR(ENOMEM);
  581. if (ARCH_X86)
  582. ff_afir_init_x86(s);
  583. return 0;
  584. }
  585. static const AVFilterPad afir_inputs[] = {
  586. {
  587. .name = "main",
  588. .type = AVMEDIA_TYPE_AUDIO,
  589. },{
  590. .name = "ir",
  591. .type = AVMEDIA_TYPE_AUDIO,
  592. },
  593. { NULL }
  594. };
  595. #define AF AV_OPT_FLAG_AUDIO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
  596. #define VF AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
  597. #define OFFSET(x) offsetof(AudioFIRContext, x)
  598. static const AVOption afir_options[] = {
  599. { "dry", "set dry gain", OFFSET(dry_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 10, AF },
  600. { "wet", "set wet gain", OFFSET(wet_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 10, AF },
  601. { "length", "set IR length", OFFSET(length), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 1, AF },
  602. { "again", "enable auto gain", OFFSET(again), AV_OPT_TYPE_BOOL, {.i64=1}, 0, 1, AF },
  603. { "gtype", "set auto gain type",OFFSET(gtype), AV_OPT_TYPE_INT, {.i64=0}, 0, 2, AF, "gtype" },
  604. { "peak", "peak gain", 0, AV_OPT_TYPE_CONST, {.i64=0}, 0, 0, AF, "gtype" },
  605. { "dc", "DC gain", 0, AV_OPT_TYPE_CONST, {.i64=1}, 0, 0, AF, "gtype" },
  606. { "gn", "gain to noise", 0, AV_OPT_TYPE_CONST, {.i64=2}, 0, 0, AF, "gtype" },
  607. { "irgain", "set IR gain", OFFSET(ir_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 1, AF },
  608. { "irfmt", "set IR format", OFFSET(ir_format), AV_OPT_TYPE_INT, {.i64=1}, 0, 1, AF, "irfmt" },
  609. { "mono", "single channel", 0, AV_OPT_TYPE_CONST, {.i64=0}, 0, 0, AF, "irfmt" },
  610. { "input", "same as input", 0, AV_OPT_TYPE_CONST, {.i64=1}, 0, 0, AF, "irfmt" },
  611. { "maxir", "set max IR length", OFFSET(max_ir_len), AV_OPT_TYPE_FLOAT, {.dbl=30}, 0.1, 60, AF },
  612. { "response", "show IR frequency response", OFFSET(response), AV_OPT_TYPE_BOOL, {.i64=0}, 0, 1, VF },
  613. { "channel", "set IR channel to display frequency response", OFFSET(ir_channel), AV_OPT_TYPE_INT, {.i64=0}, 0, 1024, VF },
  614. { "size", "set video size", OFFSET(w), AV_OPT_TYPE_IMAGE_SIZE, {.str = "hd720"}, 0, 0, VF },
  615. { NULL }
  616. };
  617. AVFILTER_DEFINE_CLASS(afir);
  618. AVFilter ff_af_afir = {
  619. .name = "afir",
  620. .description = NULL_IF_CONFIG_SMALL("Apply Finite Impulse Response filter with supplied coefficients in 2nd stream."),
  621. .priv_size = sizeof(AudioFIRContext),
  622. .priv_class = &afir_class,
  623. .query_formats = query_formats,
  624. .init = init,
  625. .activate = activate,
  626. .uninit = uninit,
  627. .inputs = afir_inputs,
  628. .flags = AVFILTER_FLAG_DYNAMIC_OUTPUTS |
  629. AVFILTER_FLAG_SLICE_THREADS,
  630. };