Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(90)

Side by Side Diff: third_party/WebKit/Source/modules/mediastream/MediaStream.cpp

Issue 2622533002: Prefer ContextClient mixin over manual ExecutionContext handling. (Closed)
Patch Set: Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 /* 1 /*
2 * Copyright (C) 2011 Google Inc. All rights reserved. 2 * Copyright (C) 2011 Google Inc. All rights reserved.
3 * Copyright (C) 2011, 2012 Ericsson AB. All rights reserved. 3 * Copyright (C) 2011, 2012 Ericsson AB. All rights reserved.
4 * 4 *
5 * Redistribution and use in source and binary forms, with or without 5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions 6 * modification, are permitted provided that the following conditions
7 * are met: 7 * are met:
8 * 1. Redistributions of source code must retain the above copyright 8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer. 9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright 10 * 2. Redistributions in binary form must reproduce the above copyright
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after
89 return new MediaStream(context, audioTracks, videoTracks); 89 return new MediaStream(context, audioTracks, videoTracks);
90 } 90 }
91 91
92 MediaStream* MediaStream::create(ExecutionContext* context, 92 MediaStream* MediaStream::create(ExecutionContext* context,
93 MediaStreamDescriptor* streamDescriptor) { 93 MediaStreamDescriptor* streamDescriptor) {
94 return new MediaStream(context, streamDescriptor); 94 return new MediaStream(context, streamDescriptor);
95 } 95 }
96 96
97 MediaStream::MediaStream(ExecutionContext* context, 97 MediaStream::MediaStream(ExecutionContext* context,
98 MediaStreamDescriptor* streamDescriptor) 98 MediaStreamDescriptor* streamDescriptor)
99 : m_descriptor(streamDescriptor), 99 : ContextClient(context),
100 m_scheduledEventTimer(this, &MediaStream::scheduledEventTimerFired), 100 m_descriptor(streamDescriptor),
101 m_executionContext(context) { 101 m_scheduledEventTimer(this, &MediaStream::scheduledEventTimerFired) {
102 m_descriptor->setClient(this); 102 m_descriptor->setClient(this);
103 103
104 size_t numberOfAudioTracks = m_descriptor->numberOfAudioComponents(); 104 size_t numberOfAudioTracks = m_descriptor->numberOfAudioComponents();
105 m_audioTracks.reserveCapacity(numberOfAudioTracks); 105 m_audioTracks.reserveCapacity(numberOfAudioTracks);
106 for (size_t i = 0; i < numberOfAudioTracks; i++) { 106 for (size_t i = 0; i < numberOfAudioTracks; i++) {
107 MediaStreamTrack* newTrack = 107 MediaStreamTrack* newTrack =
108 MediaStreamTrack::create(context, m_descriptor->audioComponent(i)); 108 MediaStreamTrack::create(context, m_descriptor->audioComponent(i));
109 newTrack->registerMediaStream(this); 109 newTrack->registerMediaStream(this);
110 m_audioTracks.push_back(newTrack); 110 m_audioTracks.push_back(newTrack);
111 } 111 }
112 112
113 size_t numberOfVideoTracks = m_descriptor->numberOfVideoComponents(); 113 size_t numberOfVideoTracks = m_descriptor->numberOfVideoComponents();
114 m_videoTracks.reserveCapacity(numberOfVideoTracks); 114 m_videoTracks.reserveCapacity(numberOfVideoTracks);
115 for (size_t i = 0; i < numberOfVideoTracks; i++) { 115 for (size_t i = 0; i < numberOfVideoTracks; i++) {
116 MediaStreamTrack* newTrack = 116 MediaStreamTrack* newTrack =
117 MediaStreamTrack::create(context, m_descriptor->videoComponent(i)); 117 MediaStreamTrack::create(context, m_descriptor->videoComponent(i));
118 newTrack->registerMediaStream(this); 118 newTrack->registerMediaStream(this);
119 m_videoTracks.push_back(newTrack); 119 m_videoTracks.push_back(newTrack);
120 } 120 }
121 121
122 if (emptyOrOnlyEndedTracks()) { 122 if (emptyOrOnlyEndedTracks()) {
123 m_descriptor->setActive(false); 123 m_descriptor->setActive(false);
124 } 124 }
125 } 125 }
126 126
127 MediaStream::MediaStream(ExecutionContext* context, 127 MediaStream::MediaStream(ExecutionContext* context,
128 const MediaStreamTrackVector& audioTracks, 128 const MediaStreamTrackVector& audioTracks,
129 const MediaStreamTrackVector& videoTracks) 129 const MediaStreamTrackVector& videoTracks)
130 : m_scheduledEventTimer(this, &MediaStream::scheduledEventTimerFired), 130 : ContextClient(context),
131 m_executionContext(context) { 131 m_scheduledEventTimer(this, &MediaStream::scheduledEventTimerFired) {
132 MediaStreamComponentVector audioComponents; 132 MediaStreamComponentVector audioComponents;
133 MediaStreamComponentVector videoComponents; 133 MediaStreamComponentVector videoComponents;
134 134
135 MediaStreamTrackVector::const_iterator iter; 135 MediaStreamTrackVector::const_iterator iter;
136 for (iter = audioTracks.begin(); iter != audioTracks.end(); ++iter) { 136 for (iter = audioTracks.begin(); iter != audioTracks.end(); ++iter) {
137 (*iter)->registerMediaStream(this); 137 (*iter)->registerMediaStream(this);
138 audioComponents.push_back((*iter)->component()); 138 audioComponents.push_back((*iter)->component());
139 } 139 }
140 for (iter = videoTracks.begin(); iter != videoTracks.end(); ++iter) { 140 for (iter = videoTracks.begin(); iter != videoTracks.end(); ++iter) {
141 (*iter)->registerMediaStream(this); 141 (*iter)->registerMediaStream(this);
(...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after
288 for (MediaStreamTrackVector::iterator iter = m_videoTracks.begin(); 288 for (MediaStreamTrackVector::iterator iter = m_videoTracks.begin();
289 iter != m_videoTracks.end(); ++iter) { 289 iter != m_videoTracks.end(); ++iter) {
290 if (!(*iter)->ended()) 290 if (!(*iter)->ended())
291 return; 291 return;
292 } 292 }
293 293
294 streamEnded(); 294 streamEnded();
295 } 295 }
296 296
297 void MediaStream::streamEnded() { 297 void MediaStream::streamEnded() {
298 if (!m_executionContext || m_executionContext->isContextDestroyed()) 298 if (!getExecutionContext())
299 return; 299 return;
300 300
301 if (active()) { 301 if (active()) {
302 m_descriptor->setActive(false); 302 m_descriptor->setActive(false);
303 scheduleDispatchEvent(Event::create(EventTypeNames::inactive)); 303 scheduleDispatchEvent(Event::create(EventTypeNames::inactive));
304 } 304 }
305 } 305 }
306 306
307 bool MediaStream::addEventListenerInternal( 307 bool MediaStream::addEventListenerInternal(
308 const AtomicString& eventType, 308 const AtomicString& eventType,
309 EventListener* listener, 309 EventListener* listener,
310 const AddEventListenerOptionsResolved& options) { 310 const AddEventListenerOptionsResolved& options) {
311 if (eventType == EventTypeNames::active) 311 if (eventType == EventTypeNames::active)
312 UseCounter::count(m_executionContext, UseCounter::MediaStreamOnActive); 312 UseCounter::count(getExecutionContext(), UseCounter::MediaStreamOnActive);
313 else if (eventType == EventTypeNames::inactive) 313 else if (eventType == EventTypeNames::inactive)
314 UseCounter::count(m_executionContext, UseCounter::MediaStreamOnInactive); 314 UseCounter::count(getExecutionContext(), UseCounter::MediaStreamOnInactive);
315 315
316 return EventTargetWithInlineData::addEventListenerInternal(eventType, 316 return EventTargetWithInlineData::addEventListenerInternal(eventType,
317 listener, options); 317 listener, options);
318 } 318 }
319 319
320 const AtomicString& MediaStream::interfaceName() const { 320 const AtomicString& MediaStream::interfaceName() const {
321 return EventTargetNames::MediaStream; 321 return EventTargetNames::MediaStream;
322 } 322 }
323 323
324 void MediaStream::addRemoteTrack(MediaStreamComponent* component) { 324 void MediaStream::addRemoteTrack(MediaStreamComponent* component) {
325 DCHECK(component); 325 DCHECK(component);
326 if (!m_executionContext || m_executionContext->isContextDestroyed()) 326 if (!getExecutionContext())
327 return; 327 return;
328 328
329 MediaStreamTrack* track = 329 MediaStreamTrack* track =
330 MediaStreamTrack::create(m_executionContext, component); 330 MediaStreamTrack::create(getExecutionContext(), component);
331 switch (component->source()->type()) { 331 switch (component->source()->type()) {
332 case MediaStreamSource::TypeAudio: 332 case MediaStreamSource::TypeAudio:
333 m_audioTracks.push_back(track); 333 m_audioTracks.push_back(track);
334 break; 334 break;
335 case MediaStreamSource::TypeVideo: 335 case MediaStreamSource::TypeVideo:
336 m_videoTracks.push_back(track); 336 m_videoTracks.push_back(track);
337 break; 337 break;
338 } 338 }
339 track->registerMediaStream(this); 339 track->registerMediaStream(this);
340 m_descriptor->addComponent(component); 340 m_descriptor->addComponent(component);
341 341
342 scheduleDispatchEvent( 342 scheduleDispatchEvent(
343 MediaStreamTrackEvent::create(EventTypeNames::addtrack, track)); 343 MediaStreamTrackEvent::create(EventTypeNames::addtrack, track));
344 344
345 if (!active() && !track->ended()) { 345 if (!active() && !track->ended()) {
346 m_descriptor->setActive(true); 346 m_descriptor->setActive(true);
347 scheduleDispatchEvent(Event::create(EventTypeNames::active)); 347 scheduleDispatchEvent(Event::create(EventTypeNames::active));
348 } 348 }
349 } 349 }
350 350
351 void MediaStream::removeRemoteTrack(MediaStreamComponent* component) { 351 void MediaStream::removeRemoteTrack(MediaStreamComponent* component) {
352 DCHECK(component); 352 DCHECK(component);
353 if (!m_executionContext || m_executionContext->isContextDestroyed()) 353 if (!getExecutionContext())
354 return; 354 return;
355 355
356 MediaStreamTrackVector* tracks = 0; 356 MediaStreamTrackVector* tracks = 0;
357 switch (component->source()->type()) { 357 switch (component->source()->type()) {
358 case MediaStreamSource::TypeAudio: 358 case MediaStreamSource::TypeAudio:
359 tracks = &m_audioTracks; 359 tracks = &m_audioTracks;
360 break; 360 break;
361 case MediaStreamSource::TypeVideo: 361 case MediaStreamSource::TypeVideo:
362 tracks = &m_videoTracks; 362 tracks = &m_videoTracks;
363 break; 363 break;
(...skipping 24 matching lines...) Expand all
388 } 388 }
389 389
390 void MediaStream::scheduleDispatchEvent(Event* event) { 390 void MediaStream::scheduleDispatchEvent(Event* event) {
391 m_scheduledEvents.push_back(event); 391 m_scheduledEvents.push_back(event);
392 392
393 if (!m_scheduledEventTimer.isActive()) 393 if (!m_scheduledEventTimer.isActive())
394 m_scheduledEventTimer.startOneShot(0, BLINK_FROM_HERE); 394 m_scheduledEventTimer.startOneShot(0, BLINK_FROM_HERE);
395 } 395 }
396 396
397 void MediaStream::scheduledEventTimerFired(TimerBase*) { 397 void MediaStream::scheduledEventTimerFired(TimerBase*) {
398 if (!m_executionContext || m_executionContext->isContextDestroyed()) 398 if (!getExecutionContext())
399 return; 399 return;
400 400
401 HeapVector<Member<Event>> events; 401 HeapVector<Member<Event>> events;
402 events.swap(m_scheduledEvents); 402 events.swap(m_scheduledEvents);
403 403
404 HeapVector<Member<Event>>::iterator it = events.begin(); 404 HeapVector<Member<Event>>::iterator it = events.begin();
405 for (; it != events.end(); ++it) 405 for (; it != events.end(); ++it)
406 dispatchEvent((*it).release()); 406 dispatchEvent((*it).release());
407 407
408 events.clear(); 408 events.clear();
409 } 409 }
410 410
411 URLRegistry& MediaStream::registry() const { 411 URLRegistry& MediaStream::registry() const {
412 return MediaStreamRegistry::registry(); 412 return MediaStreamRegistry::registry();
413 } 413 }
414 414
415 DEFINE_TRACE(MediaStream) { 415 DEFINE_TRACE(MediaStream) {
416 visitor->trace(m_audioTracks); 416 visitor->trace(m_audioTracks);
417 visitor->trace(m_videoTracks); 417 visitor->trace(m_videoTracks);
418 visitor->trace(m_descriptor); 418 visitor->trace(m_descriptor);
419 visitor->trace(m_scheduledEvents); 419 visitor->trace(m_scheduledEvents);
420 visitor->trace(m_executionContext);
421 EventTargetWithInlineData::trace(visitor); 420 EventTargetWithInlineData::trace(visitor);
421 ContextClient::trace(visitor);
422 MediaStreamDescriptorClient::trace(visitor); 422 MediaStreamDescriptorClient::trace(visitor);
423 } 423 }
424 424
425 MediaStream* toMediaStream(MediaStreamDescriptor* descriptor) { 425 MediaStream* toMediaStream(MediaStreamDescriptor* descriptor) {
426 return static_cast<MediaStream*>(descriptor->client()); 426 return static_cast<MediaStream*>(descriptor->client());
427 } 427 }
428 428
429 } // namespace blink 429 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698