GCC Code Coverage Report
Directory: ../../../ffmpeg/ Exec Total Coverage
File: src/libavcodec/audio_frame_queue.c Lines: 57 62 91.9 %
Date: 2019-11-18 18:00:01 Branches: 25 42 59.5 %

Line Branch Exec Source
1
/*
2
 * Audio Frame Queue
3
 * Copyright (c) 2012 Justin Ruggles
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/common.h"
24
#include "audio_frame_queue.h"
25
#include "internal.h"
26
#include "libavutil/avassert.h"
27
28
14
av_cold void ff_af_queue_init(AVCodecContext *avctx, AudioFrameQueue *afq)
29
{
30
14
    afq->avctx = avctx;
31
14
    afq->remaining_delay   = avctx->initial_padding;
32
14
    afq->remaining_samples = avctx->initial_padding;
33
14
    afq->frame_count       = 0;
34
14
}
35
36
14
void ff_af_queue_close(AudioFrameQueue *afq)
37
{
38
14
    if(afq->frame_count)
39
        av_log(afq->avctx, AV_LOG_WARNING, "%d frames left in the queue on closing\n", afq->frame_count);
40
14
    av_freep(&afq->frames);
41
14
    memset(afq, 0, sizeof(*afq));
42
14
}
43
44
11016
int ff_af_queue_add(AudioFrameQueue *afq, const AVFrame *f)
45
{
46
11016
    AudioFrame *new = av_fast_realloc(afq->frames, &afq->frame_alloc, sizeof(*afq->frames)*(afq->frame_count+1));
47
11016
    if(!new)
48
        return AVERROR(ENOMEM);
49
11016
    afq->frames = new;
50
11016
    new += afq->frame_count;
51
52
    /* get frame parameters */
53
11016
    new->duration = f->nb_samples;
54
11016
    new->duration += afq->remaining_delay;
55
11016
    if (f->pts != AV_NOPTS_VALUE) {
56
11016
        new->pts = av_rescale_q(f->pts,
57
11016
                                      afq->avctx->time_base,
58
11016
                                      (AVRational){ 1, afq->avctx->sample_rate });
59
11016
        new->pts -= afq->remaining_delay;
60

11016
        if(afq->frame_count && new[-1].pts >= new->pts)
61
            av_log(afq->avctx, AV_LOG_WARNING, "Queue input is backward in time\n");
62
    } else {
63
        new->pts = AV_NOPTS_VALUE;
64
    }
65
11016
    afq->remaining_delay = 0;
66
67
    /* add frame sample count */
68
11016
    afq->remaining_samples += f->nb_samples;
69
70
11016
    afq->frame_count++;
71
72
11016
    return 0;
73
}
74
75
4892
void ff_af_queue_remove(AudioFrameQueue *afq, int nb_samples, int64_t *pts,
76
                        int64_t *duration)
77
{
78
4892
    int64_t out_pts = AV_NOPTS_VALUE;
79
4892
    int removed_samples = 0;
80
    int i;
81
82

4892
    if (afq->frame_count || afq->frame_alloc) {
83
4892
        if (afq->frames->pts != AV_NOPTS_VALUE)
84
4892
            out_pts = afq->frames->pts;
85
    }
86
4892
    if(!afq->frame_count)
87
        av_log(afq->avctx, AV_LOG_WARNING, "Trying to remove %d samples, but the queue is empty\n", nb_samples);
88
4892
    if (pts)
89
4892
        *pts = ff_samples_to_time_base(afq->avctx, out_pts);
90
91

16295
    for(i=0; nb_samples && i<afq->frame_count; i++){
92
11403
        int n= FFMIN(afq->frames[i].duration, nb_samples);
93
11403
        afq->frames[i].duration -= n;
94
11403
        nb_samples              -= n;
95
11403
        removed_samples         += n;
96
11403
        if(afq->frames[i].pts != AV_NOPTS_VALUE)
97
11403
            afq->frames[i].pts      += n;
98
    }
99
4892
    afq->remaining_samples -= removed_samples;
100

4892
    i -= i && afq->frames[i-1].duration;
101
4892
    memmove(afq->frames, afq->frames + i, sizeof(*afq->frames) * (afq->frame_count - i));
102
4892
    afq->frame_count -= i;
103
104
4892
    if(nb_samples){
105
13
        av_assert0(!afq->frame_count);
106
13
        av_assert0(afq->remaining_samples == afq->remaining_delay);
107

13
        if(afq->frames && afq->frames[0].pts != AV_NOPTS_VALUE)
108
13
            afq->frames[0].pts += nb_samples;
109
13
        av_log(afq->avctx, AV_LOG_DEBUG, "Trying to remove %d more samples than there are in the queue\n", nb_samples);
110
    }
111
4892
    if (duration)
112
4892
        *duration = ff_samples_to_time_base(afq->avctx, removed_samples);
113
4892
}