Merge commit 'f5f1cf52240759208b42477e2157a7b4409ade10'
authorMichael Niedermayer <michaelni@gmx.at>
Mon, 24 Dec 2012 13:43:03 +0000 (14:43 +0100)
committerMichael Niedermayer <michaelni@gmx.at>
Mon, 24 Dec 2012 13:43:03 +0000 (14:43 +0100)
* commit 'f5f1cf52240759208b42477e2157a7b4409ade10':
  oggdec: K&R cosmetic formatting
  hlsenc: correctly report target duration

Conflicts:
libavformat/oggdec.c

Merged-by: Michael Niedermayer <michaelni@gmx.at>
1  2 
libavformat/hlsenc.c
libavformat/oggdec.c

Simple merge
@@@ -121,29 -117,23 +121,29 @@@ static int ogg_restore(AVFormatContext 
      return 0;
  }
  
 -static int ogg_reset(struct ogg *ogg)
 +static int ogg_reset(AVFormatContext *s)
  {
 +    struct ogg *ogg = s->priv_data;
      int i;
 +    int64_t start_pos = avio_tell(s->pb);
  
-     for (i = 0; i < ogg->nstreams; i++){
+     for (i = 0; i < ogg->nstreams; i++) {
          struct ogg_stream *os = ogg->streams + i;
-         os->bufpos = 0;
-         os->pstart = 0;
-         os->psize = 0;
-         os->granule = -1;
-         os->lastpts = AV_NOPTS_VALUE;
-         os->lastdts = AV_NOPTS_VALUE;
-         os->sync_pos = -1;
-         os->page_pos = 0;
-         os->nsegs = 0;
-         os->segp = 0;
+         os->bufpos     = 0;
+         os->pstart     = 0;
+         os->psize      = 0;
+         os->granule    = -1;
+         os->lastpts    = AV_NOPTS_VALUE;
+         os->lastdts    = AV_NOPTS_VALUE;
+         os->sync_pos   = -1;
+         os->page_pos   = 0;
+         os->nsegs      = 0;
+         os->segp       = 0;
          os->incomplete = 0;
 +        os->got_data = 0;
 +        if (start_pos <= s->data_offset) {
 +            os->lastpts = 0;
 +        }
      }
  
      ogg->curidx = -1;
@@@ -163,84 -153,33 +163,84 @@@ static const struct ogg_codec *ogg_find
      return NULL;
  }
  
 -static int ogg_new_stream(AVFormatContext *s, uint32_t serial, int new_avstream)
 +/**
 + * Replace the current stream with a new one. This is a typical webradio
 + * situation where a new audio stream spawn (identified with a new serial) and
 + * must replace the previous one (track switch).
 + */
 +static int ogg_replace_stream(AVFormatContext *s, uint32_t serial)
 +{
 +    struct ogg *ogg = s->priv_data;
 +    struct ogg_stream *os;
 +    unsigned bufsize;
 +    uint8_t *buf;
 +    struct ogg_codec *codec;
 +
 +    if (ogg->nstreams != 1) {
 +        av_log_missing_feature(s, "Changing stream parameters in multistream ogg", 0);
 +        return AVERROR_PATCHWELCOME;
 +    }
 +
 +    os = &ogg->streams[0];
 +
-     buf = os->buf;
++    buf     = os->buf;
 +    bufsize = os->bufsize;
 +    codec   = os->codec;
 +
 +    if (!ogg->state || ogg->state->streams[0].private != os->private)
 +        av_freep(&ogg->streams[0].private);
 +
 +    /* Set Ogg stream settings similar to what is done in ogg_new_stream(). We
 +     * also re-use the ogg_stream allocated buffer */
 +    memset(os, 0, sizeof(*os));
-     os->serial = serial;
++    os->serial  = serial;
 +    os->bufsize = bufsize;
-     os->buf = buf;
-     os->header = -1;
-     os->codec = codec;
++    os->buf     = buf;
++    os->header  = -1;
++    os->codec   = codec;
 +
 +    return 0;
 +}
 +
 +static int ogg_new_stream(AVFormatContext *s, uint32_t serial)
  {
      struct ogg *ogg = s->priv_data;
-     int idx = ogg->nstreams;
 -    int idx         = ogg->nstreams++;
++    int idx         = ogg->nstreams;
      AVStream *st;
      struct ogg_stream *os;
 +    size_t size;
  
 -    ogg->streams = av_realloc(ogg->streams,
 -                              ogg->nstreams * sizeof(*ogg->streams));
 -    memset(ogg->streams + idx, 0, sizeof(*ogg->streams));
 +    if (ogg->state) {
 +        av_log(s, AV_LOG_ERROR, "New streams are not supposed to be added "
 +               "in between Ogg context save/restore operations.\n");
 +        return AVERROR_BUG;
 +    }
  
-     ogg->streams = os;
-     os = ogg->streams + idx;
 +    /* Allocate and init a new Ogg Stream */
 +    if (av_size_mult(ogg->nstreams + 1, sizeof(*ogg->streams), &size) < 0 ||
 +        !(os = av_realloc(ogg->streams, size)))
 +        return AVERROR(ENOMEM);
-     os->serial = serial;
-     os->bufsize = DECODER_BUFFER_SIZE;
-     os->buf = av_malloc(os->bufsize + FF_INPUT_BUFFER_PADDING_SIZE);
-     os->header = -1;
++    ogg->streams      = os;
+     os                = ogg->streams + idx;
 +    memset(os, 0, sizeof(*os));
+     os->serial        = serial;
+     os->bufsize       = DECODER_BUFFER_SIZE;
+     os->buf           = av_malloc(os->bufsize + FF_INPUT_BUFFER_PADDING_SIZE);
+     os->header        = -1;
      os->start_granule = OGG_NOGRANULE_VALUE;
 -
 -    if (new_avstream) {
 -        st = avformat_new_stream(s, NULL);
 -        if (!st)
 -            return AVERROR(ENOMEM);
 -
 -        st->id = idx;
 -        avpriv_set_pts_info(st, 64, 1, 1000000);
 +    if (!os->buf)
 +        return AVERROR(ENOMEM);
 +
 +    /* Create the associated AVStream */
 +    st = avformat_new_stream(s, NULL);
 +    if (!st) {
 +        av_freep(&os->buf);
 +        return AVERROR(ENOMEM);
      }
 +    st->id = idx;
 +    avpriv_set_pts_info(st, 64, 1, 1000000);
  
 +    ogg->nstreams++;
      return idx;
  }
  
@@@ -296,38 -227,48 +298,40 @@@ static int ogg_read_page(AVFormatContex
              break;
  
          c = avio_r8(bc);
 -        if (bc->eof_reached)
 +        if (url_feof(bc))
              return AVERROR_EOF;
          sync[sp++ & 3] = c;
-     }while (i++ < MAX_PAGE_SIZE);
+     } while (i++ < MAX_PAGE_SIZE);
  
-     if (i >= MAX_PAGE_SIZE){
-         av_log (s, AV_LOG_INFO, "ogg, can't find sync word\n");
+     if (i >= MAX_PAGE_SIZE) {
+         av_log(s, AV_LOG_INFO, "cannot find sync word\n");
          return AVERROR_INVALIDDATA;
      }
  
-     if (avio_r8(bc) != 0){      /* version */
 -    if (avio_r8(bc) != 0)      /* version */
++    if (avio_r8(bc) != 0) {      /* version */
 +        av_log (s, AV_LOG_ERROR, "ogg page, unsupported version\n");
          return AVERROR_INVALIDDATA;
 +    }
  
-     flags = avio_r8(bc);
-     gp = avio_rl64 (bc);
-     serial = avio_rl32 (bc);
+     flags  = avio_r8(bc);
+     gp     = avio_rl64(bc);
+     serial = avio_rl32(bc);
      avio_skip(bc, 8); /* seq, crc */
-     nsegs = avio_r8(bc);
+     nsegs  = avio_r8(bc);
  
-     idx = ogg_find_stream (ogg, serial);
-     if (idx < 0){
+     idx = ogg_find_stream(ogg, serial);
+     if (idx < 0) {
 -        if (ogg->headers) {
 -            int n;
 -
 -            for (n = 0; n < ogg->nstreams; n++) {
 -                av_freep(&ogg->streams[n].buf);
 -                if (!ogg->state ||
 -                    ogg->state->streams[n].private != ogg->streams[n].private)
 -                    av_freep(&ogg->streams[n].private);
 -            }
 +        if (data_packets_seen(ogg))
 +            idx = ogg_replace_stream(s, serial);
 +        else
 +            idx = ogg_new_stream(s, serial);
  
 -            ogg->curidx   = -1;
 -            ogg->nstreams = 0;
 -
 -            idx = ogg_new_stream(s, serial, 0);
 -        } else {
 -            idx = ogg_new_stream(s, serial, 1);
 -        }
 -        if (idx < 0)
 +        if (idx < 0) {
 +            av_log(s, AV_LOG_ERROR, "failed to create or replace stream\n");
              return idx;
 +        }
      }
  
      os = ogg->streams + idx;
      for (i = 0; i < nsegs; i++)
          size += os->segments[i];
  
-     if (flags & OGG_FLAG_CONT || os->incomplete){
-         if (!os->psize){
 +    if (!(flags & OGG_FLAG_BOS))
 +        os->got_data = 1;
 +
-             while (os->segp < os->nsegs){
+     if (flags & OGG_FLAG_CONT || os->incomplete) {
+         if (!os->psize) {
 +            // If this is the very first segment we started
 +            // playback in the middle of a continuation packet.
 +            // Discard it since we missed the start of it.
+             while (os->segp < os->nsegs) {
                  int seg = os->segments[os->segp++];
                  os->pstart += seg;
                  if (seg < 255)
  
      os->bufpos += size;
      os->granule = gp;
-     os->flags = flags;
+     os->flags   = flags;
  
      memset(os->buf + os->bufpos, 0, FF_INPUT_BUFFER_PADDING_SIZE);
 -    if (str)
 -        *str = idx;
 +    if (sid)
 +        *sid = idx;
  
      return 0;
  }
@@@ -404,16 -332,14 +408,16 @@@ static int ogg_packet(AVFormatContext *
      int idx, i, ret;
      struct ogg_stream *os;
      int complete = 0;
-     int segp = 0, psize = 0;
+     int segp     = 0, psize = 0;
  
      av_dlog(s, "ogg_packet: curidx=%i\n", ogg->curidx);
 +    if (sid)
 +        *sid = -1;
  
-     do{
+     do {
          idx = ogg->curidx;
  
-         while (idx < 0){
+         while (idx < 0) {
              ret = ogg_read_page(s, &idx);
              if (ret < 0)
                  return ret;
              }
          }
  
-         if (!complete && os->segp == os->nsegs){
-             ogg->curidx = -1;
+         if (!complete && os->segp == os->nsegs) {
+             ogg->curidx    = -1;
 -            os->incomplete = 1;
 +            // Do not set incomplete for empty packets.
 +            // Together with the code in ogg_read_page
 +            // that discards all continuation of empty packets
 +            // we would get an infinite loop.
 +            os->incomplete = !!os->psize;
          }
-     }while (!complete);
+     } while (!complete);
  
 -    av_dlog(s, "ogg_packet: idx %i, frame size %i, start %i\n",
 -            idx, os->psize, os->pstart);
  
      if (os->granule == -1)
-         av_log(s, AV_LOG_WARNING, "Page at %"PRId64" is missing granule\n", os->page_pos);
+         av_log(s, AV_LOG_WARNING,
+                "Page at %"PRId64" is missing granule\n",
+                os->page_pos);
  
-     ogg->curidx = idx;
+     ogg->curidx    = idx;
      os->incomplete = 0;
  
      if (os->header) {
                  if (cur_os->incomplete)
                      s->data_offset = FFMIN(s->data_offset, cur_os->sync_pos);
              }
-         }else{
+         } else {
              os->nb_header++;
              os->pstart += os->psize;
-             os->psize = 0;
+             os->psize   = 0;
          }
      } else {
-         os->pflags = 0;
+         os->pflags    = 0;
          os->pduration = 0;
          if (os->codec && os->codec->packet)
-             os->codec->packet (s, idx);
+             os->codec->packet(s, idx);
 -        if (str)
 -            *str = idx;
 +        if (sid)
 +            *sid = idx;
          if (dstart)
              *dstart = os->pstart;
          if (dsize)
              *dsize = os->psize;
          if (fpos)
              *fpos = os->sync_pos;
-         os->pstart += os->psize;
-         os->psize = 0;
+         os->pstart  += os->psize;
+         os->psize    = 0;
 +        if(os->pstart == os->bufpos)
 +            os->bufpos = os->pstart = 0;
          os->sync_pos = os->page_pos;
      }
  
@@@ -534,9 -488,8 +541,9 @@@ static int ogg_get_length(AVFormatConte
      struct ogg *ogg = s->priv_data;
      int i;
      int64_t size, end;
 +    int streams_left=0;
  
-     if(!s->pb->seekable)
+     if (!s->pb->seekable)
          return 0;
  
  // already set
          if (ogg->streams[i].granule != -1 && ogg->streams[i].granule != 0 &&
              ogg->streams[i].codec) {
              s->streams[i]->duration =
-                 ogg_gptopts (s, i, ogg->streams[i].granule, NULL);
-             if (s->streams[i]->start_time != AV_NOPTS_VALUE){
+                 ogg_gptopts(s, i, ogg->streams[i].granule, NULL);
 -            if (s->streams[i]->start_time != AV_NOPTS_VALUE)
++            if (s->streams[i]->start_time != AV_NOPTS_VALUE) {
                  s->streams[i]->duration -= s->streams[i]->start_time;
-             }else if(!ogg->streams[i].got_start){
 +                streams_left-= (ogg->streams[i].got_start==-1);
 +                ogg->streams[i].got_start= 1;
++            } else if(!ogg->streams[i].got_start) {
 +                ogg->streams[i].got_start= -1;
 +                streams_left++;
 +            }
          }
      }
  
-     ogg_restore (s, 0);
+     ogg_restore(s, 0);
  
-         if (pts != AV_NOPTS_VALUE && s->streams[i]->start_time == AV_NOPTS_VALUE && !ogg->streams[i].got_start){
 +    ogg_save (s);
 +    avio_seek (s->pb, s->data_offset, SEEK_SET);
 +    ogg_reset(s);
 +    while (streams_left > 0 && !ogg_packet(s, &i, NULL, NULL, NULL)) {
 +        int64_t pts;
 +        if (i < 0) continue;
 +        pts = ogg_calc_pts(s, i, NULL);
-         }else if(s->streams[i]->start_time != AV_NOPTS_VALUE && !ogg->streams[i].got_start){
++        if (pts != AV_NOPTS_VALUE && s->streams[i]->start_time == AV_NOPTS_VALUE && !ogg->streams[i].got_start) {
 +            s->streams[i]->duration -= pts;
 +            ogg->streams[i].got_start= 1;
 +            streams_left--;
++        }else if(s->streams[i]->start_time != AV_NOPTS_VALUE && !ogg->streams[i].got_start) {
 +            ogg->streams[i].got_start= 1;
 +            streams_left--;
 +        }
 +    }
 +    ogg_restore (s, 0);
 +
      return 0;
  }
  
@@@ -594,36 -523,20 +601,36 @@@ static int ogg_read_header(AVFormatCont
  {
      struct ogg *ogg = s->priv_data;
      int ret, i;
 +
      ogg->curidx = -1;
 +
      //linear headers seek from start
 -    ret = ogg_get_headers(s);
 -    if (ret < 0)
 -        return ret;
 +    do {
 +        ret = ogg_packet(s, NULL, NULL, NULL, NULL);
 +        if (ret < 0) {
 +            ogg_read_close(s);
 +            return ret;
 +        }
 +    } while (!ogg->headers);
 +    av_dlog(s, "found headers\n");
  
 -    for (i = 0; i < ogg->nstreams; i++)
 -        if (ogg->streams[i].header < 0)
 +    for (i = 0; i < ogg->nstreams; i++) {
 +        struct ogg_stream *os = ogg->streams + i;
 +
 +        if (ogg->streams[i].header < 0) {
 +            av_log(s, AV_LOG_ERROR, "Header parsing failed for stream %d\n", i);
              ogg->streams[i].codec = NULL;
 +        } else if (os->codec && os->nb_header < os->codec->nb_header) {
 +            av_log(s, AV_LOG_WARNING, "Number of headers (%d) mismatch for stream %d\n", os->nb_header, i);
 +        }
 +        if (os->start_granule != OGG_NOGRANULE_VALUE)
 +            os->lastpts = s->streams[i]->start_time =
 +                ogg_gptopts(s, i, os->start_granule, NULL);
 +    }
  
      //linear granulepos seek from end
-     ogg_get_length (s);
+     ogg_get_length(s);
  
 -    //fill the extradata in the per codec callbacks
      return 0;
  }
  
@@@ -731,14 -630,13 +738,15 @@@ static int64_t ogg_read_timestamp(AVFor
  {
      struct ogg *ogg = s->priv_data;
      AVIOContext *bc = s->pb;
-     int64_t pts = AV_NOPTS_VALUE;
-     int64_t keypos = -1;
+     int64_t pts     = AV_NOPTS_VALUE;
 -    int i           = -1;
++    int64_t keypos  = -1;
 +    int i;
 +    int pstart, psize;
      avio_seek(bc, *pos_arg, SEEK_SET);
 -    ogg_reset(ogg);
 +    ogg_reset(s);
  
-     while (avio_tell(bc) <= pos_limit && !ogg_packet(s, &i, &pstart, &psize, pos_arg)) {
 -    while (avio_tell(bc) < pos_limit &&
 -           !ogg_packet(s, &i, NULL, NULL, pos_arg)) {
++    while (   avio_tell(bc) <= pos_limit
++           && !ogg_packet(s, &i, &pstart, &psize, pos_arg)) {
          if (i == stream_index) {
              struct ogg_stream *os = ogg->streams + stream_index;
              pts = ogg_calc_pts(s, i, NULL);