| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/webm/webm_stream_parser.h" | 5 #include "media/webm/webm_stream_parser.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 11 matching lines...) Expand all Loading... |
| 22 : state_(kWaitingForInit), | 22 : state_(kWaitingForInit), |
| 23 waiting_for_buffers_(false) { | 23 waiting_for_buffers_(false) { |
| 24 } | 24 } |
| 25 | 25 |
| 26 WebMStreamParser::~WebMStreamParser() { | 26 WebMStreamParser::~WebMStreamParser() { |
| 27 STLDeleteValues(&text_track_map_); | 27 STLDeleteValues(&text_track_map_); |
| 28 } | 28 } |
| 29 | 29 |
| 30 void WebMStreamParser::Init(const InitCB& init_cb, | 30 void WebMStreamParser::Init(const InitCB& init_cb, |
| 31 const NewConfigCB& config_cb, | 31 const NewConfigCB& config_cb, |
| 32 const NewBuffersCB& audio_cb, | 32 const NewBuffersCB& new_buffers_cb, |
| 33 const NewBuffersCB& video_cb, | |
| 34 const NewTextBuffersCB& text_cb, | 33 const NewTextBuffersCB& text_cb, |
| 35 const NeedKeyCB& need_key_cb, | 34 const NeedKeyCB& need_key_cb, |
| 36 const AddTextTrackCB& add_text_track_cb, | 35 const AddTextTrackCB& add_text_track_cb, |
| 37 const NewMediaSegmentCB& new_segment_cb, | 36 const NewMediaSegmentCB& new_segment_cb, |
| 38 const base::Closure& end_of_segment_cb, | 37 const base::Closure& end_of_segment_cb, |
| 39 const LogCB& log_cb) { | 38 const LogCB& log_cb) { |
| 40 DCHECK_EQ(state_, kWaitingForInit); | 39 DCHECK_EQ(state_, kWaitingForInit); |
| 41 DCHECK(init_cb_.is_null()); | 40 DCHECK(init_cb_.is_null()); |
| 42 DCHECK(!init_cb.is_null()); | 41 DCHECK(!init_cb.is_null()); |
| 43 DCHECK(!config_cb.is_null()); | 42 DCHECK(!config_cb.is_null()); |
| 44 DCHECK(!audio_cb.is_null() || !video_cb.is_null()); | 43 DCHECK(!new_buffers_cb.is_null()); |
| 45 DCHECK(!text_cb.is_null()); | 44 DCHECK(!text_cb.is_null()); |
| 46 DCHECK(!need_key_cb.is_null()); | 45 DCHECK(!need_key_cb.is_null()); |
| 47 DCHECK(!new_segment_cb.is_null()); | 46 DCHECK(!new_segment_cb.is_null()); |
| 48 DCHECK(!end_of_segment_cb.is_null()); | 47 DCHECK(!end_of_segment_cb.is_null()); |
| 49 | 48 |
| 50 ChangeState(kParsingHeaders); | 49 ChangeState(kParsingHeaders); |
| 51 init_cb_ = init_cb; | 50 init_cb_ = init_cb; |
| 52 config_cb_ = config_cb; | 51 config_cb_ = config_cb; |
| 53 audio_cb_ = audio_cb; | 52 new_buffers_cb_ = new_buffers_cb; |
| 54 video_cb_ = video_cb; | |
| 55 text_cb_ = text_cb; | 53 text_cb_ = text_cb; |
| 56 need_key_cb_ = need_key_cb; | 54 need_key_cb_ = need_key_cb; |
| 57 add_text_track_cb_ = add_text_track_cb; | 55 add_text_track_cb_ = add_text_track_cb; |
| 58 new_segment_cb_ = new_segment_cb; | 56 new_segment_cb_ = new_segment_cb; |
| 59 end_of_segment_cb_ = end_of_segment_cb; | 57 end_of_segment_cb_ = end_of_segment_cb; |
| 60 log_cb_ = log_cb; | 58 log_cb_ = log_cb; |
| 61 } | 59 } |
| 62 | 60 |
| 63 void WebMStreamParser::Flush() { | 61 void WebMStreamParser::Flush() { |
| 64 DCHECK_NE(state_, kWaitingForInit); | 62 DCHECK_NE(state_, kWaitingForInit); |
| (...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 284 const BufferQueue& audio_buffers = cluster_parser_->audio_buffers(); | 282 const BufferQueue& audio_buffers = cluster_parser_->audio_buffers(); |
| 285 const BufferQueue& video_buffers = cluster_parser_->video_buffers(); | 283 const BufferQueue& video_buffers = cluster_parser_->video_buffers(); |
| 286 base::TimeDelta cluster_start_time = cluster_parser_->cluster_start_time(); | 284 base::TimeDelta cluster_start_time = cluster_parser_->cluster_start_time(); |
| 287 bool cluster_ended = cluster_parser_->cluster_ended(); | 285 bool cluster_ended = cluster_parser_->cluster_ended(); |
| 288 | 286 |
| 289 if (waiting_for_buffers_ && cluster_start_time != kNoTimestamp()) { | 287 if (waiting_for_buffers_ && cluster_start_time != kNoTimestamp()) { |
| 290 new_segment_cb_.Run(cluster_start_time); | 288 new_segment_cb_.Run(cluster_start_time); |
| 291 waiting_for_buffers_ = false; | 289 waiting_for_buffers_ = false; |
| 292 } | 290 } |
| 293 | 291 |
| 294 if (!audio_buffers.empty() && !audio_cb_.Run(audio_buffers)) | 292 if ((!audio_buffers.empty() || !video_buffers.empty()) && |
| 293 !new_buffers_cb_.Run(audio_buffers, video_buffers)) { |
| 295 return -1; | 294 return -1; |
| 296 | 295 } |
| 297 if (!video_buffers.empty() && !video_cb_.Run(video_buffers)) | |
| 298 return -1; | |
| 299 | 296 |
| 300 WebMClusterParser::TextTrackIterator text_track_iter = | 297 WebMClusterParser::TextTrackIterator text_track_iter = |
| 301 cluster_parser_->CreateTextTrackIterator(); | 298 cluster_parser_->CreateTextTrackIterator(); |
| 302 | 299 |
| 303 int text_track_num; | 300 int text_track_num; |
| 304 const BufferQueue* text_buffers; | 301 const BufferQueue* text_buffers; |
| 305 | 302 |
| 306 while (text_track_iter(&text_track_num, &text_buffers)) { | 303 while (text_track_iter(&text_track_num, &text_buffers)) { |
| 307 TextTrackMap::iterator find_result = text_track_map_.find(text_track_num); | 304 TextTrackMap::iterator find_result = text_track_map_.find(text_track_num); |
| 308 | 305 |
| (...skipping 14 matching lines...) Expand all Loading... |
| 323 | 320 |
| 324 void WebMStreamParser::FireNeedKey(const std::string& key_id) { | 321 void WebMStreamParser::FireNeedKey(const std::string& key_id) { |
| 325 int key_id_size = key_id.size(); | 322 int key_id_size = key_id.size(); |
| 326 DCHECK_GT(key_id_size, 0); | 323 DCHECK_GT(key_id_size, 0); |
| 327 scoped_ptr<uint8[]> key_id_array(new uint8[key_id_size]); | 324 scoped_ptr<uint8[]> key_id_array(new uint8[key_id_size]); |
| 328 memcpy(key_id_array.get(), key_id.data(), key_id_size); | 325 memcpy(key_id_array.get(), key_id.data(), key_id_size); |
| 329 need_key_cb_.Run(kWebMEncryptInitDataType, key_id_array.Pass(), key_id_size); | 326 need_key_cb_.Run(kWebMEncryptInitDataType, key_id_array.Pass(), key_id_size); |
| 330 } | 327 } |
| 331 | 328 |
| 332 } // namespace media | 329 } // namespace media |
| OLD | NEW |