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.

773 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. switch (s->gtype) {
  270. case -1:
  271. /* nothinkg to do */
  272. break;
  273. case 0:
  274. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  275. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  276. for (i = 0; i < s->nb_taps; i++)
  277. power += FFABS(time[i]);
  278. }
  279. s->gain = ctx->inputs[1]->channels / power;
  280. break;
  281. case 1:
  282. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  283. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  284. for (i = 0; i < s->nb_taps; i++)
  285. power += time[i];
  286. }
  287. s->gain = ctx->inputs[1]->channels / power;
  288. break;
  289. case 2:
  290. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  291. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  292. for (i = 0; i < s->nb_taps; i++)
  293. power += time[i] * time[i];
  294. }
  295. s->gain = sqrtf(ch / power);
  296. break;
  297. default:
  298. return AVERROR_BUG;
  299. }
  300. s->gain = FFMIN(s->gain * s->ir_gain, 1.f);
  301. av_log(ctx, AV_LOG_DEBUG, "power %f, gain %f\n", power, s->gain);
  302. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  303. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  304. s->fdsp->vector_fmul_scalar(time, time, s->gain, FFALIGN(s->nb_taps, 4));
  305. }
  306. for (ch = 0; ch < ctx->inputs[1]->channels; ch++) {
  307. float *time = (float *)s->in[1]->extended_data[!s->one2many * ch];
  308. float *block = s->block[ch];
  309. FFTComplex *coeff = s->coeff[ch];
  310. for (i = FFMAX(1, s->length * s->nb_taps); i < s->nb_taps; i++)
  311. time[i] = 0;
  312. for (i = 0; i < s->nb_partitions; i++) {
  313. const float scale = 1.f / s->part_size;
  314. const int toffset = i * s->part_size;
  315. const int coffset = i * s->coeff_size;
  316. const int boffset = s->part_size;
  317. const int remaining = s->nb_taps - (i * s->part_size);
  318. const int size = remaining >= s->part_size ? s->part_size : remaining;
  319. memset(block, 0, sizeof(*block) * s->fft_length);
  320. memcpy(block + boffset, time + toffset, size * sizeof(*block));
  321. av_rdft_calc(s->rdft[0], block);
  322. coeff[coffset].re = block[0] * scale;
  323. coeff[coffset].im = 0;
  324. for (n = 1; n < s->part_size; n++) {
  325. coeff[coffset + n].re = block[2 * n] * scale;
  326. coeff[coffset + n].im = block[2 * n + 1] * scale;
  327. }
  328. coeff[coffset + s->part_size].re = block[1] * scale;
  329. coeff[coffset + s->part_size].im = 0;
  330. }
  331. }
  332. av_frame_free(&s->in[1]);
  333. av_log(ctx, AV_LOG_DEBUG, "nb_taps: %d\n", s->nb_taps);
  334. av_log(ctx, AV_LOG_DEBUG, "nb_partitions: %d\n", s->nb_partitions);
  335. av_log(ctx, AV_LOG_DEBUG, "partition size: %d\n", s->part_size);
  336. av_log(ctx, AV_LOG_DEBUG, "ir_length: %d\n", s->ir_length);
  337. s->have_coeffs = 1;
  338. return 0;
  339. }
  340. static int check_ir(AVFilterLink *link, AVFrame *frame)
  341. {
  342. AVFilterContext *ctx = link->dst;
  343. AudioFIRContext *s = ctx->priv;
  344. int nb_taps, max_nb_taps;
  345. nb_taps = ff_inlink_queued_samples(link);
  346. max_nb_taps = s->max_ir_len * ctx->outputs[0]->sample_rate;
  347. if (nb_taps > max_nb_taps) {
  348. av_log(ctx, AV_LOG_ERROR, "Too big number of coefficients: %d > %d.\n", nb_taps, max_nb_taps);
  349. return AVERROR(EINVAL);
  350. }
  351. return 0;
  352. }
  353. static int activate(AVFilterContext *ctx)
  354. {
  355. AudioFIRContext *s = ctx->priv;
  356. AVFilterLink *outlink = ctx->outputs[0];
  357. AVFrame *in = NULL;
  358. int ret, status;
  359. int64_t pts;
  360. FF_FILTER_FORWARD_STATUS_BACK_ALL(ctx->outputs[0], ctx);
  361. if (s->response)
  362. FF_FILTER_FORWARD_STATUS_BACK_ALL(ctx->outputs[1], ctx);
  363. if (!s->eof_coeffs) {
  364. AVFrame *ir = NULL;
  365. ret = check_ir(ctx->inputs[1], ir);
  366. if (ret < 0)
  367. return ret;
  368. if (ff_outlink_get_status(ctx->inputs[1]) == AVERROR_EOF)
  369. s->eof_coeffs = 1;
  370. if (!s->eof_coeffs) {
  371. if (ff_outlink_frame_wanted(ctx->outputs[0]))
  372. ff_inlink_request_frame(ctx->inputs[1]);
  373. return 0;
  374. }
  375. }
  376. if (!s->have_coeffs && s->eof_coeffs) {
  377. ret = convert_coeffs(ctx);
  378. if (ret < 0)
  379. return ret;
  380. }
  381. if (s->need_padding) {
  382. in = ff_get_audio_buffer(outlink, s->part_size);
  383. if (!in)
  384. return AVERROR(ENOMEM);
  385. s->need_padding = 0;
  386. ret = 1;
  387. } else {
  388. ret = ff_inlink_consume_samples(ctx->inputs[0], s->part_size, s->part_size, &in);
  389. }
  390. if (ret > 0) {
  391. ret = fir_frame(s, in, outlink);
  392. if (ret < 0)
  393. return ret;
  394. }
  395. if (ret < 0)
  396. return ret;
  397. if (s->response && s->have_coeffs) {
  398. if (ff_outlink_frame_wanted(ctx->outputs[1])) {
  399. s->video->pts = s->pts;
  400. ret = ff_filter_frame(ctx->outputs[1], av_frame_clone(s->video));
  401. if (ret < 0)
  402. return ret;
  403. }
  404. }
  405. if (ff_inlink_acknowledge_status(ctx->inputs[0], &status, &pts)) {
  406. if (status == AVERROR_EOF) {
  407. ff_outlink_set_status(ctx->outputs[0], status, pts);
  408. if (s->response)
  409. ff_outlink_set_status(ctx->outputs[1], status, pts);
  410. return 0;
  411. }
  412. }
  413. if (ff_outlink_frame_wanted(ctx->outputs[0])) {
  414. ff_inlink_request_frame(ctx->inputs[0]);
  415. return 0;
  416. }
  417. if (s->response && ff_outlink_frame_wanted(ctx->outputs[1])) {
  418. ff_inlink_request_frame(ctx->inputs[0]);
  419. return 0;
  420. }
  421. return 0;
  422. }
  423. static int query_formats(AVFilterContext *ctx)
  424. {
  425. AudioFIRContext *s = ctx->priv;
  426. AVFilterFormats *formats;
  427. AVFilterChannelLayouts *layouts;
  428. static const enum AVSampleFormat sample_fmts[] = {
  429. AV_SAMPLE_FMT_FLTP,
  430. AV_SAMPLE_FMT_NONE
  431. };
  432. static const enum AVPixelFormat pix_fmts[] = {
  433. AV_PIX_FMT_RGB0,
  434. AV_PIX_FMT_NONE
  435. };
  436. int ret;
  437. if (s->response) {
  438. AVFilterLink *videolink = ctx->outputs[1];
  439. formats = ff_make_format_list(pix_fmts);
  440. if ((ret = ff_formats_ref(formats, &videolink->in_formats)) < 0)
  441. return ret;
  442. }
  443. layouts = ff_all_channel_counts();
  444. if (!layouts)
  445. return AVERROR(ENOMEM);
  446. if (s->ir_format) {
  447. ret = ff_set_common_channel_layouts(ctx, layouts);
  448. if (ret < 0)
  449. return ret;
  450. } else {
  451. AVFilterChannelLayouts *mono = NULL;
  452. ret = ff_add_channel_layout(&mono, AV_CH_LAYOUT_MONO);
  453. if (ret)
  454. return ret;
  455. if ((ret = ff_channel_layouts_ref(layouts, &ctx->inputs[0]->out_channel_layouts)) < 0)
  456. return ret;
  457. if ((ret = ff_channel_layouts_ref(layouts, &ctx->outputs[0]->in_channel_layouts)) < 0)
  458. return ret;
  459. if ((ret = ff_channel_layouts_ref(mono, &ctx->inputs[1]->out_channel_layouts)) < 0)
  460. return ret;
  461. }
  462. formats = ff_make_format_list(sample_fmts);
  463. if ((ret = ff_set_common_formats(ctx, formats)) < 0)
  464. return ret;
  465. formats = ff_all_samplerates();
  466. return ff_set_common_samplerates(ctx, formats);
  467. }
  468. static int config_output(AVFilterLink *outlink)
  469. {
  470. AVFilterContext *ctx = outlink->src;
  471. AudioFIRContext *s = ctx->priv;
  472. s->one2many = ctx->inputs[1]->channels == 1;
  473. outlink->sample_rate = ctx->inputs[0]->sample_rate;
  474. outlink->time_base = ctx->inputs[0]->time_base;
  475. outlink->channel_layout = ctx->inputs[0]->channel_layout;
  476. outlink->channels = ctx->inputs[0]->channels;
  477. s->sum = av_calloc(outlink->channels, sizeof(*s->sum));
  478. s->coeff = av_calloc(ctx->inputs[1]->channels, sizeof(*s->coeff));
  479. s->block = av_calloc(ctx->inputs[0]->channels, sizeof(*s->block));
  480. s->rdft = av_calloc(outlink->channels, sizeof(*s->rdft));
  481. s->irdft = av_calloc(outlink->channels, sizeof(*s->irdft));
  482. if (!s->sum || !s->coeff || !s->block || !s->rdft || !s->irdft)
  483. return AVERROR(ENOMEM);
  484. s->nb_channels = outlink->channels;
  485. s->nb_coef_channels = ctx->inputs[1]->channels;
  486. s->want_skip = 1;
  487. s->need_padding = 1;
  488. s->pts = AV_NOPTS_VALUE;
  489. return 0;
  490. }
  491. static av_cold void uninit(AVFilterContext *ctx)
  492. {
  493. AudioFIRContext *s = ctx->priv;
  494. int ch;
  495. if (s->sum) {
  496. for (ch = 0; ch < s->nb_channels; ch++) {
  497. av_freep(&s->sum[ch]);
  498. }
  499. }
  500. av_freep(&s->sum);
  501. if (s->coeff) {
  502. for (ch = 0; ch < s->nb_coef_channels; ch++) {
  503. av_freep(&s->coeff[ch]);
  504. }
  505. }
  506. av_freep(&s->coeff);
  507. if (s->block) {
  508. for (ch = 0; ch < s->nb_channels; ch++) {
  509. av_freep(&s->block[ch]);
  510. }
  511. }
  512. av_freep(&s->block);
  513. if (s->rdft) {
  514. for (ch = 0; ch < s->nb_channels; ch++) {
  515. av_rdft_end(s->rdft[ch]);
  516. }
  517. }
  518. av_freep(&s->rdft);
  519. if (s->irdft) {
  520. for (ch = 0; ch < s->nb_channels; ch++) {
  521. av_rdft_end(s->irdft[ch]);
  522. }
  523. }
  524. av_freep(&s->irdft);
  525. av_frame_free(&s->in[1]);
  526. av_frame_free(&s->buffer);
  527. av_freep(&s->fdsp);
  528. for (int i = 0; i < ctx->nb_outputs; i++)
  529. av_freep(&ctx->output_pads[i].name);
  530. av_frame_free(&s->video);
  531. }
  532. static int config_video(AVFilterLink *outlink)
  533. {
  534. AVFilterContext *ctx = outlink->src;
  535. AudioFIRContext *s = ctx->priv;
  536. outlink->sample_aspect_ratio = (AVRational){1,1};
  537. outlink->w = s->w;
  538. outlink->h = s->h;
  539. av_frame_free(&s->video);
  540. s->video = ff_get_video_buffer(outlink, outlink->w, outlink->h);
  541. if (!s->video)
  542. return AVERROR(ENOMEM);
  543. return 0;
  544. }
  545. static av_cold int init(AVFilterContext *ctx)
  546. {
  547. AudioFIRContext *s = ctx->priv;
  548. AVFilterPad pad, vpad;
  549. int ret;
  550. pad = (AVFilterPad){
  551. .name = av_strdup("default"),
  552. .type = AVMEDIA_TYPE_AUDIO,
  553. .config_props = config_output,
  554. };
  555. if (!pad.name)
  556. return AVERROR(ENOMEM);
  557. if (s->response) {
  558. vpad = (AVFilterPad){
  559. .name = av_strdup("filter_response"),
  560. .type = AVMEDIA_TYPE_VIDEO,
  561. .config_props = config_video,
  562. };
  563. if (!vpad.name)
  564. return AVERROR(ENOMEM);
  565. }
  566. ret = ff_insert_outpad(ctx, 0, &pad);
  567. if (ret < 0) {
  568. av_freep(&pad.name);
  569. return ret;
  570. }
  571. if (s->response) {
  572. ret = ff_insert_outpad(ctx, 1, &vpad);
  573. if (ret < 0) {
  574. av_freep(&vpad.name);
  575. return ret;
  576. }
  577. }
  578. s->fcmul_add = fcmul_add_c;
  579. s->fdsp = avpriv_float_dsp_alloc(0);
  580. if (!s->fdsp)
  581. return AVERROR(ENOMEM);
  582. if (ARCH_X86)
  583. ff_afir_init_x86(s);
  584. return 0;
  585. }
  586. static const AVFilterPad afir_inputs[] = {
  587. {
  588. .name = "main",
  589. .type = AVMEDIA_TYPE_AUDIO,
  590. },{
  591. .name = "ir",
  592. .type = AVMEDIA_TYPE_AUDIO,
  593. },
  594. { NULL }
  595. };
  596. #define AF AV_OPT_FLAG_AUDIO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
  597. #define VF AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
  598. #define OFFSET(x) offsetof(AudioFIRContext, x)
  599. static const AVOption afir_options[] = {
  600. { "dry", "set dry gain", OFFSET(dry_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 10, AF },
  601. { "wet", "set wet gain", OFFSET(wet_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 10, AF },
  602. { "length", "set IR length", OFFSET(length), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 1, AF },
  603. { "gtype", "set IR auto gain type",OFFSET(gtype), AV_OPT_TYPE_INT, {.i64=0}, -1, 2, AF, "gtype" },
  604. { "none", "without auto gain", 0, AV_OPT_TYPE_CONST, {.i64=-1}, 0, 0, AF, "gtype" },
  605. { "peak", "peak gain", 0, AV_OPT_TYPE_CONST, {.i64=0}, 0, 0, AF, "gtype" },
  606. { "dc", "DC gain", 0, AV_OPT_TYPE_CONST, {.i64=1}, 0, 0, AF, "gtype" },
  607. { "gn", "gain to noise", 0, AV_OPT_TYPE_CONST, {.i64=2}, 0, 0, AF, "gtype" },
  608. { "irgain", "set IR gain", OFFSET(ir_gain), AV_OPT_TYPE_FLOAT, {.dbl=1}, 0, 1, AF },
  609. { "irfmt", "set IR format", OFFSET(ir_format), AV_OPT_TYPE_INT, {.i64=1}, 0, 1, AF, "irfmt" },
  610. { "mono", "single channel", 0, AV_OPT_TYPE_CONST, {.i64=0}, 0, 0, AF, "irfmt" },
  611. { "input", "same as input", 0, AV_OPT_TYPE_CONST, {.i64=1}, 0, 0, AF, "irfmt" },
  612. { "maxir", "set max IR length", OFFSET(max_ir_len), AV_OPT_TYPE_FLOAT, {.dbl=30}, 0.1, 60, AF },
  613. { "response", "show IR frequency response", OFFSET(response), AV_OPT_TYPE_BOOL, {.i64=0}, 0, 1, VF },
  614. { "channel", "set IR channel to display frequency response", OFFSET(ir_channel), AV_OPT_TYPE_INT, {.i64=0}, 0, 1024, VF },
  615. { "size", "set video size", OFFSET(w), AV_OPT_TYPE_IMAGE_SIZE, {.str = "hd720"}, 0, 0, VF },
  616. { NULL }
  617. };
  618. AVFILTER_DEFINE_CLASS(afir);
  619. AVFilter ff_af_afir = {
  620. .name = "afir",
  621. .description = NULL_IF_CONFIG_SMALL("Apply Finite Impulse Response filter with supplied coefficients in 2nd stream."),
  622. .priv_size = sizeof(AudioFIRContext),
  623. .priv_class = &afir_class,
  624. .query_formats = query_formats,
  625. .init = init,
  626. .activate = activate,
  627. .uninit = uninit,
  628. .inputs = afir_inputs,
  629. .flags = AVFILTER_FLAG_DYNAMIC_OUTPUTS |
  630. AVFILTER_FLAG_SLICE_THREADS,
  631. };