]> git.sesse.net Git - ffmpeg/blob - libavformat/avisynth.c
5756aea0b68eb6da150f4b4df4fc9a74293d1a06
[ffmpeg] / libavformat / avisynth.c
1 /*
2  * AviSynth(+) support
3  * Copyright (c) 2012 AvxSynth Team
4  *
5  * This file is part of FFmpeg
6  *
7  * FFmpeg is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Lesser General Public
9  * License as published by the Free Software Foundation; either
10  * version 2.1 of the License, or (at your option) any later version.
11  *
12  * FFmpeg is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * Lesser General Public License for more details.
16  *
17  * You should have received a copy of the GNU Lesser General Public
18  * License along with FFmpeg; if not, write to the Free Software
19  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20  */
21
22 #include "libavutil/attributes.h"
23 #include "libavutil/internal.h"
24
25 #include "libavcodec/internal.h"
26
27 #include "avformat.h"
28 #include "internal.h"
29 #include "config.h"
30
31 /* Enable function pointer definitions for runtime loading. */
32 #define AVSC_NO_DECLSPEC
33
34 /* Platform-specific directives. */
35 #ifdef _WIN32
36   #include "compat/w32dlfcn.h"
37   #undef EXTERN_C
38   #define AVISYNTH_LIB "avisynth"
39 #else
40   #include <dlfcn.h>
41   #define AVISYNTH_NAME "libavisynth"
42   #define AVISYNTH_LIB AVISYNTH_NAME SLIBSUF
43 #endif
44
45 #include <avisynth/avisynth_c.h>
46
47 typedef struct AviSynthLibrary {
48     void *library;
49 #define AVSC_DECLARE_FUNC(name) name ## _func name
50     AVSC_DECLARE_FUNC(avs_bit_blt);
51     AVSC_DECLARE_FUNC(avs_clip_get_error);
52     AVSC_DECLARE_FUNC(avs_create_script_environment);
53     AVSC_DECLARE_FUNC(avs_delete_script_environment);
54     AVSC_DECLARE_FUNC(avs_get_audio);
55     AVSC_DECLARE_FUNC(avs_get_error);
56     AVSC_DECLARE_FUNC(avs_get_frame);
57     AVSC_DECLARE_FUNC(avs_get_version);
58     AVSC_DECLARE_FUNC(avs_get_video_info);
59     AVSC_DECLARE_FUNC(avs_invoke);
60     AVSC_DECLARE_FUNC(avs_is_color_space);
61     AVSC_DECLARE_FUNC(avs_release_clip);
62     AVSC_DECLARE_FUNC(avs_release_value);
63     AVSC_DECLARE_FUNC(avs_release_video_frame);
64     AVSC_DECLARE_FUNC(avs_take_clip);
65     AVSC_DECLARE_FUNC(avs_bits_per_pixel);
66     AVSC_DECLARE_FUNC(avs_get_height_p);
67     AVSC_DECLARE_FUNC(avs_get_pitch_p);
68     AVSC_DECLARE_FUNC(avs_get_read_ptr_p);
69     AVSC_DECLARE_FUNC(avs_get_row_size_p);
70     AVSC_DECLARE_FUNC(avs_is_planar_rgb);
71     AVSC_DECLARE_FUNC(avs_is_planar_rgba);
72 #undef AVSC_DECLARE_FUNC
73 } AviSynthLibrary;
74
75 typedef struct AviSynthContext {
76     AVS_ScriptEnvironment *env;
77     AVS_Clip *clip;
78     const AVS_VideoInfo *vi;
79
80     /* avisynth_read_packet_video() iterates over this. */
81     int n_planes;
82     const int *planes;
83
84     int curr_stream;
85     int curr_frame;
86     int64_t curr_sample;
87
88     int error;
89
90     /* Linked list pointers. */
91     struct AviSynthContext *next;
92 } AviSynthContext;
93
94 static const int avs_planes_packed[1] = { 0 };
95 static const int avs_planes_grey[1]   = { AVS_PLANAR_Y };
96 static const int avs_planes_yuv[3]    = { AVS_PLANAR_Y, AVS_PLANAR_U,
97                                           AVS_PLANAR_V };
98 static const int avs_planes_rgb[3]    = { AVS_PLANAR_G, AVS_PLANAR_B,
99                                           AVS_PLANAR_R };
100 static const int avs_planes_yuva[4]   = { AVS_PLANAR_Y, AVS_PLANAR_U,
101                                           AVS_PLANAR_V, AVS_PLANAR_A };
102 static const int avs_planes_rgba[4]   = { AVS_PLANAR_G, AVS_PLANAR_B,
103                                           AVS_PLANAR_R, AVS_PLANAR_A };
104
105 /* A conflict between C++ global objects, atexit, and dynamic loading requires
106  * us to register our own atexit handler to prevent double freeing. */
107 static AviSynthLibrary avs_library;
108 static int avs_atexit_called        = 0;
109
110 /* Linked list of AviSynthContexts. An atexit handler destroys this list. */
111 static AviSynthContext *avs_ctx_list = NULL;
112
113 static av_cold void avisynth_atexit_handler(void);
114
115 static av_cold int avisynth_load_library(void)
116 {
117     avs_library.library = dlopen(AVISYNTH_LIB, RTLD_NOW | RTLD_LOCAL);
118     if (!avs_library.library)
119         return AVERROR_UNKNOWN;
120
121 #define LOAD_AVS_FUNC(name, continue_on_fail)                          \
122         avs_library.name = (name ## _func)                             \
123                            dlsym(avs_library.library, #name);          \
124         if (!continue_on_fail && !avs_library.name)                    \
125             goto fail;
126
127     LOAD_AVS_FUNC(avs_bit_blt, 0);
128     LOAD_AVS_FUNC(avs_clip_get_error, 0);
129     LOAD_AVS_FUNC(avs_create_script_environment, 0);
130     LOAD_AVS_FUNC(avs_delete_script_environment, 0);
131     LOAD_AVS_FUNC(avs_get_audio, 0);
132     LOAD_AVS_FUNC(avs_get_error, 1); // New to AviSynth 2.6
133     LOAD_AVS_FUNC(avs_get_frame, 0);
134     LOAD_AVS_FUNC(avs_get_version, 0);
135     LOAD_AVS_FUNC(avs_get_video_info, 0);
136     LOAD_AVS_FUNC(avs_invoke, 0);
137     LOAD_AVS_FUNC(avs_is_color_space, 1);
138     LOAD_AVS_FUNC(avs_release_clip, 0);
139     LOAD_AVS_FUNC(avs_release_value, 0);
140     LOAD_AVS_FUNC(avs_release_video_frame, 0);
141     LOAD_AVS_FUNC(avs_take_clip, 0);
142     LOAD_AVS_FUNC(avs_bits_per_pixel, 1);
143     LOAD_AVS_FUNC(avs_get_height_p, 1);
144     LOAD_AVS_FUNC(avs_get_pitch_p, 1);
145     LOAD_AVS_FUNC(avs_get_read_ptr_p, 1);
146     LOAD_AVS_FUNC(avs_get_row_size_p, 1);
147     LOAD_AVS_FUNC(avs_is_planar_rgb, 1);
148     LOAD_AVS_FUNC(avs_is_planar_rgba, 1);
149 #undef LOAD_AVS_FUNC
150
151     atexit(avisynth_atexit_handler);
152     return 0;
153
154 fail:
155     dlclose(avs_library.library);
156     return AVERROR_UNKNOWN;
157 }
158
159 /* Note that avisynth_context_create and avisynth_context_destroy
160  * do not allocate or free the actual context! That is taken care of
161  * by libavformat. */
162 static av_cold int avisynth_context_create(AVFormatContext *s)
163 {
164     AviSynthContext *avs = s->priv_data;
165     int ret;
166
167     if (!avs_library.library)
168         if (ret = avisynth_load_library())
169             return ret;
170
171     avs->env = avs_library.avs_create_script_environment(3);
172     if (avs_library.avs_get_error) {
173         const char *error = avs_library.avs_get_error(avs->env);
174         if (error) {
175             av_log(s, AV_LOG_ERROR, "%s\n", error);
176             return AVERROR_UNKNOWN;
177         }
178     }
179
180     if (!avs_ctx_list) {
181         avs_ctx_list = avs;
182     } else {
183         avs->next    = avs_ctx_list;
184         avs_ctx_list = avs;
185     }
186
187     return 0;
188 }
189
190 static av_cold void avisynth_context_destroy(AviSynthContext *avs)
191 {
192     if (avs_atexit_called)
193         return;
194
195     if (avs == avs_ctx_list) {
196         avs_ctx_list = avs->next;
197     } else {
198         AviSynthContext *prev = avs_ctx_list;
199         while (prev->next != avs)
200             prev = prev->next;
201         prev->next = avs->next;
202     }
203
204     if (avs->clip) {
205         avs_library.avs_release_clip(avs->clip);
206         avs->clip = NULL;
207     }
208     if (avs->env) {
209         avs_library.avs_delete_script_environment(avs->env);
210         avs->env = NULL;
211     }
212 }
213
214 static av_cold void avisynth_atexit_handler(void)
215 {
216     AviSynthContext *avs = avs_ctx_list;
217
218     while (avs) {
219         AviSynthContext *next = avs->next;
220         avisynth_context_destroy(avs);
221         avs = next;
222     }
223     dlclose(avs_library.library);
224
225     avs_atexit_called = 1;
226 }
227
228 /* Create AVStream from audio and video data. */
229 static int avisynth_create_stream_video(AVFormatContext *s, AVStream *st)
230 {
231     AviSynthContext *avs = s->priv_data;
232     int planar = 0; // 0: packed, 1: YUV, 2: Y8, 3: Planar RGB, 4: YUVA, 5: Planar RGBA
233
234     st->codecpar->codec_type = AVMEDIA_TYPE_VIDEO;
235     st->codecpar->codec_id   = AV_CODEC_ID_RAWVIDEO;
236     st->codecpar->width      = avs->vi->width;
237     st->codecpar->height     = avs->vi->height;
238
239     st->avg_frame_rate    = (AVRational) { avs->vi->fps_numerator,
240                                            avs->vi->fps_denominator };
241     st->start_time        = 0;
242     st->duration          = avs->vi->num_frames;
243     st->nb_frames         = avs->vi->num_frames;
244     avpriv_set_pts_info(st, 32, avs->vi->fps_denominator, avs->vi->fps_numerator);
245
246     switch (avs->vi->pixel_type) {
247     /* 10~16-bit YUV pix_fmts (AviSynth+) */
248     case AVS_CS_YUV444P10:
249         st->codecpar->format = AV_PIX_FMT_YUV444P10;
250         planar               = 1;
251         break;
252     case AVS_CS_YUV422P10:
253         st->codecpar->format = AV_PIX_FMT_YUV422P10;
254         planar               = 1;
255         break;
256     case AVS_CS_YUV420P10:
257         st->codecpar->format = AV_PIX_FMT_YUV420P10;
258         planar               = 1;
259         break;
260     case AVS_CS_YUV444P12:
261         st->codecpar->format = AV_PIX_FMT_YUV444P12;
262         planar               = 1;
263         break;
264     case AVS_CS_YUV422P12:
265         st->codecpar->format = AV_PIX_FMT_YUV422P12;
266         planar               = 1;
267         break;
268     case AVS_CS_YUV420P12:
269         st->codecpar->format = AV_PIX_FMT_YUV420P12;
270         planar               = 1;
271         break;
272     case AVS_CS_YUV444P14:
273         st->codecpar->format = AV_PIX_FMT_YUV444P14;
274         planar               = 1;
275         break;
276     case AVS_CS_YUV422P14:
277         st->codecpar->format = AV_PIX_FMT_YUV422P14;
278         planar               = 1;
279         break;
280     case AVS_CS_YUV420P14:
281         st->codecpar->format = AV_PIX_FMT_YUV420P14;
282         planar               = 1;
283         break;
284     case AVS_CS_YUV444P16:
285         st->codecpar->format = AV_PIX_FMT_YUV444P16;
286         planar               = 1;
287         break;
288     case AVS_CS_YUV422P16:
289         st->codecpar->format = AV_PIX_FMT_YUV422P16;
290         planar               = 1;
291         break;
292     case AVS_CS_YUV420P16:
293         st->codecpar->format = AV_PIX_FMT_YUV420P16;
294         planar               = 1;
295         break;
296     /* 8~16-bit YUV pix_fmts with Alpha (AviSynth+) */
297     case AVS_CS_YUVA444:
298         st->codecpar->format = AV_PIX_FMT_YUVA444P;
299         planar               = 4;
300         break;
301     case AVS_CS_YUVA422:
302         st->codecpar->format = AV_PIX_FMT_YUVA422P;
303         planar               = 4;
304         break;
305     case AVS_CS_YUVA420:
306         st->codecpar->format = AV_PIX_FMT_YUVA420P;
307         planar               = 4;
308         break;
309     case AVS_CS_YUVA444P10:
310         st->codecpar->format = AV_PIX_FMT_YUVA444P10;
311         planar               = 4;
312         break;
313     case AVS_CS_YUVA422P10:
314         st->codecpar->format = AV_PIX_FMT_YUVA422P10;
315         planar               = 4;
316         break;
317     case AVS_CS_YUVA420P10:
318         st->codecpar->format = AV_PIX_FMT_YUVA420P10;
319         planar               = 4;
320         break;
321     case AVS_CS_YUVA422P12:
322         st->codecpar->format = AV_PIX_FMT_YUVA422P12;
323         planar               = 4;
324         break;
325     case AVS_CS_YUVA444P16:
326         st->codecpar->format = AV_PIX_FMT_YUVA444P16;
327         planar               = 4;
328         break;
329     case AVS_CS_YUVA422P16:
330         st->codecpar->format = AV_PIX_FMT_YUVA422P16;
331         planar               = 4;
332         break;
333     case AVS_CS_YUVA420P16:
334         st->codecpar->format = AV_PIX_FMT_YUVA420P16;
335         planar               = 4;
336         break;
337     /* Planar RGB pix_fmts (AviSynth+) */
338     case AVS_CS_RGBP:
339         st->codecpar->format = AV_PIX_FMT_GBRP;
340         planar               = 3;
341         break;
342     case AVS_CS_RGBP10:
343         st->codecpar->format = AV_PIX_FMT_GBRP10;
344         planar               = 3;
345         break;
346     case AVS_CS_RGBP12:
347         st->codecpar->format = AV_PIX_FMT_GBRP12;
348         planar               = 3;
349         break;
350     case AVS_CS_RGBP14:
351         st->codecpar->format = AV_PIX_FMT_GBRP14;
352         planar               = 3;
353         break;
354     case AVS_CS_RGBP16:
355         st->codecpar->format = AV_PIX_FMT_GBRP16;
356         planar               = 3;
357         break;
358     /* Single precision floating point Planar RGB (AviSynth+) */
359     case AVS_CS_RGBPS:
360         st->codecpar->format = AV_PIX_FMT_GBRPF32;
361         planar               = 3;
362         break;
363     /* Planar RGB pix_fmts with Alpha (AviSynth+) */
364     case AVS_CS_RGBAP:
365         st->codecpar->format = AV_PIX_FMT_GBRAP;
366         planar               = 5;
367         break;
368     case AVS_CS_RGBAP10:
369         st->codecpar->format = AV_PIX_FMT_GBRAP10;
370         planar               = 5;
371         break;
372     case AVS_CS_RGBAP12:
373         st->codecpar->format = AV_PIX_FMT_GBRAP12;
374         planar               = 5;
375         break;
376     case AVS_CS_RGBAP16:
377         st->codecpar->format = AV_PIX_FMT_GBRAP16;
378         planar               = 5;
379         break;
380     /* Single precision floating point Planar RGB with Alpha (AviSynth+) */
381     case AVS_CS_RGBAPS:
382         st->codecpar->format = AV_PIX_FMT_GBRAPF32;
383         planar               = 5;
384         break;
385     /* 10~16-bit gray pix_fmts (AviSynth+) */
386     case AVS_CS_Y10:
387         st->codecpar->format = AV_PIX_FMT_GRAY10;
388         planar               = 2;
389         break;
390     case AVS_CS_Y12:
391         st->codecpar->format = AV_PIX_FMT_GRAY12;
392         planar               = 2;
393         break;
394     case AVS_CS_Y14:
395         st->codecpar->format = AV_PIX_FMT_GRAY14;
396         planar               = 2;
397         break;
398     case AVS_CS_Y16:
399         st->codecpar->format = AV_PIX_FMT_GRAY16;
400         planar               = 2;
401         break;
402     /* Single precision floating point gray (AviSynth+) */
403     case AVS_CS_Y32:
404         st->codecpar->format = AV_PIX_FMT_GRAYF32;
405         planar               = 2;
406         break;
407     /* pix_fmts added in AviSynth 2.6 */
408     case AVS_CS_YV24:
409         st->codecpar->format = AV_PIX_FMT_YUV444P;
410         planar               = 1;
411         break;
412     case AVS_CS_YV16:
413         st->codecpar->format = AV_PIX_FMT_YUV422P;
414         planar               = 1;
415         break;
416     case AVS_CS_YV411:
417         st->codecpar->format = AV_PIX_FMT_YUV411P;
418         planar               = 1;
419         break;
420     case AVS_CS_Y8:
421         st->codecpar->format = AV_PIX_FMT_GRAY8;
422         planar               = 2;
423         break;
424     /* 16-bit packed RGB pix_fmts (AviSynth+) */
425     case AVS_CS_BGR48:
426         st->codecpar->format = AV_PIX_FMT_BGR48;
427         break;
428     case AVS_CS_BGR64:
429         st->codecpar->format = AV_PIX_FMT_BGRA64;
430         break;
431     /* AviSynth 2.5 pix_fmts */
432     case AVS_CS_BGR24:
433         st->codecpar->format = AV_PIX_FMT_BGR24;
434         break;
435     case AVS_CS_BGR32:
436         st->codecpar->format = AV_PIX_FMT_RGB32;
437         break;
438     case AVS_CS_YUY2:
439         st->codecpar->format = AV_PIX_FMT_YUYV422;
440         break;
441     case AVS_CS_YV12:
442         st->codecpar->format = AV_PIX_FMT_YUV420P;
443         planar               = 1;
444         break;
445     case AVS_CS_I420: // Is this even used anywhere?
446         st->codecpar->format = AV_PIX_FMT_YUV420P;
447         planar               = 1;
448         break;
449     default:
450         av_log(s, AV_LOG_ERROR,
451                "unknown AviSynth colorspace %d\n", avs->vi->pixel_type);
452         avs->error = 1;
453         return AVERROR_UNKNOWN;
454     }
455
456     switch (planar) {
457     case 5: // Planar RGB + Alpha
458         avs->n_planes = 4;
459         avs->planes   = avs_planes_rgba;
460         break;
461     case 4: // YUV + Alpha
462         avs->n_planes = 4;
463         avs->planes   = avs_planes_yuva;
464         break;
465     case 3: // Planar RGB
466         avs->n_planes = 3;
467         avs->planes   = avs_planes_rgb;
468         break;
469     case 2: // Y8
470         avs->n_planes = 1;
471         avs->planes   = avs_planes_grey;
472         break;
473     case 1: // YUV
474         avs->n_planes = 3;
475         avs->planes   = avs_planes_yuv;
476         break;
477     default:
478         avs->n_planes = 1;
479         avs->planes   = avs_planes_packed;
480     }
481     return 0;
482 }
483
484 static int avisynth_create_stream_audio(AVFormatContext *s, AVStream *st)
485 {
486     AviSynthContext *avs = s->priv_data;
487
488     st->codecpar->codec_type  = AVMEDIA_TYPE_AUDIO;
489     st->codecpar->sample_rate = avs->vi->audio_samples_per_second;
490     st->codecpar->channels    = avs->vi->nchannels;
491     st->duration              = avs->vi->num_audio_samples;
492     avpriv_set_pts_info(st, 64, 1, avs->vi->audio_samples_per_second);
493
494     switch (avs->vi->sample_type) {
495     case AVS_SAMPLE_INT8:
496         st->codecpar->codec_id = AV_CODEC_ID_PCM_U8;
497         break;
498     case AVS_SAMPLE_INT16:
499         st->codecpar->codec_id = AV_CODEC_ID_PCM_S16LE;
500         break;
501     case AVS_SAMPLE_INT24:
502         st->codecpar->codec_id = AV_CODEC_ID_PCM_S24LE;
503         break;
504     case AVS_SAMPLE_INT32:
505         st->codecpar->codec_id = AV_CODEC_ID_PCM_S32LE;
506         break;
507     case AVS_SAMPLE_FLOAT:
508         st->codecpar->codec_id = AV_CODEC_ID_PCM_F32LE;
509         break;
510     default:
511         av_log(s, AV_LOG_ERROR,
512                "unknown AviSynth sample type %d\n", avs->vi->sample_type);
513         avs->error = 1;
514         return AVERROR_UNKNOWN;
515     }
516     return 0;
517 }
518
519 static int avisynth_create_stream(AVFormatContext *s)
520 {
521     AviSynthContext *avs = s->priv_data;
522     AVStream *st;
523     int ret;
524     int id = 0;
525
526     if (avs_has_video(avs->vi)) {
527         st = avformat_new_stream(s, NULL);
528         if (!st)
529             return AVERROR_UNKNOWN;
530         st->id = id++;
531         if (ret = avisynth_create_stream_video(s, st))
532             return ret;
533     }
534     if (avs_has_audio(avs->vi)) {
535         st = avformat_new_stream(s, NULL);
536         if (!st)
537             return AVERROR_UNKNOWN;
538         st->id = id++;
539         if (ret = avisynth_create_stream_audio(s, st))
540             return ret;
541     }
542     return 0;
543 }
544
545 static int avisynth_open_file(AVFormatContext *s)
546 {
547     AviSynthContext *avs = s->priv_data;
548     AVS_Value arg, val;
549     int ret;
550 #ifdef _WIN32
551     char filename_ansi[MAX_PATH * 4];
552     wchar_t filename_wc[MAX_PATH * 4];
553 #endif
554
555     if (ret = avisynth_context_create(s))
556         return ret;
557
558 #ifdef _WIN32
559     /* Convert UTF-8 to ANSI code page */
560     MultiByteToWideChar(CP_UTF8, 0, s->url, -1, filename_wc, MAX_PATH * 4);
561     WideCharToMultiByte(CP_THREAD_ACP, 0, filename_wc, -1, filename_ansi,
562                         MAX_PATH * 4, NULL, NULL);
563     arg = avs_new_value_string(filename_ansi);
564 #else
565     arg = avs_new_value_string(s->url);
566 #endif
567     val = avs_library.avs_invoke(avs->env, "Import", arg, 0);
568     if (avs_is_error(val)) {
569         av_log(s, AV_LOG_ERROR, "%s\n", avs_as_error(val));
570         ret = AVERROR_UNKNOWN;
571         goto fail;
572     }
573     if (!avs_is_clip(val)) {
574         av_log(s, AV_LOG_ERROR, "AviSynth script did not return a clip\n");
575         ret = AVERROR_UNKNOWN;
576         goto fail;
577     }
578
579     avs->clip = avs_library.avs_take_clip(val, avs->env);
580     avs->vi   = avs_library.avs_get_video_info(avs->clip);
581
582     /* On Windows, FFmpeg supports AviSynth interface version 6 or higher.
583      * This includes AviSynth 2.6 RC1 or higher, and AviSynth+ r1718 or higher,
584      * and excludes 2.5 and the 2.6 alphas. */
585
586     if (avs_library.avs_get_version(avs->clip) < 6) {
587         av_log(s, AV_LOG_ERROR,
588                "AviSynth version is too old. Please upgrade to either AviSynth 2.6 >= RC1 or AviSynth+ >= r1718.\n");
589         ret = AVERROR_UNKNOWN;
590         goto fail;
591     }
592
593     /* Release the AVS_Value as it will go out of scope. */
594     avs_library.avs_release_value(val);
595
596     if (ret = avisynth_create_stream(s))
597         goto fail;
598
599     return 0;
600
601 fail:
602     avisynth_context_destroy(avs);
603     return ret;
604 }
605
606 static void avisynth_next_stream(AVFormatContext *s, AVStream **st,
607                                  AVPacket *pkt, int *discard)
608 {
609     AviSynthContext *avs = s->priv_data;
610
611     avs->curr_stream++;
612     avs->curr_stream %= s->nb_streams;
613
614     *st = s->streams[avs->curr_stream];
615     if ((*st)->discard == AVDISCARD_ALL)
616         *discard = 1;
617     else
618         *discard = 0;
619
620     return;
621 }
622
623 /* Copy AviSynth clip data into an AVPacket. */
624 static int avisynth_read_packet_video(AVFormatContext *s, AVPacket *pkt,
625                                       int discard)
626 {
627     AviSynthContext *avs = s->priv_data;
628     AVS_VideoFrame *frame;
629     unsigned char *dst_p;
630     const unsigned char *src_p;
631     int n, i, plane, rowsize, planeheight, pitch, bits, ret;
632     const char *error;
633
634     if (avs->curr_frame >= avs->vi->num_frames)
635         return AVERROR_EOF;
636
637     /* This must happen even if the stream is discarded to prevent desync. */
638     n = avs->curr_frame++;
639     if (discard)
640         return 0;
641
642     bits = avs_library.avs_bits_per_pixel(avs->vi);
643
644     /* Without the cast to int64_t, calculation overflows at about 9k x 9k
645      * resolution. */
646     pkt->size = (((int64_t)avs->vi->width *
647                   (int64_t)avs->vi->height) * bits) / 8;
648     if (!pkt->size)
649         return AVERROR_UNKNOWN;
650
651     if ((ret = av_new_packet(pkt, pkt->size)) < 0)
652         return ret;
653
654     pkt->pts      = n;
655     pkt->dts      = n;
656     pkt->duration = 1;
657     pkt->stream_index = avs->curr_stream;
658
659     frame = avs_library.avs_get_frame(avs->clip, n);
660     error = avs_library.avs_clip_get_error(avs->clip);
661     if (error) {
662         av_log(s, AV_LOG_ERROR, "%s\n", error);
663         avs->error = 1;
664         av_packet_unref(pkt);
665         return AVERROR_UNKNOWN;
666     }
667
668     dst_p = pkt->data;
669     for (i = 0; i < avs->n_planes; i++) {
670         plane = avs->planes[i];
671         src_p = avs_library.avs_get_read_ptr_p(frame, plane);
672         pitch = avs_library.avs_get_pitch_p(frame, plane);
673
674         rowsize     = avs_library.avs_get_row_size_p(frame, plane);
675         planeheight = avs_library.avs_get_height_p(frame, plane);
676
677         /* Flip RGB video. */
678         if (avs_library.avs_is_color_space(avs->vi, AVS_CS_BGR)   ||
679             avs_library.avs_is_color_space(avs->vi, AVS_CS_BGR48) ||
680             avs_library.avs_is_color_space(avs->vi, AVS_CS_BGR64)) {
681             src_p = src_p + (planeheight - 1) * pitch;
682             pitch = -pitch;
683         }
684
685         avs_library.avs_bit_blt(avs->env, dst_p, rowsize, src_p, pitch,
686                                  rowsize, planeheight);
687         dst_p += rowsize * planeheight;
688     }
689
690     avs_library.avs_release_video_frame(frame);
691     return 0;
692 }
693
694 static int avisynth_read_packet_audio(AVFormatContext *s, AVPacket *pkt,
695                                       int discard)
696 {
697     AviSynthContext *avs = s->priv_data;
698     AVRational fps, samplerate;
699     int samples, ret;
700     int64_t n;
701     const char *error;
702
703     if (avs->curr_sample >= avs->vi->num_audio_samples)
704         return AVERROR_EOF;
705
706     fps.num        = avs->vi->fps_numerator;
707     fps.den        = avs->vi->fps_denominator;
708     samplerate.num = avs->vi->audio_samples_per_second;
709     samplerate.den = 1;
710
711     if (avs_has_video(avs->vi)) {
712         if (avs->curr_frame < avs->vi->num_frames)
713             samples = av_rescale_q(avs->curr_frame, samplerate, fps) -
714                       avs->curr_sample;
715         else
716             samples = av_rescale_q(1, samplerate, fps);
717     } else {
718         samples = 1000;
719     }
720
721     /* After seeking, audio may catch up with video. */
722     if (samples <= 0) {
723         pkt->size = 0;
724         pkt->data = NULL;
725         return 0;
726     }
727
728     if (avs->curr_sample + samples > avs->vi->num_audio_samples)
729         samples = avs->vi->num_audio_samples - avs->curr_sample;
730
731     /* This must happen even if the stream is discarded to prevent desync. */
732     n                 = avs->curr_sample;
733     avs->curr_sample += samples;
734     if (discard)
735         return 0;
736
737     pkt->size = avs_bytes_per_channel_sample(avs->vi) *
738                 samples * avs->vi->nchannels;
739     if (!pkt->size)
740         return AVERROR_UNKNOWN;
741
742     if ((ret = av_new_packet(pkt, pkt->size)) < 0)
743         return ret;
744
745     pkt->pts      = n;
746     pkt->dts      = n;
747     pkt->duration = samples;
748     pkt->stream_index = avs->curr_stream;
749
750     avs_library.avs_get_audio(avs->clip, pkt->data, n, samples);
751     error = avs_library.avs_clip_get_error(avs->clip);
752     if (error) {
753         av_log(s, AV_LOG_ERROR, "%s\n", error);
754         avs->error = 1;
755         av_packet_unref(pkt);
756         return AVERROR_UNKNOWN;
757     }
758     return 0;
759 }
760
761 static av_cold int avisynth_read_header(AVFormatContext *s)
762 {
763     int ret;
764
765     // Calling library must implement a lock for thread-safe opens.
766     if (ret = ff_lock_avformat())
767         return ret;
768
769     if (ret = avisynth_open_file(s)) {
770         ff_unlock_avformat();
771         return ret;
772     }
773
774     ff_unlock_avformat();
775     return 0;
776 }
777
778 static int avisynth_read_packet(AVFormatContext *s, AVPacket *pkt)
779 {
780     AviSynthContext *avs = s->priv_data;
781     AVStream *st;
782     int discard = 0;
783     int ret;
784
785     if (avs->error)
786         return AVERROR_UNKNOWN;
787
788     /* If either stream reaches EOF, try to read the other one before
789      * giving up. */
790     avisynth_next_stream(s, &st, pkt, &discard);
791     if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
792         ret = avisynth_read_packet_video(s, pkt, discard);
793         if (ret == AVERROR_EOF && avs_has_audio(avs->vi)) {
794             avisynth_next_stream(s, &st, pkt, &discard);
795             return avisynth_read_packet_audio(s, pkt, discard);
796         }
797     } else {
798         ret = avisynth_read_packet_audio(s, pkt, discard);
799         if (ret == AVERROR_EOF && avs_has_video(avs->vi)) {
800             avisynth_next_stream(s, &st, pkt, &discard);
801             return avisynth_read_packet_video(s, pkt, discard);
802         }
803     }
804
805     return ret;
806 }
807
808 static av_cold int avisynth_read_close(AVFormatContext *s)
809 {
810     if (ff_lock_avformat())
811         return AVERROR_UNKNOWN;
812
813     avisynth_context_destroy(s->priv_data);
814     ff_unlock_avformat();
815     return 0;
816 }
817
818 static int avisynth_read_seek(AVFormatContext *s, int stream_index,
819                               int64_t timestamp, int flags)
820 {
821     AviSynthContext *avs = s->priv_data;
822     AVStream *st;
823     AVRational fps, samplerate;
824
825     if (avs->error)
826         return AVERROR_UNKNOWN;
827
828     fps        = (AVRational) { avs->vi->fps_numerator,
829                                 avs->vi->fps_denominator };
830     samplerate = (AVRational) { avs->vi->audio_samples_per_second, 1 };
831
832     st = s->streams[stream_index];
833     if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
834         /* AviSynth frame counts are signed int. */
835         if ((timestamp >= avs->vi->num_frames) ||
836             (timestamp > INT_MAX)              ||
837             (timestamp < 0))
838             return AVERROR_EOF;
839         avs->curr_frame = timestamp;
840         if (avs_has_audio(avs->vi))
841             avs->curr_sample = av_rescale_q(timestamp, samplerate, fps);
842     } else {
843         if ((timestamp >= avs->vi->num_audio_samples) || (timestamp < 0))
844             return AVERROR_EOF;
845         /* Force frame granularity for seeking. */
846         if (avs_has_video(avs->vi)) {
847             avs->curr_frame  = av_rescale_q(timestamp, fps, samplerate);
848             avs->curr_sample = av_rescale_q(avs->curr_frame, samplerate, fps);
849         } else {
850             avs->curr_sample = timestamp;
851         }
852     }
853
854     return 0;
855 }
856
857 AVInputFormat ff_avisynth_demuxer = {
858     .name           = "avisynth",
859     .long_name      = NULL_IF_CONFIG_SMALL("AviSynth script"),
860     .priv_data_size = sizeof(AviSynthContext),
861     .read_header    = avisynth_read_header,
862     .read_packet    = avisynth_read_packet,
863     .read_close     = avisynth_read_close,
864     .read_seek      = avisynth_read_seek,
865     .extensions     = "avs",
866 };