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

Side by Side Diff: content/renderer/media/remote_media_stream_impl.cc

Issue 63253002: Rename WebKit namespace to blink (part 3) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 1 month 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 | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2013 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 "content/renderer/media/remote_media_stream_impl.h" 5 #include "content/renderer/media/remote_media_stream_impl.h"
6 6
7 #include <string> 7 #include <string>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "base/strings/utf_string_conversions.h" 10 #include "base/strings/utf_string_conversions.h"
11 #include "content/renderer/media/media_stream_dependency_factory.h" 11 #include "content/renderer/media/media_stream_dependency_factory.h"
12 #include "content/renderer/media/media_stream_extra_data.h" 12 #include "content/renderer/media/media_stream_extra_data.h"
13 #include "third_party/WebKit/public/platform/WebString.h" 13 #include "third_party/WebKit/public/platform/WebString.h"
14 14
15 namespace content { 15 namespace content {
16 16
17 // RemoteMediaStreamTrackObserver is responsible for listening on change 17 // RemoteMediaStreamTrackObserver is responsible for listening on change
18 // notification on a remote webrtc MediaStreamTrack and notify WebKit. 18 // notification on a remote webrtc MediaStreamTrack and notify WebKit.
19 class RemoteMediaStreamTrackObserver 19 class RemoteMediaStreamTrackObserver
20 : NON_EXPORTED_BASE(public webrtc::ObserverInterface), 20 : NON_EXPORTED_BASE(public webrtc::ObserverInterface),
21 NON_EXPORTED_BASE(public base::NonThreadSafe) { 21 NON_EXPORTED_BASE(public base::NonThreadSafe) {
22 public: 22 public:
23 RemoteMediaStreamTrackObserver( 23 RemoteMediaStreamTrackObserver(
24 webrtc::MediaStreamTrackInterface* webrtc_track, 24 webrtc::MediaStreamTrackInterface* webrtc_track,
25 const WebKit::WebMediaStreamTrack& webkit_track); 25 const blink::WebMediaStreamTrack& webkit_track);
26 virtual ~RemoteMediaStreamTrackObserver(); 26 virtual ~RemoteMediaStreamTrackObserver();
27 27
28 webrtc::MediaStreamTrackInterface* observered_track() { 28 webrtc::MediaStreamTrackInterface* observered_track() {
29 return webrtc_track_.get(); 29 return webrtc_track_.get();
30 } 30 }
31 const WebKit::WebMediaStreamTrack& webkit_track() { return webkit_track_; } 31 const blink::WebMediaStreamTrack& webkit_track() { return webkit_track_; }
32 32
33 private: 33 private:
34 // webrtc::ObserverInterface implementation. 34 // webrtc::ObserverInterface implementation.
35 virtual void OnChanged() OVERRIDE; 35 virtual void OnChanged() OVERRIDE;
36 36
37 webrtc::MediaStreamTrackInterface::TrackState state_; 37 webrtc::MediaStreamTrackInterface::TrackState state_;
38 scoped_refptr<webrtc::MediaStreamTrackInterface> webrtc_track_; 38 scoped_refptr<webrtc::MediaStreamTrackInterface> webrtc_track_;
39 WebKit::WebMediaStreamTrack webkit_track_; 39 blink::WebMediaStreamTrack webkit_track_;
40 40
41 DISALLOW_COPY_AND_ASSIGN(RemoteMediaStreamTrackObserver); 41 DISALLOW_COPY_AND_ASSIGN(RemoteMediaStreamTrackObserver);
42 }; 42 };
43 43
44 } // namespace content 44 } // namespace content
45 45
46 namespace { 46 namespace {
47 47
48 void InitializeWebkitTrack(webrtc::MediaStreamTrackInterface* track, 48 void InitializeWebkitTrack(webrtc::MediaStreamTrackInterface* track,
49 WebKit::WebMediaStreamTrack* webkit_track, 49 blink::WebMediaStreamTrack* webkit_track,
50 WebKit::WebMediaStreamSource::Type type) { 50 blink::WebMediaStreamSource::Type type) {
51 WebKit::WebMediaStreamSource webkit_source; 51 blink::WebMediaStreamSource webkit_source;
52 WebKit::WebString webkit_track_id(UTF8ToUTF16(track->id())); 52 blink::WebString webkit_track_id(UTF8ToUTF16(track->id()));
53 53
54 webkit_source.initialize(webkit_track_id, type, webkit_track_id); 54 webkit_source.initialize(webkit_track_id, type, webkit_track_id);
55 webkit_track->initialize(webkit_track_id, webkit_source); 55 webkit_track->initialize(webkit_track_id, webkit_source);
56 content::MediaStreamDependencyFactory::AddNativeTrackToBlinkTrack(track, 56 content::MediaStreamDependencyFactory::AddNativeTrackToBlinkTrack(track,
57 *webkit_track); 57 *webkit_track);
58 } 58 }
59 59
60 content::RemoteMediaStreamTrackObserver* FindTrackObserver( 60 content::RemoteMediaStreamTrackObserver* FindTrackObserver(
61 webrtc::MediaStreamTrackInterface* track, 61 webrtc::MediaStreamTrackInterface* track,
62 const ScopedVector<content::RemoteMediaStreamTrackObserver>& observers) { 62 const ScopedVector<content::RemoteMediaStreamTrackObserver>& observers) {
63 ScopedVector<content::RemoteMediaStreamTrackObserver>::const_iterator it = 63 ScopedVector<content::RemoteMediaStreamTrackObserver>::const_iterator it =
64 observers.begin(); 64 observers.begin();
65 for (; it != observers.end(); ++it) { 65 for (; it != observers.end(); ++it) {
66 if ((*it)->observered_track() == track) 66 if ((*it)->observered_track() == track)
67 return *it; 67 return *it;
68 } 68 }
69 return NULL; 69 return NULL;
70 } 70 }
71 71
72 } // namespace anonymous 72 } // namespace anonymous
73 73
74 namespace content { 74 namespace content {
75 75
76 RemoteMediaStreamTrackObserver::RemoteMediaStreamTrackObserver( 76 RemoteMediaStreamTrackObserver::RemoteMediaStreamTrackObserver(
77 webrtc::MediaStreamTrackInterface* webrtc_track, 77 webrtc::MediaStreamTrackInterface* webrtc_track,
78 const WebKit::WebMediaStreamTrack& webkit_track) 78 const blink::WebMediaStreamTrack& webkit_track)
79 : state_(webrtc_track->state()), 79 : state_(webrtc_track->state()),
80 webrtc_track_(webrtc_track), 80 webrtc_track_(webrtc_track),
81 webkit_track_(webkit_track) { 81 webkit_track_(webkit_track) {
82 webrtc_track->RegisterObserver(this); 82 webrtc_track->RegisterObserver(this);
83 } 83 }
84 84
85 RemoteMediaStreamTrackObserver::~RemoteMediaStreamTrackObserver() { 85 RemoteMediaStreamTrackObserver::~RemoteMediaStreamTrackObserver() {
86 webrtc_track_->UnregisterObserver(this); 86 webrtc_track_->UnregisterObserver(this);
87 } 87 }
88 88
89 void RemoteMediaStreamTrackObserver::OnChanged() { 89 void RemoteMediaStreamTrackObserver::OnChanged() {
90 DCHECK(CalledOnValidThread()); 90 DCHECK(CalledOnValidThread());
91 91
92 webrtc::MediaStreamTrackInterface::TrackState state = webrtc_track_->state(); 92 webrtc::MediaStreamTrackInterface::TrackState state = webrtc_track_->state();
93 if (state == state_) 93 if (state == state_)
94 return; 94 return;
95 95
96 state_ = state; 96 state_ = state;
97 switch (state) { 97 switch (state) {
98 case webrtc::MediaStreamTrackInterface::kInitializing: 98 case webrtc::MediaStreamTrackInterface::kInitializing:
99 // Ignore the kInitializing state since there is no match in 99 // Ignore the kInitializing state since there is no match in
100 // WebMediaStreamSource::ReadyState. 100 // WebMediaStreamSource::ReadyState.
101 break; 101 break;
102 case webrtc::MediaStreamTrackInterface::kLive: 102 case webrtc::MediaStreamTrackInterface::kLive:
103 webkit_track_.source().setReadyState( 103 webkit_track_.source().setReadyState(
104 WebKit::WebMediaStreamSource::ReadyStateLive); 104 blink::WebMediaStreamSource::ReadyStateLive);
105 break; 105 break;
106 case webrtc::MediaStreamTrackInterface::kEnded: 106 case webrtc::MediaStreamTrackInterface::kEnded:
107 webkit_track_.source().setReadyState( 107 webkit_track_.source().setReadyState(
108 WebKit::WebMediaStreamSource::ReadyStateEnded); 108 blink::WebMediaStreamSource::ReadyStateEnded);
109 break; 109 break;
110 default: 110 default:
111 NOTREACHED(); 111 NOTREACHED();
112 break; 112 break;
113 } 113 }
114 } 114 }
115 115
116 RemoteMediaStreamImpl::RemoteMediaStreamImpl( 116 RemoteMediaStreamImpl::RemoteMediaStreamImpl(
117 webrtc::MediaStreamInterface* webrtc_stream) 117 webrtc::MediaStreamInterface* webrtc_stream)
118 : webrtc_stream_(webrtc_stream) { 118 : webrtc_stream_(webrtc_stream) {
119 webrtc_stream_->RegisterObserver(this); 119 webrtc_stream_->RegisterObserver(this);
120 120
121 webrtc::AudioTrackVector webrtc_audio_tracks = 121 webrtc::AudioTrackVector webrtc_audio_tracks =
122 webrtc_stream_->GetAudioTracks(); 122 webrtc_stream_->GetAudioTracks();
123 WebKit::WebVector<WebKit::WebMediaStreamTrack> webkit_audio_tracks( 123 blink::WebVector<blink::WebMediaStreamTrack> webkit_audio_tracks(
124 webrtc_audio_tracks.size()); 124 webrtc_audio_tracks.size());
125 125
126 // Initialize WebKit audio tracks. 126 // Initialize WebKit audio tracks.
127 size_t i = 0; 127 size_t i = 0;
128 for (; i < webrtc_audio_tracks.size(); ++i) { 128 for (; i < webrtc_audio_tracks.size(); ++i) {
129 webrtc::AudioTrackInterface* audio_track = webrtc_audio_tracks[i]; 129 webrtc::AudioTrackInterface* audio_track = webrtc_audio_tracks[i];
130 DCHECK(audio_track); 130 DCHECK(audio_track);
131 InitializeWebkitTrack(audio_track, &webkit_audio_tracks[i], 131 InitializeWebkitTrack(audio_track, &webkit_audio_tracks[i],
132 WebKit::WebMediaStreamSource::TypeAudio); 132 blink::WebMediaStreamSource::TypeAudio);
133 audio_track_observers_.push_back( 133 audio_track_observers_.push_back(
134 new RemoteMediaStreamTrackObserver(audio_track, 134 new RemoteMediaStreamTrackObserver(audio_track,
135 webkit_audio_tracks[i])); 135 webkit_audio_tracks[i]));
136 } 136 }
137 137
138 // Initialize WebKit video tracks. 138 // Initialize WebKit video tracks.
139 webrtc::VideoTrackVector webrtc_video_tracks = 139 webrtc::VideoTrackVector webrtc_video_tracks =
140 webrtc_stream_->GetVideoTracks(); 140 webrtc_stream_->GetVideoTracks();
141 WebKit::WebVector<WebKit::WebMediaStreamTrack> webkit_video_tracks( 141 blink::WebVector<blink::WebMediaStreamTrack> webkit_video_tracks(
142 webrtc_video_tracks.size()); 142 webrtc_video_tracks.size());
143 for (i = 0; i < webrtc_video_tracks.size(); ++i) { 143 for (i = 0; i < webrtc_video_tracks.size(); ++i) {
144 webrtc::VideoTrackInterface* video_track = webrtc_video_tracks[i]; 144 webrtc::VideoTrackInterface* video_track = webrtc_video_tracks[i];
145 DCHECK(video_track); 145 DCHECK(video_track);
146 InitializeWebkitTrack(video_track, &webkit_video_tracks[i], 146 InitializeWebkitTrack(video_track, &webkit_video_tracks[i],
147 WebKit::WebMediaStreamSource::TypeVideo); 147 blink::WebMediaStreamSource::TypeVideo);
148 video_track_observers_.push_back( 148 video_track_observers_.push_back(
149 new RemoteMediaStreamTrackObserver(video_track, 149 new RemoteMediaStreamTrackObserver(video_track,
150 webkit_video_tracks[i])); 150 webkit_video_tracks[i]));
151 } 151 }
152 152
153 webkit_stream_.initialize(UTF8ToUTF16(webrtc_stream->label()), 153 webkit_stream_.initialize(UTF8ToUTF16(webrtc_stream->label()),
154 webkit_audio_tracks, webkit_video_tracks); 154 webkit_audio_tracks, webkit_video_tracks);
155 webkit_stream_.setExtraData(new MediaStreamExtraData(webrtc_stream, false)); 155 webkit_stream_.setExtraData(new MediaStreamExtraData(webrtc_stream, false));
156 } 156 }
157 157
(...skipping 27 matching lines...) Expand all
185 ++video_it; 185 ++video_it;
186 } 186 }
187 } 187 }
188 188
189 // Find added audio tracks. 189 // Find added audio tracks.
190 webrtc::AudioTrackVector webrtc_audio_tracks = 190 webrtc::AudioTrackVector webrtc_audio_tracks =
191 webrtc_stream_->GetAudioTracks(); 191 webrtc_stream_->GetAudioTracks();
192 for (webrtc::AudioTrackVector::iterator it = webrtc_audio_tracks.begin(); 192 for (webrtc::AudioTrackVector::iterator it = webrtc_audio_tracks.begin();
193 it != webrtc_audio_tracks.end(); ++it) { 193 it != webrtc_audio_tracks.end(); ++it) {
194 if (!FindTrackObserver(*it, audio_track_observers_)) { 194 if (!FindTrackObserver(*it, audio_track_observers_)) {
195 WebKit::WebMediaStreamTrack new_track; 195 blink::WebMediaStreamTrack new_track;
196 InitializeWebkitTrack(*it, &new_track, 196 InitializeWebkitTrack(*it, &new_track,
197 WebKit::WebMediaStreamSource::TypeAudio); 197 blink::WebMediaStreamSource::TypeAudio);
198 audio_track_observers_.push_back( 198 audio_track_observers_.push_back(
199 new RemoteMediaStreamTrackObserver(*it, new_track)); 199 new RemoteMediaStreamTrackObserver(*it, new_track));
200 webkit_stream_.addTrack(new_track); 200 webkit_stream_.addTrack(new_track);
201 } 201 }
202 } 202 }
203 203
204 // Find added video tracks. 204 // Find added video tracks.
205 webrtc::VideoTrackVector webrtc_video_tracks = 205 webrtc::VideoTrackVector webrtc_video_tracks =
206 webrtc_stream_->GetVideoTracks(); 206 webrtc_stream_->GetVideoTracks();
207 for (webrtc::VideoTrackVector::iterator it = webrtc_video_tracks.begin(); 207 for (webrtc::VideoTrackVector::iterator it = webrtc_video_tracks.begin();
208 it != webrtc_video_tracks.end(); ++it) { 208 it != webrtc_video_tracks.end(); ++it) {
209 if (!FindTrackObserver(*it, video_track_observers_)) { 209 if (!FindTrackObserver(*it, video_track_observers_)) {
210 WebKit::WebMediaStreamTrack new_track; 210 blink::WebMediaStreamTrack new_track;
211 InitializeWebkitTrack(*it, &new_track, 211 InitializeWebkitTrack(*it, &new_track,
212 WebKit::WebMediaStreamSource::TypeVideo); 212 blink::WebMediaStreamSource::TypeVideo);
213 video_track_observers_.push_back( 213 video_track_observers_.push_back(
214 new RemoteMediaStreamTrackObserver(*it, new_track)); 214 new RemoteMediaStreamTrackObserver(*it, new_track));
215 webkit_stream_.addTrack(new_track); 215 webkit_stream_.addTrack(new_track);
216 } 216 }
217 } 217 }
218 } 218 }
219 219
220 } // namespace content 220 } // namespace content
OLDNEW
« no previous file with comments | « content/renderer/media/remote_media_stream_impl.h ('k') | content/renderer/media/renderer_webaudiodevice_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698