Chrome-side implementation of media source timestamp offset

media/webm/webm_cluster_parser.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/webm/webm_cluster_parser.h"
 
 #include "base/logging.h"
 #include "base/sys_byteorder.h"
 #include "media/base/data_buffer.h"
 #include "media/base/decrypt_config.h"
@@ skipping 25 matching lines @@
                                      const uint8* video_encryption_key_id,
                                      int video_encryption_key_id_size)
     : timecode_multiplier_(timecode_scale / 1000.0),
       video_encryption_key_id_size_(video_encryption_key_id_size),
       parser_(kWebMIdCluster, this),
       last_block_timecode_(-1),
       block_data_size_(-1),
       block_duration_(-1),
       cluster_timecode_(-1),
       cluster_start_time_(kNoTimestamp()),
+      cluster_ended_(false),
       audio_(audio_track_num),
       video_(video_track_num) {
   CHECK_GE(video_encryption_key_id_size, 0);
   if (video_encryption_key_id_size > 0) {
     video_encryption_key_id_.reset(new uint8[video_encryption_key_id_size]);
     memcpy(video_encryption_key_id_.get(), video_encryption_key_id,
            video_encryption_key_id_size);
   }
 }
 
 WebMClusterParser::~WebMClusterParser() {}
 
 void WebMClusterParser::Reset() {
   last_block_timecode_ = -1;
   cluster_timecode_ = -1;
   cluster_start_time_ = kNoTimestamp();
+  cluster_ended_ = false;
   parser_.Reset();
   audio_.Reset();
   video_.Reset();
 }
 
 int WebMClusterParser::Parse(const uint8* buf, int size) {
   audio_.Reset();
   video_.Reset();
 
   int result = parser_.Parse(buf, size);
 
-  if (result <= 0)
+  if (result <= 0) {
+    cluster_ended_ = false;
     return result;
+  }
 
-  if (parser_.IsParsingComplete()) {
+  cluster_ended_ = parser_.IsParsingComplete();
+  if (cluster_ended_) {
     // If there were no buffers in this cluster, set the cluster start time to
     // be the |cluster_timecode_|.
     if (cluster_start_time_ == kNoTimestamp()) {
       DCHECK_GT(cluster_timecode_, -1);
       cluster_start_time_ = base::TimeDelta::FromMicroseconds(
           cluster_timecode_ * timecode_multiplier_);
     }
 
     // Reset the parser if we're done parsing so that
     // it is ready to accept another cluster on the next
@@ skipping 194 matching lines @@
 
   buffers_.push_back(buffer);
   return true;
 }
 
 void WebMClusterParser::Track::Reset() {
   buffers_.clear();
 }
 
 }  // namespace media