OLD | NEW |
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 12 matching lines...) Expand all Loading... |
23 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 23 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
24 */ | 24 */ |
25 | 25 |
26 #include "config.h" | 26 #include "config.h" |
27 #include "modules/mediastream/MediaStream.h" | 27 #include "modules/mediastream/MediaStream.h" |
28 | 28 |
29 #if ENABLE(MEDIA_STREAM) | 29 #if ENABLE(MEDIA_STREAM) |
30 | 30 |
31 #include "core/dom/Event.h" | 31 #include "core/dom/Event.h" |
32 #include "core/dom/ExceptionCode.h" | 32 #include "core/dom/ExceptionCode.h" |
33 #include "core/platform/UUID.h" | |
34 #include "core/platform/mediastream/MediaStreamCenter.h" | 33 #include "core/platform/mediastream/MediaStreamCenter.h" |
35 #include "core/platform/mediastream/MediaStreamSource.h" | 34 #include "core/platform/mediastream/MediaStreamSource.h" |
36 #include "modules/mediastream/MediaStreamTrackEvent.h" | 35 #include "modules/mediastream/MediaStreamTrackEvent.h" |
37 | 36 |
38 namespace WebCore { | 37 namespace WebCore { |
39 | 38 |
40 static bool containsSource(MediaStreamSourceVector& sourceVector, MediaStreamSou
rce* source) | 39 static bool containsSource(MediaStreamSourceVector& sourceVector, MediaStreamSou
rce* source) |
41 { | 40 { |
42 for (size_t i = 0; i < sourceVector.size(); ++i) { | 41 for (size_t i = 0; i < sourceVector.size(); ++i) { |
43 if (source->id() == sourceVector[i]->id()) | 42 if (source->id() == sourceVector[i]->id()) |
44 return true; | 43 return true; |
45 } | 44 } |
46 return false; | 45 return false; |
47 } | 46 } |
48 | 47 |
49 static void processTrack(MediaStreamTrack* track, MediaStreamSourceVector& sourc
eVector) | 48 static void processTrack(MediaStreamTrack* track, MediaStreamSourceVector& sourc
eVector) |
50 { | 49 { |
51 if (track->ended()) | 50 if (track->ended()) |
52 return; | 51 return; |
53 | 52 |
54 MediaStreamSource* source = track->component()->source(); | 53 MediaStreamSource* source = track->component()->source(); |
55 if (!containsSource(sourceVector, source)) | 54 if (!containsSource(sourceVector, source)) |
56 sourceVector.append(source); | 55 sourceVector.append(source); |
57 } | 56 } |
58 | 57 |
59 static PassRefPtr<MediaStream> createFromSourceVectors(ScriptExecutionContext* c
ontext, const MediaStreamSourceVector& audioSources, const MediaStreamSourceVect
or& videoSources) | 58 static PassRefPtr<MediaStream> createFromSourceVectors(ScriptExecutionContext* c
ontext, const MediaStreamSourceVector& audioSources, const MediaStreamSourceVect
or& videoSources) |
60 { | 59 { |
61 RefPtr<MediaStreamDescriptor> descriptor = MediaStreamDescriptor::create(cre
ateCanonicalUUIDString(), audioSources, videoSources); | 60 RefPtr<MediaStreamDescriptor> descriptor = MediaStreamDescriptor::create(aud
ioSources, videoSources); |
62 MediaStreamCenter::instance().didCreateMediaStream(descriptor.get()); | 61 MediaStreamCenter::instance().didCreateMediaStream(descriptor.get()); |
63 | 62 |
64 return MediaStream::create(context, descriptor.release()); | 63 return MediaStream::create(context, descriptor.release()); |
65 } | 64 } |
66 | 65 |
67 PassRefPtr<MediaStream> MediaStream::create(ScriptExecutionContext* context) | 66 PassRefPtr<MediaStream> MediaStream::create(ScriptExecutionContext* context) |
68 { | 67 { |
69 MediaStreamSourceVector audioSources; | 68 MediaStreamSourceVector audioSources; |
70 MediaStreamSourceVector videoSources; | 69 MediaStreamSourceVector videoSources; |
71 | 70 |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
214 } | 213 } |
215 | 214 |
216 for (MediaStreamTrackVector::iterator iter = m_videoTracks.begin(); iter !=
m_videoTracks.end(); ++iter) { | 215 for (MediaStreamTrackVector::iterator iter = m_videoTracks.begin(); iter !=
m_videoTracks.end(); ++iter) { |
217 if ((*iter)->id() == id) | 216 if ((*iter)->id() == id) |
218 return (*iter).get(); | 217 return (*iter).get(); |
219 } | 218 } |
220 | 219 |
221 return 0; | 220 return 0; |
222 } | 221 } |
223 | 222 |
| 223 void MediaStream::stop() |
| 224 { |
| 225 if (ended()) |
| 226 return; |
| 227 |
| 228 MediaStreamCenter::instance().didStopLocalMediaStream(descriptor()); |
| 229 |
| 230 streamEnded(); |
| 231 } |
| 232 |
224 void MediaStream::trackEnded() | 233 void MediaStream::trackEnded() |
225 { | 234 { |
226 for (size_t i = 0; i < m_audioTracks.size(); ++i) | 235 for (size_t i = 0; i < m_audioTracks.size(); ++i) |
227 if (!m_audioTracks[i]->ended()) | 236 if (!m_audioTracks[i]->ended()) |
228 return; | 237 return; |
229 | 238 |
230 for (size_t i = 0; i < m_videoTracks.size(); ++i) | 239 for (size_t i = 0; i < m_videoTracks.size(); ++i) |
231 if (!m_videoTracks[i]->ended()) | 240 if (!m_videoTracks[i]->ended()) |
232 return; | 241 return; |
233 | 242 |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
342 Vector<RefPtr<Event> >::iterator it = events.begin(); | 351 Vector<RefPtr<Event> >::iterator it = events.begin(); |
343 for (; it != events.end(); ++it) | 352 for (; it != events.end(); ++it) |
344 dispatchEvent((*it).release()); | 353 dispatchEvent((*it).release()); |
345 | 354 |
346 events.clear(); | 355 events.clear(); |
347 } | 356 } |
348 | 357 |
349 } // namespace WebCore | 358 } // namespace WebCore |
350 | 359 |
351 #endif // ENABLE(MEDIA_STREAM) | 360 #endif // ENABLE(MEDIA_STREAM) |
OLD | NEW |