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 |