X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=libavcodec%2Fvorbisenc.c;h=35bdd57fb1a9cac463aa2c5136c38baac9c3ccf8;hb=cab63a8b594cdc365bb2581a12b3ac8e6dd480b2;hp=67d094b37d37f914f621d1d310bad9ecf6f303d5;hpb=0a6b1a9f21d5970a0439e32303535ed85f07673e;p=ffmpeg diff --git a/libavcodec/vorbisenc.c b/libavcodec/vorbisenc.c index 67d094b37d3..35bdd57fb1a 100644 --- a/libavcodec/vorbisenc.c +++ b/libavcodec/vorbisenc.c @@ -25,9 +25,11 @@ */ #include + #include "avcodec.h" -#include "dsputil.h" +#include "internal.h" #include "fft.h" +#include "mathops.h" #include "vorbis.h" #include "vorbis_enc_data.h" @@ -37,28 +39,28 @@ #undef NDEBUG #include -typedef struct { +typedef struct vorbis_enc_codebook { int nentries; uint8_t *lens; uint32_t *codewords; - int ndimentions; + int ndimensions; float min; float delta; int seq_p; int lookup; int *quantlist; - float *dimentions; + float *dimensions; float *pow2; } vorbis_enc_codebook; -typedef struct { +typedef struct vorbis_enc_floor_class { int dim; int subclass; int masterbook; int *books; } vorbis_enc_floor_class; -typedef struct { +typedef struct vorbis_enc_floor { int partitions; int *partition_to_class; int nclasses; @@ -69,7 +71,7 @@ typedef struct { vorbis_floor1_entry *list; } vorbis_enc_floor; -typedef struct { +typedef struct vorbis_enc_residue { int type; int begin; int end; @@ -80,7 +82,7 @@ typedef struct { float (*maxes)[2]; } vorbis_enc_residue; -typedef struct { +typedef struct vorbis_enc_mapping { int submaps; int *mux; int *floor; @@ -90,12 +92,12 @@ typedef struct { int *angle; } vorbis_enc_mapping; -typedef struct { +typedef struct vorbis_enc_mode { int blockflag; int mapping; } vorbis_enc_mode; -typedef struct { +typedef struct vorbis_enc_context { int channels; int sample_rate; int log2_blocksize[2]; @@ -123,7 +125,7 @@ typedef struct { int nmodes; vorbis_enc_mode *modes; - int64_t sample_count; + int64_t next_pts; } vorbis_enc_context; #define MAX_CHANNELS 2 @@ -137,63 +139,71 @@ typedef struct { #define RESIDUE_PART_SIZE 32 #define NUM_RESIDUE_PARTITIONS (RESIDUE_SIZE/RESIDUE_PART_SIZE) -static inline void put_codeword(PutBitContext *pb, vorbis_enc_codebook *cb, - int entry) +static inline int put_codeword(PutBitContext *pb, vorbis_enc_codebook *cb, + int entry) { assert(entry >= 0); assert(entry < cb->nentries); assert(cb->lens[entry]); + if (pb->size_in_bits - put_bits_count(pb) < cb->lens[entry]) + return AVERROR(EINVAL); put_bits(pb, cb->lens[entry], cb->codewords[entry]); + return 0; } -static int cb_lookup_vals(int lookup, int dimentions, int entries) +static int cb_lookup_vals(int lookup, int dimensions, int entries) { if (lookup == 1) - return ff_vorbis_nth_root(entries, dimentions); + return ff_vorbis_nth_root(entries, dimensions); else if (lookup == 2) - return dimentions *entries; + return dimensions *entries; return 0; } -static void ready_codebook(vorbis_enc_codebook *cb) +static int ready_codebook(vorbis_enc_codebook *cb) { int i; ff_vorbis_len2vlc(cb->lens, cb->codewords, cb->nentries); if (!cb->lookup) { - cb->pow2 = cb->dimentions = NULL; + cb->pow2 = cb->dimensions = NULL; } else { - int vals = cb_lookup_vals(cb->lookup, cb->ndimentions, cb->nentries); - cb->dimentions = av_malloc(sizeof(float) * cb->nentries * cb->ndimentions); + int vals = cb_lookup_vals(cb->lookup, cb->ndimensions, cb->nentries); + cb->dimensions = av_malloc(sizeof(float) * cb->nentries * cb->ndimensions); cb->pow2 = av_mallocz(sizeof(float) * cb->nentries); + if (!cb->dimensions || !cb->pow2) + return AVERROR(ENOMEM); for (i = 0; i < cb->nentries; i++) { float last = 0; int j; int div = 1; - for (j = 0; j < cb->ndimentions; j++) { + for (j = 0; j < cb->ndimensions; j++) { int off; if (cb->lookup == 1) off = (i / div) % vals; // lookup type 1 else - off = i * cb->ndimentions + j; // lookup type 2 + off = i * cb->ndimensions + j; // lookup type 2 - cb->dimentions[i * cb->ndimentions + j] = last + cb->min + cb->quantlist[off] * cb->delta; + cb->dimensions[i * cb->ndimensions + j] = last + cb->min + cb->quantlist[off] * cb->delta; if (cb->seq_p) - last = cb->dimentions[i * cb->ndimentions + j]; - cb->pow2[i] += cb->dimentions[i * cb->ndimentions + j] * cb->dimentions[i * cb->ndimentions + j]; + last = cb->dimensions[i * cb->ndimensions + j]; + cb->pow2[i] += cb->dimensions[i * cb->ndimensions + j] * cb->dimensions[i * cb->ndimensions + j]; div *= vals; } - cb->pow2[i] /= 2.; + cb->pow2[i] /= 2.0; } } + return 0; } -static void ready_residue(vorbis_enc_residue *rc, vorbis_enc_context *venc) +static int ready_residue(vorbis_enc_residue *rc, vorbis_enc_context *venc) { int i; assert(rc->type == 2); rc->maxes = av_mallocz(sizeof(float[2]) * rc->classifications); + if (!rc->maxes) + return AVERROR(ENOMEM); for (i = 0; i < rc->classifications; i++) { int j; vorbis_enc_codebook * cb; @@ -203,17 +213,17 @@ static void ready_residue(vorbis_enc_residue *rc, vorbis_enc_context *venc) if (j == 8) // zero continue; cb = &venc->codebooks[rc->books[i][j]]; - assert(cb->ndimentions >= 2); + assert(cb->ndimensions >= 2); assert(cb->lookup); for (j = 0; j < cb->nentries; j++) { float a; if (!cb->lens[j]) continue; - a = fabs(cb->dimentions[j * cb->ndimentions]); + a = fabs(cb->dimensions[j * cb->ndimensions]); if (a > rc->maxes[i][0]) rc->maxes[i][0] = a; - a = fabs(cb->dimentions[j * cb->ndimentions + 1]); + a = fabs(cb->dimensions[j * cb->ndimensions + 1]); if (a > rc->maxes[i][1]) rc->maxes[i][1] = a; } @@ -223,22 +233,25 @@ static void ready_residue(vorbis_enc_residue *rc, vorbis_enc_context *venc) rc->maxes[i][0] += 0.8; rc->maxes[i][1] += 0.8; } + return 0; } -static void create_vorbis_context(vorbis_enc_context *venc, - AVCodecContext *avccontext) +static int create_vorbis_context(vorbis_enc_context *venc, + AVCodecContext *avctx) { vorbis_enc_floor *fc; vorbis_enc_residue *rc; vorbis_enc_mapping *mc; - int i, book; + int i, book, ret; - venc->channels = avccontext->channels; - venc->sample_rate = avccontext->sample_rate; + venc->channels = avctx->channels; + venc->sample_rate = avctx->sample_rate; venc->log2_blocksize[0] = venc->log2_blocksize[1] = 11; venc->ncodebooks = FF_ARRAY_ELEMS(cvectors); venc->codebooks = av_malloc(sizeof(vorbis_enc_codebook) * venc->ncodebooks); + if (!venc->codebooks) + return AVERROR(ENOMEM); // codebook 0..14 - floor1 book, values 0..255 // codebook 15 residue masterbook @@ -246,7 +259,7 @@ static void create_vorbis_context(vorbis_enc_context *venc, for (book = 0; book < venc->ncodebooks; book++) { vorbis_enc_codebook *cb = &venc->codebooks[book]; int vals; - cb->ndimentions = cvectors[book].dim; + cb->ndimensions = cvectors[book].dim; cb->nentries = cvectors[book].real_len; cb->min = cvectors[book].min; cb->delta = cvectors[book].delta; @@ -255,27 +268,36 @@ static void create_vorbis_context(vorbis_enc_context *venc, cb->lens = av_malloc(sizeof(uint8_t) * cb->nentries); cb->codewords = av_malloc(sizeof(uint32_t) * cb->nentries); + if (!cb->lens || !cb->codewords) + return AVERROR(ENOMEM); memcpy(cb->lens, cvectors[book].clens, cvectors[book].len); memset(cb->lens + cvectors[book].len, 0, cb->nentries - cvectors[book].len); if (cb->lookup) { - vals = cb_lookup_vals(cb->lookup, cb->ndimentions, cb->nentries); + vals = cb_lookup_vals(cb->lookup, cb->ndimensions, cb->nentries); cb->quantlist = av_malloc(sizeof(int) * vals); + if (!cb->quantlist) + return AVERROR(ENOMEM); for (i = 0; i < vals; i++) cb->quantlist[i] = cvectors[book].quant[i]; } else { cb->quantlist = NULL; } - ready_codebook(cb); + if ((ret = ready_codebook(cb)) < 0) + return ret; } venc->nfloors = 1; venc->floors = av_malloc(sizeof(vorbis_enc_floor) * venc->nfloors); + if (!venc->floors) + return AVERROR(ENOMEM); // just 1 floor fc = &venc->floors[0]; fc->partitions = NUM_FLOOR_PARTITIONS; fc->partition_to_class = av_malloc(sizeof(int) * fc->partitions); + if (!fc->partition_to_class) + return AVERROR(ENOMEM); fc->nclasses = 0; for (i = 0; i < fc->partitions; i++) { static const int a[] = {0, 1, 2, 2, 3, 3, 4, 4}; @@ -284,6 +306,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, } fc->nclasses++; fc->classes = av_malloc(sizeof(vorbis_enc_floor_class) * fc->nclasses); + if (!fc->classes) + return AVERROR(ENOMEM); for (i = 0; i < fc->nclasses; i++) { vorbis_enc_floor_class * c = &fc->classes[i]; int j, books; @@ -292,6 +316,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, c->masterbook = floor_classes[i].masterbook; books = (1 << c->subclass); c->books = av_malloc(sizeof(int) * books); + if (!c->books) + return AVERROR(ENOMEM); for (j = 0; j < books; j++) c->books[j] = floor_classes[i].nbooks[j]; } @@ -303,6 +329,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, fc->values += fc->classes[fc->partition_to_class[i]].dim; fc->list = av_malloc(sizeof(vorbis_floor1_entry) * fc->values); + if (!fc->list) + return AVERROR(ENOMEM); fc->list[0].x = 0; fc->list[1].x = 1 << fc->rangebits; for (i = 2; i < fc->values; i++) { @@ -313,10 +341,13 @@ static void create_vorbis_context(vorbis_enc_context *venc, }; fc->list[i].x = a[i - 2]; } - ff_vorbis_ready_floor1_list(fc->list, fc->values); + if (ff_vorbis_ready_floor1_list(avctx, fc->list, fc->values)) + return AVERROR_BUG; venc->nresidues = 1; venc->residues = av_malloc(sizeof(vorbis_enc_residue) * venc->nresidues); + if (!venc->residues) + return AVERROR(ENOMEM); // single residue rc = &venc->residues[0]; @@ -327,6 +358,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, rc->classifications = 10; rc->classbook = 15; rc->books = av_malloc(sizeof(*rc->books) * rc->classifications); + if (!rc->books) + return AVERROR(ENOMEM); { static const int8_t a[10][8] = { { -1, -1, -1, -1, -1, -1, -1, -1, }, @@ -342,19 +375,26 @@ static void create_vorbis_context(vorbis_enc_context *venc, }; memcpy(rc->books, a, sizeof a); } - ready_residue(rc, venc); + if ((ret = ready_residue(rc, venc)) < 0) + return ret; venc->nmappings = 1; venc->mappings = av_malloc(sizeof(vorbis_enc_mapping) * venc->nmappings); + if (!venc->mappings) + return AVERROR(ENOMEM); // single mapping mc = &venc->mappings[0]; mc->submaps = 1; mc->mux = av_malloc(sizeof(int) * venc->channels); + if (!mc->mux) + return AVERROR(ENOMEM); for (i = 0; i < venc->channels; i++) mc->mux[i] = 0; mc->floor = av_malloc(sizeof(int) * mc->submaps); mc->residue = av_malloc(sizeof(int) * mc->submaps); + if (!mc->floor || !mc->residue) + return AVERROR(ENOMEM); for (i = 0; i < mc->submaps; i++) { mc->floor[i] = 0; mc->residue[i] = 0; @@ -362,6 +402,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, mc->coupling_steps = venc->channels == 2 ? 1 : 0; mc->magnitude = av_malloc(sizeof(int) * mc->coupling_steps); mc->angle = av_malloc(sizeof(int) * mc->coupling_steps); + if (!mc->magnitude || !mc->angle) + return AVERROR(ENOMEM); if (mc->coupling_steps) { mc->magnitude[0] = 0; mc->angle[0] = 1; @@ -369,6 +411,8 @@ static void create_vorbis_context(vorbis_enc_context *venc, venc->nmodes = 1; venc->modes = av_malloc(sizeof(vorbis_enc_mode) * venc->nmodes); + if (!venc->modes) + return AVERROR(ENOMEM); // single mode venc->modes[0].blockflag = 0; @@ -379,12 +423,18 @@ static void create_vorbis_context(vorbis_enc_context *venc, venc->samples = av_malloc(sizeof(float) * venc->channels * (1 << venc->log2_blocksize[1])); venc->floor = av_malloc(sizeof(float) * venc->channels * (1 << venc->log2_blocksize[1]) / 2); venc->coeffs = av_malloc(sizeof(float) * venc->channels * (1 << venc->log2_blocksize[1]) / 2); + if (!venc->saved || !venc->samples || !venc->floor || !venc->coeffs) + return AVERROR(ENOMEM); venc->win[0] = ff_vorbis_vwin[venc->log2_blocksize[0] - 6]; venc->win[1] = ff_vorbis_vwin[venc->log2_blocksize[1] - 6]; - ff_mdct_init(&venc->mdct[0], venc->log2_blocksize[0], 0, 1.0); - ff_mdct_init(&venc->mdct[1], venc->log2_blocksize[1], 0, 1.0); + if ((ret = ff_mdct_init(&venc->mdct[0], venc->log2_blocksize[0], 0, 1.0)) < 0) + return ret; + if ((ret = ff_mdct_init(&venc->mdct[1], venc->log2_blocksize[1], 0, 1.0)) < 0) + return ret; + + return 0; } static void put_float(PutBitContext *pb, float f) @@ -407,7 +457,7 @@ static void put_codebook_header(PutBitContext *pb, vorbis_enc_codebook *cb) int ordered = 0; put_bits(pb, 24, 0x564342); //magic - put_bits(pb, 16, cb->ndimentions); + put_bits(pb, 16, cb->ndimensions); put_bits(pb, 24, cb->nentries); for (i = 1; i < cb->nentries; i++) @@ -449,7 +499,7 @@ static void put_codebook_header(PutBitContext *pb, vorbis_enc_codebook *cb) put_bits(pb, 4, cb->lookup); if (cb->lookup) { - int tmp = cb_lookup_vals(cb->lookup, cb->ndimentions, cb->nentries); + int tmp = cb_lookup_vals(cb->lookup, cb->ndimensions, cb->nentries); int bits = ilog(cb->quantlist[0]); for (i = 1; i < tmp; i++) @@ -647,6 +697,8 @@ static int put_main_header(vorbis_enc_context *venc, uint8_t **out) len = hlens[0] + hlens[1] + hlens[2]; p = *out = av_mallocz(64 + len + len/255); + if (!p) + return AVERROR(ENOMEM); *p++ = 2; p += av_xiphlacing(p, hlens[0]); @@ -678,7 +730,7 @@ static void floor_fit(vorbis_enc_context *venc, vorbis_enc_floor *fc, { int range = 255 / fc->multiplier + 1; int i; - float tot_average = 0.; + float tot_average = 0.0; float averages[MAX_FLOOR_VALUES]; for (i = 0; i < fc->values; i++) { averages[i] = get_floor_average(fc, coeffs, i); @@ -705,14 +757,16 @@ static int render_point(int x0, int y0, int x1, int y1, int x) return y0 + (x - x0) * (y1 - y0) / (x1 - x0); } -static void floor_encode(vorbis_enc_context *venc, vorbis_enc_floor *fc, - PutBitContext *pb, uint16_t *posts, - float *floor, int samples) +static int floor_encode(vorbis_enc_context *venc, vorbis_enc_floor *fc, + PutBitContext *pb, uint16_t *posts, + float *floor, int samples) { int range = 255 / fc->multiplier + 1; int coded[MAX_FLOOR_VALUES]; // first 2 values are unused int i, counter; + if (pb->size_in_bits - put_bits_count(pb) < 1 + 2 * ilog(range - 1)) + return AVERROR(EINVAL); put_bits(pb, 1, 1); // non zero put_bits(pb, ilog(range - 1), posts[0]); put_bits(pb, ilog(range - 1), posts[1]); @@ -770,7 +824,8 @@ static void floor_encode(vorbis_enc_context *venc, vorbis_enc_floor *fc, cval |= l << cshift; cshift += c->subclass; } - put_codeword(pb, book, cval); + if (put_codeword(pb, book, cval)) + return AVERROR(EINVAL); } for (k = 0; k < c->dim; k++) { int book = c->books[cval & (csub-1)]; @@ -780,12 +835,15 @@ static void floor_encode(vorbis_enc_context *venc, vorbis_enc_floor *fc, continue; if (entry == -1) entry = 0; - put_codeword(pb, &venc->codebooks[book], entry); + if (put_codeword(pb, &venc->codebooks[book], entry)) + return AVERROR(EINVAL); } } ff_vorbis_floor1_render_list(fc->list, fc->values, posts, coded, fc->multiplier, floor, samples); + + return 0; } static float *put_vector(vorbis_enc_codebook *book, PutBitContext *pb, @@ -793,38 +851,39 @@ static float *put_vector(vorbis_enc_codebook *book, PutBitContext *pb, { int i, entry = -1; float distance = FLT_MAX; - assert(book->dimentions); + assert(book->dimensions); for (i = 0; i < book->nentries; i++) { - float * vec = book->dimentions + i * book->ndimentions, d = book->pow2[i]; + float * vec = book->dimensions + i * book->ndimensions, d = book->pow2[i]; int j; if (!book->lens[i]) continue; - for (j = 0; j < book->ndimentions; j++) + for (j = 0; j < book->ndimensions; j++) d -= vec[j] * num[j]; if (distance > d) { entry = i; distance = d; } } - put_codeword(pb, book, entry); - return &book->dimentions[entry * book->ndimentions]; + if (put_codeword(pb, book, entry)) + return NULL; + return &book->dimensions[entry * book->ndimensions]; } -static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, - PutBitContext *pb, float *coeffs, int samples, - int real_ch) +static int residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, + PutBitContext *pb, float *coeffs, int samples, + int real_ch) { int pass, i, j, p, k; int psize = rc->partition_size; int partitions = (rc->end - rc->begin) / psize; int channels = (rc->type == 2) ? 1 : real_ch; int classes[MAX_CHANNELS][NUM_RESIDUE_PARTITIONS]; - int classwords = venc->codebooks[rc->classbook].ndimentions; + int classwords = venc->codebooks[rc->classbook].ndimensions; assert(rc->type == 2); assert(real_ch == 2); for (p = 0; p < partitions; p++) { - float max1 = 0., max2 = 0.; + float max1 = 0.0, max2 = 0.0; int s = rc->begin + p * psize; for (k = s; k < s + psize; k += 2) { max1 = FFMAX(max1, fabs(coeffs[ k / real_ch])); @@ -848,7 +907,8 @@ static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, entry *= rc->classifications; entry += classes[j][p + i]; } - put_codeword(pb, book, entry); + if (put_codeword(pb, book, entry)) + return AVERROR(EINVAL); } for (i = 0; i < classwords && p < partitions; i++, p++) { for (j = 0; j < channels; j++) { @@ -859,13 +919,15 @@ static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, continue; assert(rc->type == 0 || rc->type == 2); - assert(!(psize % book->ndimentions)); + assert(!(psize % book->ndimensions)); if (rc->type == 0) { - for (k = 0; k < psize; k += book->ndimentions) { - float *a = put_vector(book, pb, &buf[k]); + for (k = 0; k < psize; k += book->ndimensions) { int l; - for (l = 0; l < book->ndimentions; l++) + float *a = put_vector(book, pb, &buf[k]); + if (!a) + return AVERROR(EINVAL); + for (l = 0; l < book->ndimensions; l++) buf[k + l] -= a[l]; } } else { @@ -873,10 +935,10 @@ static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, a1 = (s % real_ch) * samples; b1 = s / real_ch; s = real_ch * samples; - for (k = 0; k < psize; k += book->ndimentions) { + for (k = 0; k < psize; k += book->ndimensions) { int dim, a2 = a1, b2 = b1; float vec[MAX_CODEBOOK_DIM], *pv = vec; - for (dim = book->ndimentions; dim--; ) { + for (dim = book->ndimensions; dim--; ) { *pv++ = coeffs[a2 + b2]; if ((a2 += samples) == s) { a2 = 0; @@ -884,7 +946,9 @@ static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, } } pv = put_vector(book, pb, vec); - for (dim = book->ndimentions; dim--; ) { + if (!pv) + return AVERROR(EINVAL); + for (dim = book->ndimensions; dim--; ) { coeffs[a1 + b1] -= *pv++; if ((a1 += samples) == s) { a1 = 0; @@ -897,15 +961,16 @@ static void residue_encode(vorbis_enc_context *venc, vorbis_enc_residue *rc, } } } + return 0; } -static int apply_window_and_mdct(vorbis_enc_context *venc, const signed short *audio, - int samples) +static int apply_window_and_mdct(vorbis_enc_context *venc, + float **audio, int samples) { - int i, j, channel; + int i, channel; const float * win = venc->win[0]; int window_len = 1 << (venc->log2_blocksize[0] - 1); - float n = (float)(1 << venc->log2_blocksize[0]) / 4.; + float n = (float)(1 << venc->log2_blocksize[0]) / 4.0; // FIXME use dsp if (!venc->have_saved && !samples) @@ -924,9 +989,8 @@ static int apply_window_and_mdct(vorbis_enc_context *venc, const signed short *a if (samples) { for (channel = 0; channel < venc->channels; channel++) { float * offset = venc->samples + channel*window_len*2 + window_len; - j = channel; - for (i = 0; i < samples; i++, j += venc->channels) - offset[i] = audio[j] / 32768. / n * win[window_len - i - 1]; + for (i = 0; i < samples; i++) + offset[i] = audio[channel][i] / n * win[window_len - i - 1]; } } else { for (channel = 0; channel < venc->channels; channel++) @@ -941,9 +1005,8 @@ static int apply_window_and_mdct(vorbis_enc_context *venc, const signed short *a if (samples) { for (channel = 0; channel < venc->channels; channel++) { float *offset = venc->saved + channel * window_len; - j = channel; - for (i = 0; i < samples; i++, j += venc->channels) - offset[i] = audio[j] / 32768. / n * win[i]; + for (i = 0; i < samples; i++) + offset[i] = audio[channel][i] / n * win[i]; } venc->have_saved = 1; } else { @@ -952,50 +1015,33 @@ static int apply_window_and_mdct(vorbis_enc_context *venc, const signed short *a return 1; } -static av_cold int vorbis_encode_init(AVCodecContext *avccontext) -{ - vorbis_enc_context *venc = avccontext->priv_data; - - if (avccontext->channels != 2) { - av_log(avccontext, AV_LOG_ERROR, "Current Libav Vorbis encoder only supports 2 channels.\n"); - return -1; - } - - create_vorbis_context(venc, avccontext); - - if (avccontext->flags & CODEC_FLAG_QSCALE) - venc->quality = avccontext->global_quality / (float)FF_QP2LAMBDA / 10.; - else - venc->quality = 0.03; - venc->quality *= venc->quality; - - avccontext->extradata_size = put_main_header(venc, (uint8_t**)&avccontext->extradata); - avccontext->frame_size = 1 << (venc->log2_blocksize[0] - 1); - - avccontext->coded_frame = avcodec_alloc_frame(); - avccontext->coded_frame->key_frame = 1; - - return 0; -} - -static int vorbis_encode_frame(AVCodecContext *avccontext, - unsigned char *packets, - int buf_size, void *data) +static int vorbis_encode_frame(AVCodecContext *avctx, AVPacket *avpkt, + const AVFrame *frame, int *got_packet_ptr) { - vorbis_enc_context *venc = avccontext->priv_data; - const signed short *audio = data; - int samples = data ? avccontext->frame_size : 0; + vorbis_enc_context *venc = avctx->priv_data; + float **audio = frame ? (float **)frame->extended_data : NULL; + int samples = frame ? frame->nb_samples : 0; vorbis_enc_mode *mode; vorbis_enc_mapping *mapping; PutBitContext pb; - int i; + int i, ret; if (!apply_window_and_mdct(venc, audio, samples)) return 0; samples = 1 << (venc->log2_blocksize[0] - 1); - init_put_bits(&pb, packets, buf_size); + if ((ret = ff_alloc_packet(avpkt, 8192))) { + av_log(avctx, AV_LOG_ERROR, "Error getting output packet\n"); + return ret; + } + + init_put_bits(&pb, avpkt->data, avpkt->size); + + if (pb.size_in_bits - put_bits_count(&pb) < 1 + ilog(venc->nmodes - 1)) { + av_log(avctx, AV_LOG_ERROR, "output buffer is too small\n"); + return AVERROR(EINVAL); + } put_bits(&pb, 1, 0); // magic bit @@ -1012,7 +1058,10 @@ static int vorbis_encode_frame(AVCodecContext *avccontext, vorbis_enc_floor *fc = &venc->floors[mapping->floor[mapping->mux[i]]]; uint16_t posts[MAX_FLOOR_VALUES]; floor_fit(venc, fc, &venc->coeffs[i * samples], posts, samples); - floor_encode(venc, fc, &pb, posts, &venc->floor[i * samples], samples); + if (floor_encode(venc, fc, &pb, posts, &venc->floor[i * samples], samples)) { + av_log(avctx, AV_LOG_ERROR, "output buffer is too small\n"); + return AVERROR(EINVAL); + } } for (i = 0; i < venc->channels * samples; i++) @@ -1032,19 +1081,33 @@ static int vorbis_encode_frame(AVCodecContext *avccontext, } } - residue_encode(venc, &venc->residues[mapping->residue[mapping->mux[0]]], - &pb, venc->coeffs, samples, venc->channels); + if (residue_encode(venc, &venc->residues[mapping->residue[mapping->mux[0]]], + &pb, venc->coeffs, samples, venc->channels)) { + av_log(avctx, AV_LOG_ERROR, "output buffer is too small\n"); + return AVERROR(EINVAL); + } - avccontext->coded_frame->pts = venc->sample_count; - venc->sample_count += avccontext->frame_size; flush_put_bits(&pb); - return put_bits_count(&pb) >> 3; + avpkt->size = put_bits_count(&pb) >> 3; + + avpkt->duration = ff_samples_to_time_base(avctx, avctx->frame_size); + if (frame) { + if (frame->pts != AV_NOPTS_VALUE) + avpkt->pts = ff_samples_to_time_base(avctx, frame->pts); + } else { + avpkt->pts = venc->next_pts; + } + if (avpkt->pts != AV_NOPTS_VALUE) + venc->next_pts = avpkt->pts + avpkt->duration; + + *got_packet_ptr = 1; + return 0; } -static av_cold int vorbis_encode_close(AVCodecContext *avccontext) +static av_cold int vorbis_encode_close(AVCodecContext *avctx) { - vorbis_enc_context *venc = avccontext->priv_data; + vorbis_enc_context *venc = avctx->priv_data; int i; if (venc->codebooks) @@ -1052,7 +1115,7 @@ static av_cold int vorbis_encode_close(AVCodecContext *avccontext) av_freep(&venc->codebooks[i].lens); av_freep(&venc->codebooks[i].codewords); av_freep(&venc->codebooks[i].quantlist); - av_freep(&venc->codebooks[i].dimentions); + av_freep(&venc->codebooks[i].dimensions); av_freep(&venc->codebooks[i].pow2); } av_freep(&venc->codebooks); @@ -1096,21 +1159,53 @@ static av_cold int vorbis_encode_close(AVCodecContext *avccontext) ff_mdct_end(&venc->mdct[0]); ff_mdct_end(&venc->mdct[1]); - av_freep(&avccontext->coded_frame); - av_freep(&avccontext->extradata); + av_freep(&avctx->extradata); return 0 ; } +static av_cold int vorbis_encode_init(AVCodecContext *avctx) +{ + vorbis_enc_context *venc = avctx->priv_data; + int ret; + + if (avctx->channels != 2) { + av_log(avctx, AV_LOG_ERROR, "Current Libav Vorbis encoder only supports 2 channels.\n"); + return -1; + } + + if ((ret = create_vorbis_context(venc, avctx)) < 0) + goto error; + + avctx->bit_rate = 0; + if (avctx->flags & AV_CODEC_FLAG_QSCALE) + venc->quality = avctx->global_quality / (float)FF_QP2LAMBDA; + else + venc->quality = 3.0; + venc->quality *= venc->quality; + + if ((ret = put_main_header(venc, (uint8_t**)&avctx->extradata)) < 0) + goto error; + avctx->extradata_size = ret; + + avctx->frame_size = 1 << (venc->log2_blocksize[0] - 1); + + return 0; +error: + vorbis_encode_close(avctx); + return ret; +} + AVCodec ff_vorbis_encoder = { - "vorbis", - AVMEDIA_TYPE_AUDIO, - CODEC_ID_VORBIS, - sizeof(vorbis_enc_context), - vorbis_encode_init, - vorbis_encode_frame, - vorbis_encode_close, - .capabilities= CODEC_CAP_DELAY | CODEC_CAP_EXPERIMENTAL, - .sample_fmts = (const enum AVSampleFormat[]){AV_SAMPLE_FMT_S16,AV_SAMPLE_FMT_NONE}, - .long_name = NULL_IF_CONFIG_SMALL("Vorbis"), + .name = "vorbis", + .long_name = NULL_IF_CONFIG_SMALL("Vorbis"), + .type = AVMEDIA_TYPE_AUDIO, + .id = AV_CODEC_ID_VORBIS, + .priv_data_size = sizeof(vorbis_enc_context), + .init = vorbis_encode_init, + .encode2 = vorbis_encode_frame, + .close = vorbis_encode_close, + .capabilities = AV_CODEC_CAP_DELAY | AV_CODEC_CAP_EXPERIMENTAL, + .sample_fmts = (const enum AVSampleFormat[]){ AV_SAMPLE_FMT_FLTP, + AV_SAMPLE_FMT_NONE }, };