| OLD | NEW |
|---|
| (Empty) |
| 1 /* | |
| 2 * libjingle | |
| 3 * Copyright 2014 Google Inc. | |
| 4 * | |
| 5 * Redistribution and use in source and binary forms, with or without | |
| 6 * modification, are permitted provided that the following conditions are met: | |
| 7 * | |
| 8 * 1. Redistributions of source code must retain the above copyright notice, | |
| 9 * this list of conditions and the following disclaimer. | |
| 10 * 2. Redistributions in binary form must reproduce the above copyright notice, | |
| 11 * this list of conditions and the following disclaimer in the documentation | |
| 12 * and/or other materials provided with the distribution. | |
| 13 * 3. The name of the author may not be used to endorse or promote products | |
| 14 * derived from this software without specific prior written permission. | |
| 15 * | |
| 16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED | |
| 17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF | |
| 18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO | |
| 19 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
| 20 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, | |
| 21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; | |
| 22 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, | |
| 23 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR | |
| 24 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF | |
| 25 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
| 26 */ | |
| 27 | |
| 28 #ifndef TALK_MEDIA_BASE_VIDEOENGINE_UNITTEST_H_ // NOLINT | |
| 29 #define TALK_MEDIA_BASE_VIDEOENGINE_UNITTEST_H_ | |
| 30 | |
| 31 #include <string> | |
| 32 #include <vector> | |
| 33 | |
| 34 #include "talk/media/base/fakenetworkinterface.h" | |
| 35 #include "talk/media/base/fakevideocapturer.h" | |
| 36 #include "talk/media/base/fakevideorenderer.h" | |
| 37 #include "talk/media/base/mediachannel.h" | |
| 38 #include "talk/media/base/streamparams.h" | |
| 39 #include "talk/media/webrtc/fakewebrtccall.h" | |
| 40 #include "webrtc/base/bytebuffer.h" | |
| 41 #include "webrtc/base/gunit.h" | |
| 42 #include "webrtc/base/timeutils.h" | |
| 43 #include "webrtc/call.h" | |
| 44 | |
| 45 #define EXPECT_FRAME_WAIT(c, w, h, t) \ | |
| 46 EXPECT_EQ_WAIT((c), renderer_.num_rendered_frames(), (t)); \ | |
| 47 EXPECT_EQ((w), renderer_.width()); \ | |
| 48 EXPECT_EQ((h), renderer_.height()); \ | |
| 49 EXPECT_EQ(0, renderer_.errors()); \ | |
| 50 | |
| 51 #define EXPECT_FRAME_ON_RENDERER_WAIT(r, c, w, h, t) \ | |
| 52 EXPECT_EQ_WAIT((c), (r).num_rendered_frames(), (t)); \ | |
| 53 EXPECT_EQ((w), (r).width()); \ | |
| 54 EXPECT_EQ((h), (r).height()); \ | |
| 55 EXPECT_EQ(0, (r).errors()); \ | |
| 56 | |
| 57 #define EXPECT_GT_FRAME_ON_RENDERER_WAIT(r, c, w, h, t) \ | |
| 58 EXPECT_TRUE_WAIT((r).num_rendered_frames() >= (c) && \ | |
| 59 (w) == (r).width() && \ | |
| 60 (h) == (r).height(), (t)); \ | |
| 61 EXPECT_EQ(0, (r).errors()); | |
| 62 | |
| 63 static const uint32_t kTimeout = 5000U; | |
| 64 static const uint32_t kDefaultReceiveSsrc = 0; | |
| 65 static const uint32_t kSsrc = 1234u; | |
| 66 static const uint32_t kRtxSsrc = 4321u; | |
| 67 static const uint32_t kSsrcs4[] = {1, 2, 3, 4}; | |
| 68 | |
| 69 inline bool IsEqualRes(const cricket::VideoCodec& a, int w, int h, int fps) { | |
| 70 return a.width == w && a.height == h && a.framerate == fps; | |
| 71 } | |
| 72 | |
| 73 inline bool IsEqualCodec(const cricket::VideoCodec& a, | |
| 74 const cricket::VideoCodec& b) { | |
| 75 return a.id == b.id && a.name == b.name && | |
| 76 IsEqualRes(a, b.width, b.height, b.framerate); | |
| 77 } | |
| 78 | |
| 79 namespace std { | |
| 80 inline std::ostream& operator<<(std::ostream& s, const cricket::VideoCodec& c) { | |
| 81 s << "{" << c.name << "(" << c.id << "), " | |
| 82 << c.width << "x" << c.height << "x" << c.framerate << "}"; | |
| 83 return s; | |
| 84 } | |
| 85 } // namespace std | |
| 86 | |
| 87 inline int TimeBetweenSend(const cricket::VideoCodec& codec) { | |
| 88 return static_cast<int>( | |
| 89 cricket::VideoFormat::FpsToInterval(codec.framerate) / | |
| 90 rtc::kNumNanosecsPerMillisec); | |
| 91 } | |
| 92 | |
| 93 // Fake video engine that makes it possible to test enabling and disabling | |
| 94 // capturer (checking that the engine state is updated and that the capturer | |
| 95 // is indeed capturing) without having to create a channel. It also makes it | |
| 96 // possible to test that the media processors are indeed being called when | |
| 97 // registered. | |
| 98 template<class T> | |
| 99 class VideoEngineOverride : public T { | |
| 100 public: | |
| 101 VideoEngineOverride() : T() { | |
| 102 } | |
| 103 virtual ~VideoEngineOverride() { | |
| 104 } | |
| 105 bool is_camera_on() const { return T::GetVideoCapturer()->IsRunning(); } | |
| 106 void set_has_senders(bool has_senders) { | |
| 107 cricket::VideoCapturer* video_capturer = T::GetVideoCapturer(); | |
| 108 if (has_senders) { | |
| 109 video_capturer->SignalVideoFrame.connect(this, | |
| 110 &VideoEngineOverride<T>::OnLocalFrame); | |
| 111 } else { | |
| 112 video_capturer->SignalVideoFrame.disconnect(this); | |
| 113 } | |
| 114 } | |
| 115 void OnLocalFrame(cricket::VideoCapturer*, | |
| 116 const cricket::VideoFrame*) { | |
| 117 } | |
| 118 void OnLocalFrameFormat(cricket::VideoCapturer*, | |
| 119 const cricket::VideoFormat*) { | |
| 120 } | |
| 121 | |
| 122 void TriggerMediaFrame(uint32_t ssrc, | |
| 123 cricket::VideoFrame* frame, | |
| 124 bool* drop_frame) { | |
| 125 T::SignalMediaFrame(ssrc, frame, drop_frame); | |
| 126 } | |
| 127 }; | |
| 128 | |
| 129 template<class E, class C> | |
| 130 class VideoMediaChannelTest : public testing::Test, | |
| 131 public sigslot::has_slots<> { | |
| 132 protected: | |
| 133 VideoMediaChannelTest<E, C>() | |
| 134 : call_(webrtc::Call::Create(webrtc::Call::Config())) {} | |
| 135 | |
| 136 virtual cricket::VideoCodec DefaultCodec() = 0; | |
| 137 | |
| 138 virtual cricket::StreamParams DefaultSendStreamParams() { | |
| 139 return cricket::StreamParams::CreateLegacy(kSsrc); | |
| 140 } | |
| 141 | |
| 142 virtual void SetUp() { | |
| 143 cricket::Device device("test", "device"); | |
| 144 engine_.Init(); | |
| 145 channel_.reset( | |
| 146 engine_.CreateChannel(call_.get(), cricket::VideoOptions())); | |
| 147 EXPECT_TRUE(channel_.get() != NULL); | |
| 148 network_interface_.SetDestination(channel_.get()); | |
| 149 channel_->SetInterface(&network_interface_); | |
| 150 media_error_ = cricket::VideoMediaChannel::ERROR_NONE; | |
| 151 cricket::VideoRecvParameters parameters; | |
| 152 parameters.codecs = engine_.codecs(); | |
| 153 channel_->SetRecvParameters(parameters); | |
| 154 EXPECT_TRUE(channel_->AddSendStream(DefaultSendStreamParams())); | |
| 155 video_capturer_.reset(CreateFakeVideoCapturer()); | |
| 156 cricket::VideoFormat format(640, 480, | |
| 157 cricket::VideoFormat::FpsToInterval(30), | |
| 158 cricket::FOURCC_I420); | |
| 159 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_->Start(format)); | |
| 160 EXPECT_TRUE(channel_->SetCapturer(kSsrc, video_capturer_.get())); | |
| 161 } | |
| 162 | |
| 163 virtual cricket::FakeVideoCapturer* CreateFakeVideoCapturer() { | |
| 164 return new cricket::FakeVideoCapturer(); | |
| 165 } | |
| 166 | |
| 167 // Utility method to setup an additional stream to send and receive video. | |
| 168 // Used to test send and recv between two streams. | |
| 169 void SetUpSecondStream() { | |
| 170 SetUpSecondStreamWithNoRecv(); | |
| 171 // Setup recv for second stream. | |
| 172 EXPECT_TRUE(channel_->AddRecvStream( | |
| 173 cricket::StreamParams::CreateLegacy(kSsrc + 2))); | |
| 174 // Make the second renderer available for use by a new stream. | |
| 175 EXPECT_TRUE(channel_->SetSink(kSsrc + 2, &renderer2_)); | |
| 176 } | |
| 177 // Setup an additional stream just to send video. Defer add recv stream. | |
| 178 // This is required if you want to test unsignalled recv of video rtp packets. | |
| 179 void SetUpSecondStreamWithNoRecv() { | |
| 180 // SetUp() already added kSsrc make sure duplicate SSRCs cant be added. | |
| 181 EXPECT_TRUE(channel_->AddRecvStream( | |
| 182 cricket::StreamParams::CreateLegacy(kSsrc))); | |
| 183 EXPECT_TRUE(channel_->SetSink(kSsrc, &renderer_)); | |
| 184 EXPECT_FALSE(channel_->AddSendStream( | |
| 185 cricket::StreamParams::CreateLegacy(kSsrc))); | |
| 186 EXPECT_TRUE(channel_->AddSendStream( | |
| 187 cricket::StreamParams::CreateLegacy(kSsrc + 2))); | |
| 188 // We dont add recv for the second stream. | |
| 189 | |
| 190 // Setup the receive and renderer for second stream after send. | |
| 191 video_capturer_2_.reset(CreateFakeVideoCapturer()); | |
| 192 cricket::VideoFormat format(640, 480, | |
| 193 cricket::VideoFormat::FpsToInterval(30), | |
| 194 cricket::FOURCC_I420); | |
| 195 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_2_->Start(format)); | |
| 196 | |
| 197 EXPECT_TRUE(channel_->SetCapturer(kSsrc + 2, video_capturer_2_.get())); | |
| 198 } | |
| 199 virtual void TearDown() { | |
| 200 channel_.reset(); | |
| 201 } | |
| 202 bool SetDefaultCodec() { | |
| 203 return SetOneCodec(DefaultCodec()); | |
| 204 } | |
| 205 | |
| 206 bool SetOneCodec(int pt, const char* name, int w, int h, int fr) { | |
| 207 return SetOneCodec(cricket::VideoCodec(pt, name, w, h, fr, 0)); | |
| 208 } | |
| 209 bool SetOneCodec(const cricket::VideoCodec& codec) { | |
| 210 cricket::VideoFormat capture_format(codec.width, codec.height, | |
| 211 cricket::VideoFormat::FpsToInterval(codec.framerate), | |
| 212 cricket::FOURCC_I420); | |
| 213 | |
| 214 if (video_capturer_) { | |
| 215 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_->Start(capture_format)); | |
| 216 } | |
| 217 if (video_capturer_2_) { | |
| 218 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_2_->Start(capture_format)); | |
| 219 } | |
| 220 | |
| 221 bool sending = channel_->sending(); | |
| 222 bool success = SetSend(false); | |
| 223 if (success) { | |
| 224 cricket::VideoSendParameters parameters; | |
| 225 parameters.codecs.push_back(codec); | |
| 226 success = channel_->SetSendParameters(parameters); | |
| 227 } | |
| 228 if (success) { | |
| 229 success = SetSend(sending); | |
| 230 } | |
| 231 return success; | |
| 232 } | |
| 233 bool SetSend(bool send) { | |
| 234 return channel_->SetSend(send); | |
| 235 } | |
| 236 int DrainOutgoingPackets() { | |
| 237 int packets = 0; | |
| 238 do { | |
| 239 packets = NumRtpPackets(); | |
| 240 // 100 ms should be long enough. | |
| 241 rtc::Thread::Current()->ProcessMessages(100); | |
| 242 } while (NumRtpPackets() > packets); | |
| 243 return NumRtpPackets(); | |
| 244 } | |
| 245 bool SendFrame() { | |
| 246 if (video_capturer_2_) { | |
| 247 video_capturer_2_->CaptureFrame(); | |
| 248 } | |
| 249 return video_capturer_.get() && | |
| 250 video_capturer_->CaptureFrame(); | |
| 251 } | |
| 252 bool WaitAndSendFrame(int wait_ms) { | |
| 253 bool ret = rtc::Thread::Current()->ProcessMessages(wait_ms); | |
| 254 ret &= SendFrame(); | |
| 255 return ret; | |
| 256 } | |
| 257 // Sends frames and waits for the decoder to be fully initialized. | |
| 258 // Returns the number of frames that were sent. | |
| 259 int WaitForDecoder() { | |
| 260 #if defined(HAVE_OPENMAX) | |
| 261 // Send enough frames for the OpenMAX decoder to continue processing, and | |
| 262 // return the number of frames sent. | |
| 263 // Send frames for a full kTimeout's worth of 15fps video. | |
| 264 int frame_count = 0; | |
| 265 while (frame_count < static_cast<int>(kTimeout) / 66) { | |
| 266 EXPECT_TRUE(WaitAndSendFrame(66)); | |
| 267 ++frame_count; | |
| 268 } | |
| 269 return frame_count; | |
| 270 #else | |
| 271 return 0; | |
| 272 #endif | |
| 273 } | |
| 274 bool SendCustomVideoFrame(int w, int h) { | |
| 275 if (!video_capturer_.get()) return false; | |
| 276 return video_capturer_->CaptureCustomFrame(w, h, cricket::FOURCC_I420); | |
| 277 } | |
| 278 int NumRtpBytes() { | |
| 279 return network_interface_.NumRtpBytes(); | |
| 280 } | |
| 281 int NumRtpBytes(uint32_t ssrc) { | |
| 282 return network_interface_.NumRtpBytes(ssrc); | |
| 283 } | |
| 284 int NumRtpPackets() { | |
| 285 return network_interface_.NumRtpPackets(); | |
| 286 } | |
| 287 int NumRtpPackets(uint32_t ssrc) { | |
| 288 return network_interface_.NumRtpPackets(ssrc); | |
| 289 } | |
| 290 int NumSentSsrcs() { | |
| 291 return network_interface_.NumSentSsrcs(); | |
| 292 } | |
| 293 const rtc::Buffer* GetRtpPacket(int index) { | |
| 294 return network_interface_.GetRtpPacket(index); | |
| 295 } | |
| 296 int NumRtcpPackets() { | |
| 297 return network_interface_.NumRtcpPackets(); | |
| 298 } | |
| 299 const rtc::Buffer* GetRtcpPacket(int index) { | |
| 300 return network_interface_.GetRtcpPacket(index); | |
| 301 } | |
| 302 static int GetPayloadType(const rtc::Buffer* p) { | |
| 303 int pt = -1; | |
| 304 ParseRtpPacket(p, NULL, &pt, NULL, NULL, NULL, NULL); | |
| 305 return pt; | |
| 306 } | |
| 307 static bool ParseRtpPacket(const rtc::Buffer* p, | |
| 308 bool* x, | |
| 309 int* pt, | |
| 310 int* seqnum, | |
| 311 uint32_t* tstamp, | |
| 312 uint32_t* ssrc, | |
| 313 std::string* payload) { | |
| 314 rtc::ByteBuffer buf(*p); | |
| 315 uint8_t u08 = 0; | |
| 316 uint16_t u16 = 0; | |
| 317 uint32_t u32 = 0; | |
| 318 | |
| 319 // Read X and CC fields. | |
| 320 if (!buf.ReadUInt8(&u08)) return false; | |
| 321 bool extension = ((u08 & 0x10) != 0); | |
| 322 uint8_t cc = (u08 & 0x0F); | |
| 323 if (x) *x = extension; | |
| 324 | |
| 325 // Read PT field. | |
| 326 if (!buf.ReadUInt8(&u08)) return false; | |
| 327 if (pt) *pt = (u08 & 0x7F); | |
| 328 | |
| 329 // Read Sequence Number field. | |
| 330 if (!buf.ReadUInt16(&u16)) return false; | |
| 331 if (seqnum) *seqnum = u16; | |
| 332 | |
| 333 // Read Timestamp field. | |
| 334 if (!buf.ReadUInt32(&u32)) return false; | |
| 335 if (tstamp) *tstamp = u32; | |
| 336 | |
| 337 // Read SSRC field. | |
| 338 if (!buf.ReadUInt32(&u32)) return false; | |
| 339 if (ssrc) *ssrc = u32; | |
| 340 | |
| 341 // Skip CSRCs. | |
| 342 for (uint8_t i = 0; i < cc; ++i) { | |
| 343 if (!buf.ReadUInt32(&u32)) return false; | |
| 344 } | |
| 345 | |
| 346 // Skip extension header. | |
| 347 if (extension) { | |
| 348 // Read Profile-specific extension header ID | |
| 349 if (!buf.ReadUInt16(&u16)) return false; | |
| 350 | |
| 351 // Read Extension header length | |
| 352 if (!buf.ReadUInt16(&u16)) return false; | |
| 353 uint16_t ext_header_len = u16; | |
| 354 | |
| 355 // Read Extension header | |
| 356 for (uint16_t i = 0; i < ext_header_len; ++i) { | |
| 357 if (!buf.ReadUInt32(&u32)) return false; | |
| 358 } | |
| 359 } | |
| 360 | |
| 361 if (payload) { | |
| 362 return buf.ReadString(payload, buf.Length()); | |
| 363 } | |
| 364 return true; | |
| 365 } | |
| 366 | |
| 367 // Parse all RTCP packet, from start_index to stop_index, and count how many | |
| 368 // FIR (PT=206 and FMT=4 according to RFC 5104). If successful, set the count | |
| 369 // and return true. | |
| 370 bool CountRtcpFir(int start_index, int stop_index, int* fir_count) { | |
| 371 int count = 0; | |
| 372 for (int i = start_index; i < stop_index; ++i) { | |
| 373 rtc::scoped_ptr<const rtc::Buffer> p(GetRtcpPacket(i)); | |
| 374 rtc::ByteBuffer buf(*p); | |
| 375 size_t total_len = 0; | |
| 376 // The packet may be a compound RTCP packet. | |
| 377 while (total_len < p->size()) { | |
| 378 // Read FMT, type and length. | |
| 379 uint8_t fmt = 0; | |
| 380 uint8_t type = 0; | |
| 381 uint16_t length = 0; | |
| 382 if (!buf.ReadUInt8(&fmt)) return false; | |
| 383 fmt &= 0x1F; | |
| 384 if (!buf.ReadUInt8(&type)) return false; | |
| 385 if (!buf.ReadUInt16(&length)) return false; | |
| 386 buf.Consume(length * 4); // Skip RTCP data. | |
| 387 total_len += (length + 1) * 4; | |
| 388 if ((192 == type) || ((206 == type) && (4 == fmt))) { | |
| 389 ++count; | |
| 390 } | |
| 391 } | |
| 392 } | |
| 393 | |
| 394 if (fir_count) { | |
| 395 *fir_count = count; | |
| 396 } | |
| 397 return true; | |
| 398 } | |
| 399 | |
| 400 void OnVideoChannelError(uint32_t ssrc, | |
| 401 cricket::VideoMediaChannel::Error error) { | |
| 402 media_error_ = error; | |
| 403 } | |
| 404 | |
| 405 // Test that SetSend works. | |
| 406 void SetSend() { | |
| 407 EXPECT_FALSE(channel_->sending()); | |
| 408 EXPECT_TRUE(channel_->SetCapturer(kSsrc, video_capturer_.get())); | |
| 409 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 410 EXPECT_FALSE(channel_->sending()); | |
| 411 EXPECT_TRUE(SetSend(true)); | |
| 412 EXPECT_TRUE(channel_->sending()); | |
| 413 EXPECT_TRUE(SendFrame()); | |
| 414 EXPECT_TRUE_WAIT(NumRtpPackets() > 0, kTimeout); | |
| 415 EXPECT_TRUE(SetSend(false)); | |
| 416 EXPECT_FALSE(channel_->sending()); | |
| 417 } | |
| 418 // Test that SetSend fails without codecs being set. | |
| 419 void SetSendWithoutCodecs() { | |
| 420 EXPECT_FALSE(channel_->sending()); | |
| 421 EXPECT_FALSE(SetSend(true)); | |
| 422 EXPECT_FALSE(channel_->sending()); | |
| 423 } | |
| 424 // Test that we properly set the send and recv buffer sizes by the time | |
| 425 // SetSend is called. | |
| 426 void SetSendSetsTransportBufferSizes() { | |
| 427 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 428 EXPECT_TRUE(SetSend(true)); | |
| 429 EXPECT_EQ(64 * 1024, network_interface_.sendbuf_size()); | |
| 430 EXPECT_EQ(64 * 1024, network_interface_.recvbuf_size()); | |
| 431 } | |
| 432 // Tests that we can send frames and the right payload type is used. | |
| 433 void Send(const cricket::VideoCodec& codec) { | |
| 434 EXPECT_TRUE(SetOneCodec(codec)); | |
| 435 EXPECT_TRUE(SetSend(true)); | |
| 436 EXPECT_TRUE(SendFrame()); | |
| 437 EXPECT_TRUE_WAIT(NumRtpPackets() > 0, kTimeout); | |
| 438 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 439 EXPECT_EQ(codec.id, GetPayloadType(p.get())); | |
| 440 } | |
| 441 // Tests that we can send and receive frames. | |
| 442 void SendAndReceive(const cricket::VideoCodec& codec) { | |
| 443 EXPECT_TRUE(SetOneCodec(codec)); | |
| 444 EXPECT_TRUE(SetSend(true)); | |
| 445 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 446 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 447 EXPECT_TRUE(SendFrame()); | |
| 448 EXPECT_FRAME_WAIT(1, codec.width, codec.height, kTimeout); | |
| 449 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 450 EXPECT_EQ(codec.id, GetPayloadType(p.get())); | |
| 451 } | |
| 452 void SendReceiveManyAndGetStats(const cricket::VideoCodec& codec, | |
| 453 int duration_sec, int fps) { | |
| 454 EXPECT_TRUE(SetOneCodec(codec)); | |
| 455 EXPECT_TRUE(SetSend(true)); | |
| 456 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 457 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 458 for (int i = 0; i < duration_sec; ++i) { | |
| 459 for (int frame = 1; frame <= fps; ++frame) { | |
| 460 EXPECT_TRUE(WaitAndSendFrame(1000 / fps)); | |
| 461 EXPECT_FRAME_WAIT(frame + i * fps, codec.width, codec.height, kTimeout); | |
| 462 } | |
| 463 } | |
| 464 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 465 EXPECT_EQ(codec.id, GetPayloadType(p.get())); | |
| 466 } | |
| 467 | |
| 468 // Test that stats work properly for a 1-1 call. | |
| 469 void GetStats() { | |
| 470 const int kDurationSec = 3; | |
| 471 const int kFps = 10; | |
| 472 SendReceiveManyAndGetStats(DefaultCodec(), kDurationSec, kFps); | |
| 473 | |
| 474 cricket::VideoMediaInfo info; | |
| 475 EXPECT_TRUE(channel_->GetStats(&info)); | |
| 476 | |
| 477 ASSERT_EQ(1U, info.senders.size()); | |
| 478 // TODO(whyuan): bytes_sent and bytes_rcvd are different. Are both payload? | |
| 479 // For webrtc, bytes_sent does not include the RTP header length. | |
| 480 EXPECT_GT(info.senders[0].bytes_sent, 0); | |
| 481 EXPECT_EQ(NumRtpPackets(), info.senders[0].packets_sent); | |
| 482 EXPECT_EQ(0.0, info.senders[0].fraction_lost); | |
| 483 EXPECT_EQ(0, info.senders[0].firs_rcvd); | |
| 484 EXPECT_EQ(0, info.senders[0].plis_rcvd); | |
| 485 EXPECT_EQ(0, info.senders[0].nacks_rcvd); | |
| 486 EXPECT_EQ(DefaultCodec().width, info.senders[0].send_frame_width); | |
| 487 EXPECT_EQ(DefaultCodec().height, info.senders[0].send_frame_height); | |
| 488 EXPECT_GT(info.senders[0].framerate_input, 0); | |
| 489 EXPECT_GT(info.senders[0].framerate_sent, 0); | |
| 490 | |
| 491 ASSERT_EQ(1U, info.receivers.size()); | |
| 492 EXPECT_EQ(1U, info.senders[0].ssrcs().size()); | |
| 493 EXPECT_EQ(1U, info.receivers[0].ssrcs().size()); | |
| 494 EXPECT_EQ(info.senders[0].ssrcs()[0], info.receivers[0].ssrcs()[0]); | |
| 495 EXPECT_EQ(NumRtpBytes(), info.receivers[0].bytes_rcvd); | |
| 496 EXPECT_EQ(NumRtpPackets(), info.receivers[0].packets_rcvd); | |
| 497 EXPECT_EQ(0.0, info.receivers[0].fraction_lost); | |
| 498 EXPECT_EQ(0, info.receivers[0].packets_lost); | |
| 499 // TODO(asapersson): Not set for webrtc. Handle missing stats. | |
| 500 // EXPECT_EQ(0, info.receivers[0].packets_concealed); | |
| 501 EXPECT_EQ(0, info.receivers[0].firs_sent); | |
| 502 EXPECT_EQ(0, info.receivers[0].plis_sent); | |
| 503 EXPECT_EQ(0, info.receivers[0].nacks_sent); | |
| 504 EXPECT_EQ(DefaultCodec().width, info.receivers[0].frame_width); | |
| 505 EXPECT_EQ(DefaultCodec().height, info.receivers[0].frame_height); | |
| 506 EXPECT_GT(info.receivers[0].framerate_rcvd, 0); | |
| 507 EXPECT_GT(info.receivers[0].framerate_decoded, 0); | |
| 508 EXPECT_GT(info.receivers[0].framerate_output, 0); | |
| 509 } | |
| 510 | |
| 511 cricket::VideoSenderInfo GetSenderStats(size_t i) { | |
| 512 cricket::VideoMediaInfo info; | |
| 513 EXPECT_TRUE(channel_->GetStats(&info)); | |
| 514 return info.senders[i]; | |
| 515 } | |
| 516 | |
| 517 cricket::VideoReceiverInfo GetReceiverStats(size_t i) { | |
| 518 cricket::VideoMediaInfo info; | |
| 519 EXPECT_TRUE(channel_->GetStats(&info)); | |
| 520 return info.receivers[i]; | |
| 521 } | |
| 522 | |
| 523 // Test that stats work properly for a conf call with multiple recv streams. | |
| 524 void GetStatsMultipleRecvStreams() { | |
| 525 cricket::FakeVideoRenderer renderer1, renderer2; | |
| 526 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 527 cricket::VideoSendParameters parameters; | |
| 528 parameters.codecs.push_back(DefaultCodec()); | |
| 529 parameters.options.conference_mode = rtc::Optional<bool>(true); | |
| 530 EXPECT_TRUE(channel_->SetSendParameters(parameters)); | |
| 531 EXPECT_TRUE(SetSend(true)); | |
| 532 EXPECT_TRUE(channel_->AddRecvStream( | |
| 533 cricket::StreamParams::CreateLegacy(1))); | |
| 534 EXPECT_TRUE(channel_->AddRecvStream( | |
| 535 cricket::StreamParams::CreateLegacy(2))); | |
| 536 EXPECT_TRUE(channel_->SetSink(1, &renderer1)); | |
| 537 EXPECT_TRUE(channel_->SetSink(2, &renderer2)); | |
| 538 EXPECT_EQ(0, renderer1.num_rendered_frames()); | |
| 539 EXPECT_EQ(0, renderer2.num_rendered_frames()); | |
| 540 std::vector<uint32_t> ssrcs; | |
| 541 ssrcs.push_back(1); | |
| 542 ssrcs.push_back(2); | |
| 543 network_interface_.SetConferenceMode(true, ssrcs); | |
| 544 EXPECT_TRUE(SendFrame()); | |
| 545 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 546 renderer1, 1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 547 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 548 renderer2, 1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 549 | |
| 550 EXPECT_TRUE(channel_->SetSend(false)); | |
| 551 | |
| 552 cricket::VideoMediaInfo info; | |
| 553 EXPECT_TRUE(channel_->GetStats(&info)); | |
| 554 ASSERT_EQ(1U, info.senders.size()); | |
| 555 // TODO(whyuan): bytes_sent and bytes_rcvd are different. Are both payload? | |
| 556 // For webrtc, bytes_sent does not include the RTP header length. | |
| 557 EXPECT_GT(GetSenderStats(0).bytes_sent, 0); | |
| 558 EXPECT_EQ_WAIT(NumRtpPackets(), GetSenderStats(0).packets_sent, kTimeout); | |
| 559 EXPECT_EQ(DefaultCodec().width, GetSenderStats(0).send_frame_width); | |
| 560 EXPECT_EQ(DefaultCodec().height, GetSenderStats(0).send_frame_height); | |
| 561 | |
| 562 ASSERT_EQ(2U, info.receivers.size()); | |
| 563 for (size_t i = 0; i < info.receivers.size(); ++i) { | |
| 564 EXPECT_EQ(1U, GetReceiverStats(i).ssrcs().size()); | |
| 565 EXPECT_EQ(i + 1, GetReceiverStats(i).ssrcs()[0]); | |
| 566 EXPECT_EQ_WAIT(NumRtpBytes(), GetReceiverStats(i).bytes_rcvd, kTimeout); | |
| 567 EXPECT_EQ_WAIT(NumRtpPackets(), GetReceiverStats(i).packets_rcvd, | |
| 568 kTimeout); | |
| 569 EXPECT_EQ(DefaultCodec().width, GetReceiverStats(i).frame_width); | |
| 570 EXPECT_EQ(DefaultCodec().height, GetReceiverStats(i).frame_height); | |
| 571 } | |
| 572 } | |
| 573 // Test that stats work properly for a conf call with multiple send streams. | |
| 574 void GetStatsMultipleSendStreams() { | |
| 575 // Normal setup; note that we set the SSRC explicitly to ensure that | |
| 576 // it will come first in the senders map. | |
| 577 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 578 cricket::VideoSendParameters parameters; | |
| 579 parameters.codecs.push_back(DefaultCodec()); | |
| 580 parameters.options.conference_mode = rtc::Optional<bool>(true); | |
| 581 EXPECT_TRUE(channel_->SetSendParameters(parameters)); | |
| 582 EXPECT_TRUE(channel_->AddRecvStream( | |
| 583 cricket::StreamParams::CreateLegacy(kSsrc))); | |
| 584 EXPECT_TRUE(channel_->SetSink(kSsrc, &renderer_)); | |
| 585 EXPECT_TRUE(SetSend(true)); | |
| 586 EXPECT_TRUE(SendFrame()); | |
| 587 EXPECT_TRUE_WAIT(NumRtpPackets() > 0, kTimeout); | |
| 588 EXPECT_FRAME_WAIT(1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 589 | |
| 590 // Add an additional capturer, and hook up a renderer to receive it. | |
| 591 cricket::FakeVideoRenderer renderer2; | |
| 592 rtc::scoped_ptr<cricket::FakeVideoCapturer> capturer( | |
| 593 CreateFakeVideoCapturer()); | |
| 594 capturer->SetScreencast(true); | |
| 595 const int kTestWidth = 160; | |
| 596 const int kTestHeight = 120; | |
| 597 cricket::VideoFormat format(kTestWidth, kTestHeight, | |
| 598 cricket::VideoFormat::FpsToInterval(5), | |
| 599 cricket::FOURCC_I420); | |
| 600 EXPECT_EQ(cricket::CS_RUNNING, capturer->Start(format)); | |
| 601 EXPECT_TRUE(channel_->AddSendStream( | |
| 602 cricket::StreamParams::CreateLegacy(5678))); | |
| 603 EXPECT_TRUE(channel_->SetCapturer(5678, capturer.get())); | |
| 604 EXPECT_TRUE(channel_->AddRecvStream( | |
| 605 cricket::StreamParams::CreateLegacy(5678))); | |
| 606 EXPECT_TRUE(channel_->SetSink(5678, &renderer2)); | |
| 607 EXPECT_TRUE(capturer->CaptureCustomFrame( | |
| 608 kTestWidth, kTestHeight, cricket::FOURCC_I420)); | |
| 609 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 610 renderer2, 1, kTestWidth, kTestHeight, kTimeout); | |
| 611 | |
| 612 // Get stats, and make sure they are correct for two senders. We wait until | |
| 613 // the number of expected packets have been sent to avoid races where we | |
| 614 // check stats before it has been updated. | |
| 615 cricket::VideoMediaInfo info; | |
| 616 for (uint32_t i = 0; i < kTimeout; ++i) { | |
| 617 rtc::Thread::Current()->ProcessMessages(1); | |
| 618 EXPECT_TRUE(channel_->GetStats(&info)); | |
| 619 ASSERT_EQ(2U, info.senders.size()); | |
| 620 if (info.senders[0].packets_sent + info.senders[1].packets_sent == | |
| 621 NumRtpPackets()) { | |
| 622 // Stats have been updated for both sent frames, expectations can be | |
| 623 // checked now. | |
| 624 break; | |
| 625 } | |
| 626 } | |
| 627 EXPECT_EQ(NumRtpPackets(), | |
| 628 info.senders[0].packets_sent + info.senders[1].packets_sent) | |
| 629 << "Timed out while waiting for packet counts for all sent packets."; | |
| 630 EXPECT_EQ(1U, info.senders[0].ssrcs().size()); | |
| 631 EXPECT_EQ(1234U, info.senders[0].ssrcs()[0]); | |
| 632 EXPECT_EQ(DefaultCodec().width, info.senders[0].send_frame_width); | |
| 633 EXPECT_EQ(DefaultCodec().height, info.senders[0].send_frame_height); | |
| 634 EXPECT_EQ(1U, info.senders[1].ssrcs().size()); | |
| 635 EXPECT_EQ(5678U, info.senders[1].ssrcs()[0]); | |
| 636 EXPECT_EQ(kTestWidth, info.senders[1].send_frame_width); | |
| 637 EXPECT_EQ(kTestHeight, info.senders[1].send_frame_height); | |
| 638 // The capturer must be unregistered here as it runs out of it's scope next. | |
| 639 EXPECT_TRUE(channel_->SetCapturer(5678, NULL)); | |
| 640 } | |
| 641 | |
| 642 // Test that we can set the bandwidth. | |
| 643 void SetSendBandwidth() { | |
| 644 cricket::VideoSendParameters parameters; | |
| 645 parameters.codecs.push_back(DefaultCodec()); | |
| 646 parameters.max_bandwidth_bps = -1; // <= 0 means unlimited. | |
| 647 EXPECT_TRUE(channel_->SetSendParameters(parameters)); | |
| 648 parameters.max_bandwidth_bps = 128 * 1024; | |
| 649 EXPECT_TRUE(channel_->SetSendParameters(parameters)); | |
| 650 } | |
| 651 // Test that we can set the SSRC for the default send source. | |
| 652 void SetSendSsrc() { | |
| 653 EXPECT_TRUE(SetDefaultCodec()); | |
| 654 EXPECT_TRUE(SetSend(true)); | |
| 655 EXPECT_TRUE(SendFrame()); | |
| 656 EXPECT_TRUE_WAIT(NumRtpPackets() > 0, kTimeout); | |
| 657 uint32_t ssrc = 0; | |
| 658 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 659 ParseRtpPacket(p.get(), NULL, NULL, NULL, NULL, &ssrc, NULL); | |
| 660 EXPECT_EQ(kSsrc, ssrc); | |
| 661 // Packets are being paced out, so these can mismatch between the first and | |
| 662 // second call to NumRtpPackets until pending packets are paced out. | |
| 663 EXPECT_EQ_WAIT(NumRtpPackets(), NumRtpPackets(ssrc), kTimeout); | |
| 664 EXPECT_EQ_WAIT(NumRtpBytes(), NumRtpBytes(ssrc), kTimeout); | |
| 665 EXPECT_EQ(1, NumSentSsrcs()); | |
| 666 EXPECT_EQ(0, NumRtpPackets(kSsrc - 1)); | |
| 667 EXPECT_EQ(0, NumRtpBytes(kSsrc - 1)); | |
| 668 } | |
| 669 // Test that we can set the SSRC even after codecs are set. | |
| 670 void SetSendSsrcAfterSetCodecs() { | |
| 671 // Remove stream added in Setup. | |
| 672 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc)); | |
| 673 EXPECT_TRUE(SetDefaultCodec()); | |
| 674 EXPECT_TRUE(channel_->AddSendStream( | |
| 675 cricket::StreamParams::CreateLegacy(999))); | |
| 676 EXPECT_TRUE(channel_->SetCapturer(999u, video_capturer_.get())); | |
| 677 EXPECT_TRUE(SetSend(true)); | |
| 678 EXPECT_TRUE(WaitAndSendFrame(0)); | |
| 679 EXPECT_TRUE_WAIT(NumRtpPackets() > 0, kTimeout); | |
| 680 uint32_t ssrc = 0; | |
| 681 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 682 ParseRtpPacket(p.get(), NULL, NULL, NULL, NULL, &ssrc, NULL); | |
| 683 EXPECT_EQ(999u, ssrc); | |
| 684 // Packets are being paced out, so these can mismatch between the first and | |
| 685 // second call to NumRtpPackets until pending packets are paced out. | |
| 686 EXPECT_EQ_WAIT(NumRtpPackets(), NumRtpPackets(ssrc), kTimeout); | |
| 687 EXPECT_EQ_WAIT(NumRtpBytes(), NumRtpBytes(ssrc), kTimeout); | |
| 688 EXPECT_EQ(1, NumSentSsrcs()); | |
| 689 EXPECT_EQ(0, NumRtpPackets(kSsrc)); | |
| 690 EXPECT_EQ(0, NumRtpBytes(kSsrc)); | |
| 691 } | |
| 692 // Test that we can set the default video renderer before and after | |
| 693 // media is received. | |
| 694 void SetSink() { | |
| 695 uint8_t data1[] = { | |
| 696 0x80, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00}; | |
| 697 | |
| 698 rtc::Buffer packet1(data1, sizeof(data1)); | |
| 699 rtc::SetBE32(packet1.data() + 8, kSsrc); | |
| 700 channel_->SetSink(kDefaultReceiveSsrc, NULL); | |
| 701 EXPECT_TRUE(SetDefaultCodec()); | |
| 702 EXPECT_TRUE(SetSend(true)); | |
| 703 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 704 channel_->OnPacketReceived(&packet1, rtc::PacketTime()); | |
| 705 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 706 EXPECT_TRUE(SendFrame()); | |
| 707 EXPECT_FRAME_WAIT(1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 708 } | |
| 709 | |
| 710 // Tests empty StreamParams is rejected. | |
| 711 void RejectEmptyStreamParams() { | |
| 712 // Remove the send stream that was added during Setup. | |
| 713 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc)); | |
| 714 | |
| 715 cricket::StreamParams empty; | |
| 716 EXPECT_FALSE(channel_->AddSendStream(empty)); | |
| 717 EXPECT_TRUE(channel_->AddSendStream( | |
| 718 cricket::StreamParams::CreateLegacy(789u))); | |
| 719 } | |
| 720 | |
| 721 // Tests setting up and configuring a send stream. | |
| 722 void AddRemoveSendStreams() { | |
| 723 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 724 EXPECT_TRUE(SetSend(true)); | |
| 725 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 726 EXPECT_TRUE(SendFrame()); | |
| 727 EXPECT_FRAME_WAIT(1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 728 EXPECT_GT(NumRtpPackets(), 0); | |
| 729 uint32_t ssrc = 0; | |
| 730 size_t last_packet = NumRtpPackets() - 1; | |
| 731 rtc::scoped_ptr<const rtc::Buffer> | |
| 732 p(GetRtpPacket(static_cast<int>(last_packet))); | |
| 733 ParseRtpPacket(p.get(), NULL, NULL, NULL, NULL, &ssrc, NULL); | |
| 734 EXPECT_EQ(kSsrc, ssrc); | |
| 735 | |
| 736 // Remove the send stream that was added during Setup. | |
| 737 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc)); | |
| 738 int rtp_packets = NumRtpPackets(); | |
| 739 | |
| 740 EXPECT_TRUE(channel_->AddSendStream( | |
| 741 cricket::StreamParams::CreateLegacy(789u))); | |
| 742 EXPECT_TRUE(channel_->SetCapturer(789u, video_capturer_.get())); | |
| 743 EXPECT_EQ(rtp_packets, NumRtpPackets()); | |
| 744 // Wait 30ms to guarantee the engine does not drop the frame. | |
| 745 EXPECT_TRUE(WaitAndSendFrame(30)); | |
| 746 EXPECT_TRUE_WAIT(NumRtpPackets() > rtp_packets, kTimeout); | |
| 747 | |
| 748 last_packet = NumRtpPackets() - 1; | |
| 749 p.reset(GetRtpPacket(static_cast<int>(last_packet))); | |
| 750 ParseRtpPacket(p.get(), NULL, NULL, NULL, NULL, &ssrc, NULL); | |
| 751 EXPECT_EQ(789u, ssrc); | |
| 752 } | |
| 753 | |
| 754 // Tests the behavior of incoming streams in a conference scenario. | |
| 755 void SimulateConference() { | |
| 756 cricket::FakeVideoRenderer renderer1, renderer2; | |
| 757 EXPECT_TRUE(SetDefaultCodec()); | |
| 758 cricket::VideoSendParameters parameters; | |
| 759 parameters.codecs.push_back(DefaultCodec()); | |
| 760 parameters.options.conference_mode = rtc::Optional<bool>(true); | |
| 761 EXPECT_TRUE(channel_->SetSendParameters(parameters)); | |
| 762 EXPECT_TRUE(SetSend(true)); | |
| 763 EXPECT_TRUE(channel_->AddRecvStream( | |
| 764 cricket::StreamParams::CreateLegacy(1))); | |
| 765 EXPECT_TRUE(channel_->AddRecvStream( | |
| 766 cricket::StreamParams::CreateLegacy(2))); | |
| 767 EXPECT_TRUE(channel_->SetSink(1, &renderer1)); | |
| 768 EXPECT_TRUE(channel_->SetSink(2, &renderer2)); | |
| 769 EXPECT_EQ(0, renderer1.num_rendered_frames()); | |
| 770 EXPECT_EQ(0, renderer2.num_rendered_frames()); | |
| 771 std::vector<uint32_t> ssrcs; | |
| 772 ssrcs.push_back(1); | |
| 773 ssrcs.push_back(2); | |
| 774 network_interface_.SetConferenceMode(true, ssrcs); | |
| 775 EXPECT_TRUE(SendFrame()); | |
| 776 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 777 renderer1, 1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 778 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 779 renderer2, 1, DefaultCodec().width, DefaultCodec().height, kTimeout); | |
| 780 | |
| 781 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 782 EXPECT_EQ(DefaultCodec().id, GetPayloadType(p.get())); | |
| 783 EXPECT_EQ(DefaultCodec().width, renderer1.width()); | |
| 784 EXPECT_EQ(DefaultCodec().height, renderer1.height()); | |
| 785 EXPECT_EQ(DefaultCodec().width, renderer2.width()); | |
| 786 EXPECT_EQ(DefaultCodec().height, renderer2.height()); | |
| 787 EXPECT_TRUE(channel_->RemoveRecvStream(2)); | |
| 788 EXPECT_TRUE(channel_->RemoveRecvStream(1)); | |
| 789 } | |
| 790 | |
| 791 // Tests that we can add and remove capturers and frames are sent out properly | |
| 792 void AddRemoveCapturer() { | |
| 793 cricket::VideoCodec codec = DefaultCodec(); | |
| 794 codec.width = 320; | |
| 795 codec.height = 240; | |
| 796 const int time_between_send = TimeBetweenSend(codec); | |
| 797 EXPECT_TRUE(SetOneCodec(codec)); | |
| 798 EXPECT_TRUE(SetSend(true)); | |
| 799 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 800 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 801 EXPECT_TRUE(SendFrame()); | |
| 802 EXPECT_FRAME_WAIT(1, codec.width, codec.height, kTimeout); | |
| 803 rtc::scoped_ptr<cricket::FakeVideoCapturer> capturer( | |
| 804 CreateFakeVideoCapturer()); | |
| 805 capturer->SetScreencast(true); | |
| 806 cricket::VideoFormat format(480, 360, | |
| 807 cricket::VideoFormat::FpsToInterval(30), | |
| 808 cricket::FOURCC_I420); | |
| 809 EXPECT_EQ(cricket::CS_RUNNING, capturer->Start(format)); | |
| 810 // All capturers start generating frames with the same timestamp. ViE does | |
| 811 // not allow the same timestamp to be used. Capture one frame before | |
| 812 // associating the capturer with the channel. | |
| 813 EXPECT_TRUE(capturer->CaptureCustomFrame(format.width, format.height, | |
| 814 cricket::FOURCC_I420)); | |
| 815 | |
| 816 int captured_frames = 1; | |
| 817 for (int iterations = 0; iterations < 2; ++iterations) { | |
| 818 EXPECT_TRUE(channel_->SetCapturer(kSsrc, capturer.get())); | |
| 819 rtc::Thread::Current()->ProcessMessages(time_between_send); | |
| 820 EXPECT_TRUE(capturer->CaptureCustomFrame(format.width, format.height, | |
| 821 cricket::FOURCC_I420)); | |
| 822 ++captured_frames; | |
| 823 // Wait until frame of right size is captured. | |
| 824 EXPECT_TRUE_WAIT(renderer_.num_rendered_frames() >= captured_frames && | |
| 825 format.width == renderer_.width() && | |
| 826 format.height == renderer_.height() && | |
| 827 !renderer_.black_frame(), kTimeout); | |
| 828 EXPECT_GE(renderer_.num_rendered_frames(), captured_frames); | |
| 829 EXPECT_EQ(format.width, renderer_.width()); | |
| 830 EXPECT_EQ(format.height, renderer_.height()); | |
| 831 captured_frames = renderer_.num_rendered_frames() + 1; | |
| 832 EXPECT_FALSE(renderer_.black_frame()); | |
| 833 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); | |
| 834 // Make sure a black frame is generated within the specified timeout. | |
| 835 // The black frame should be the resolution of the previous frame to | |
| 836 // prevent expensive encoder reconfigurations. | |
| 837 EXPECT_TRUE_WAIT(renderer_.num_rendered_frames() >= captured_frames && | |
| 838 format.width == renderer_.width() && | |
| 839 format.height == renderer_.height() && | |
| 840 renderer_.black_frame(), kTimeout); | |
| 841 EXPECT_GE(renderer_.num_rendered_frames(), captured_frames); | |
| 842 EXPECT_EQ(format.width, renderer_.width()); | |
| 843 EXPECT_EQ(format.height, renderer_.height()); | |
| 844 EXPECT_TRUE(renderer_.black_frame()); | |
| 845 | |
| 846 // The black frame has the same timestamp as the next frame since it's | |
| 847 // timestamp is set to the last frame's timestamp + interval. WebRTC will | |
| 848 // not render a frame with the same timestamp so capture another frame | |
| 849 // with the frame capturer to increment the next frame's timestamp. | |
| 850 EXPECT_TRUE(capturer->CaptureCustomFrame(format.width, format.height, | |
| 851 cricket::FOURCC_I420)); | |
| 852 } | |
| 853 } | |
| 854 | |
| 855 // Tests that if RemoveCapturer is called without a capturer ever being | |
| 856 // added, the plugin shouldn't crash (and no black frame should be sent). | |
| 857 void RemoveCapturerWithoutAdd() { | |
| 858 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 859 EXPECT_TRUE(SetSend(true)); | |
| 860 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 861 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 862 EXPECT_TRUE(SendFrame()); | |
| 863 EXPECT_FRAME_WAIT(1, 640, 400, kTimeout); | |
| 864 // Wait for one frame so they don't get dropped because we send frames too | |
| 865 // tightly. | |
| 866 rtc::Thread::Current()->ProcessMessages(30); | |
| 867 // Remove the capturer. | |
| 868 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); | |
| 869 // Wait for one black frame for removing the capturer. | |
| 870 EXPECT_FRAME_WAIT(2, 640, 400, kTimeout); | |
| 871 | |
| 872 // No capturer was added, so this RemoveCapturer should | |
| 873 // fail. | |
| 874 EXPECT_FALSE(channel_->SetCapturer(kSsrc, NULL)); | |
| 875 rtc::Thread::Current()->ProcessMessages(300); | |
| 876 // Verify no more frames were sent. | |
| 877 EXPECT_EQ(2, renderer_.num_rendered_frames()); | |
| 878 } | |
| 879 | |
| 880 // Tests that we can add and remove capturer as unique sources. | |
| 881 void AddRemoveCapturerMultipleSources() { | |
| 882 // WebRTC implementation will drop frames if pushed to quickly. Wait the | |
| 883 // interval time to avoid that. | |
| 884 // WebRTC implementation will drop frames if pushed to quickly. Wait the | |
| 885 // interval time to avoid that. | |
| 886 // Set up the stream associated with the engine. | |
| 887 EXPECT_TRUE(channel_->AddRecvStream( | |
| 888 cricket::StreamParams::CreateLegacy(kSsrc))); | |
| 889 EXPECT_TRUE(channel_->SetSink(kSsrc, &renderer_)); | |
| 890 cricket::VideoFormat capture_format; // default format | |
| 891 capture_format.interval = cricket::VideoFormat::FpsToInterval(30); | |
| 892 // Set up additional stream 1. | |
| 893 cricket::FakeVideoRenderer renderer1; | |
| 894 EXPECT_FALSE(channel_->SetSink(1, &renderer1)); | |
| 895 EXPECT_TRUE(channel_->AddRecvStream( | |
| 896 cricket::StreamParams::CreateLegacy(1))); | |
| 897 EXPECT_TRUE(channel_->SetSink(1, &renderer1)); | |
| 898 EXPECT_TRUE(channel_->AddSendStream( | |
| 899 cricket::StreamParams::CreateLegacy(1))); | |
| 900 rtc::scoped_ptr<cricket::FakeVideoCapturer> capturer1( | |
| 901 CreateFakeVideoCapturer()); | |
| 902 capturer1->SetScreencast(true); | |
| 903 EXPECT_EQ(cricket::CS_RUNNING, capturer1->Start(capture_format)); | |
| 904 // Set up additional stream 2. | |
| 905 cricket::FakeVideoRenderer renderer2; | |
| 906 EXPECT_FALSE(channel_->SetSink(2, &renderer2)); | |
| 907 EXPECT_TRUE(channel_->AddRecvStream( | |
| 908 cricket::StreamParams::CreateLegacy(2))); | |
| 909 EXPECT_TRUE(channel_->SetSink(2, &renderer2)); | |
| 910 EXPECT_TRUE(channel_->AddSendStream( | |
| 911 cricket::StreamParams::CreateLegacy(2))); | |
| 912 rtc::scoped_ptr<cricket::FakeVideoCapturer> capturer2( | |
| 913 CreateFakeVideoCapturer()); | |
| 914 capturer2->SetScreencast(true); | |
| 915 EXPECT_EQ(cricket::CS_RUNNING, capturer2->Start(capture_format)); | |
| 916 // State for all the streams. | |
| 917 EXPECT_TRUE(SetOneCodec(DefaultCodec())); | |
| 918 // A limitation in the lmi implementation requires that SetCapturer() is | |
| 919 // called after SetOneCodec(). | |
| 920 // TODO(hellner): this seems like an unnecessary constraint, fix it. | |
| 921 EXPECT_TRUE(channel_->SetCapturer(1, capturer1.get())); | |
| 922 EXPECT_TRUE(channel_->SetCapturer(2, capturer2.get())); | |
| 923 EXPECT_TRUE(SetSend(true)); | |
| 924 // Test capturer associated with engine. | |
| 925 const int kTestWidth = 160; | |
| 926 const int kTestHeight = 120; | |
| 927 EXPECT_TRUE(capturer1->CaptureCustomFrame( | |
| 928 kTestWidth, kTestHeight, cricket::FOURCC_I420)); | |
| 929 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 930 renderer1, 1, kTestWidth, kTestHeight, kTimeout); | |
| 931 // Capture a frame with additional capturer2, frames should be received | |
| 932 EXPECT_TRUE(capturer2->CaptureCustomFrame( | |
| 933 kTestWidth, kTestHeight, cricket::FOURCC_I420)); | |
| 934 EXPECT_FRAME_ON_RENDERER_WAIT( | |
| 935 renderer2, 1, kTestWidth, kTestHeight, kTimeout); | |
| 936 // Successfully remove the capturer. | |
| 937 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); | |
| 938 // Fail to re-remove the capturer. | |
| 939 EXPECT_FALSE(channel_->SetCapturer(kSsrc, NULL)); | |
| 940 // The capturers must be unregistered here as it runs out of it's scope | |
| 941 // next. | |
| 942 EXPECT_TRUE(channel_->SetCapturer(1, NULL)); | |
| 943 EXPECT_TRUE(channel_->SetCapturer(2, NULL)); | |
| 944 } | |
| 945 | |
| 946 void HighAspectHighHeightCapturer() { | |
| 947 const int kWidth = 80; | |
| 948 const int kHeight = 10000; | |
| 949 const int kScaledWidth = 20; | |
| 950 const int kScaledHeight = 2500; | |
| 951 | |
| 952 cricket::VideoCodec codec(DefaultCodec()); | |
| 953 EXPECT_TRUE(SetOneCodec(codec)); | |
| 954 EXPECT_TRUE(SetSend(true)); | |
| 955 | |
| 956 cricket::FakeVideoRenderer renderer; | |
| 957 EXPECT_TRUE(channel_->AddRecvStream( | |
| 958 cricket::StreamParams::CreateLegacy(kSsrc))); | |
| 959 EXPECT_TRUE(channel_->SetSink(kSsrc, &renderer)); | |
| 960 EXPECT_EQ(0, renderer.num_rendered_frames()); | |
| 961 | |
| 962 EXPECT_TRUE(SendFrame()); | |
| 963 EXPECT_GT_FRAME_ON_RENDERER_WAIT( | |
| 964 renderer, 1, codec.width, codec.height, kTimeout); | |
| 965 | |
| 966 // Registering an external capturer is currently the same as screen casting | |
| 967 // (update the test when this changes). | |
| 968 rtc::scoped_ptr<cricket::FakeVideoCapturer> capturer( | |
| 969 CreateFakeVideoCapturer()); | |
| 970 capturer->SetScreencast(true); | |
| 971 const std::vector<cricket::VideoFormat>* formats = | |
| 972 capturer->GetSupportedFormats(); | |
| 973 cricket::VideoFormat capture_format = (*formats)[0]; | |
| 974 EXPECT_EQ(cricket::CS_RUNNING, capturer->Start(capture_format)); | |
| 975 // Capture frame to not get same frame timestamps as previous capturer. | |
| 976 capturer->CaptureFrame(); | |
| 977 EXPECT_TRUE(channel_->SetCapturer(kSsrc, capturer.get())); | |
| 978 EXPECT_TRUE(rtc::Thread::Current()->ProcessMessages(30)); | |
| 979 EXPECT_TRUE(capturer->CaptureCustomFrame(kWidth, kHeight, | |
| 980 cricket::FOURCC_ARGB)); | |
| 981 EXPECT_GT_FRAME_ON_RENDERER_WAIT( | |
| 982 renderer, 2, kScaledWidth, kScaledHeight, kTimeout); | |
| 983 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); | |
| 984 } | |
| 985 | |
| 986 // Tests that we can adapt video resolution with 16:10 aspect ratio properly. | |
| 987 void AdaptResolution16x10() { | |
| 988 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 989 cricket::VideoCodec codec(DefaultCodec()); | |
| 990 codec.width = 640; | |
| 991 codec.height = 400; | |
| 992 SendAndReceive(codec); | |
| 993 codec.width /= 2; | |
| 994 codec.height /= 2; | |
| 995 // Adapt the resolution. | |
| 996 EXPECT_TRUE(SetOneCodec(codec)); | |
| 997 EXPECT_TRUE(WaitAndSendFrame(30)); | |
| 998 EXPECT_FRAME_WAIT(2, codec.width, codec.height, kTimeout); | |
| 999 } | |
| 1000 // Tests that we can adapt video resolution with 4:3 aspect ratio properly. | |
| 1001 void AdaptResolution4x3() { | |
| 1002 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 1003 cricket::VideoCodec codec(DefaultCodec()); | |
| 1004 codec.width = 640; | |
| 1005 codec.height = 400; | |
| 1006 SendAndReceive(codec); | |
| 1007 codec.width /= 2; | |
| 1008 codec.height /= 2; | |
| 1009 // Adapt the resolution. | |
| 1010 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1011 EXPECT_TRUE(WaitAndSendFrame(30)); | |
| 1012 EXPECT_FRAME_WAIT(2, codec.width, codec.height, kTimeout); | |
| 1013 } | |
| 1014 // Tests that we can drop all frames properly. | |
| 1015 void AdaptDropAllFrames() { | |
| 1016 // Set the channel codec's resolution to 0, which will require the adapter | |
| 1017 // to drop all frames. | |
| 1018 cricket::VideoCodec codec(DefaultCodec()); | |
| 1019 codec.width = codec.height = codec.framerate = 0; | |
| 1020 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1021 EXPECT_TRUE(SetSend(true)); | |
| 1022 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 1023 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 1024 EXPECT_TRUE(SendFrame()); | |
| 1025 EXPECT_TRUE(SendFrame()); | |
| 1026 rtc::Thread::Current()->ProcessMessages(500); | |
| 1027 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 1028 } | |
| 1029 // Tests that we can reduce the frame rate on demand properly. | |
| 1030 // TODO(fbarchard): This test is flakey on pulse. Fix and re-enable | |
| 1031 void AdaptFramerate() { | |
| 1032 cricket::VideoCodec codec(DefaultCodec()); | |
| 1033 int frame_count = 0; | |
| 1034 // The capturer runs at 30 fps. The channel requires 30 fps. | |
| 1035 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1036 EXPECT_TRUE(SetSend(true)); | |
| 1037 EXPECT_EQ(frame_count, renderer_.num_rendered_frames()); | |
| 1038 EXPECT_TRUE(WaitAndSendFrame(0)); // Should be rendered. | |
| 1039 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be rendered. | |
| 1040 frame_count += 2; | |
| 1041 EXPECT_FRAME_WAIT(frame_count, codec.width, codec.height, kTimeout); | |
| 1042 rtc::scoped_ptr<const rtc::Buffer> p(GetRtpPacket(0)); | |
| 1043 EXPECT_EQ(codec.id, GetPayloadType(p.get())); | |
| 1044 | |
| 1045 // The channel requires 15 fps. | |
| 1046 codec.framerate = 15; | |
| 1047 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1048 EXPECT_TRUE(WaitAndSendFrame(0)); // Should be rendered. | |
| 1049 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be dropped. | |
| 1050 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be rendered. | |
| 1051 frame_count += 2; | |
| 1052 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1053 | |
| 1054 // The channel requires 10 fps. | |
| 1055 codec.framerate = 10; | |
| 1056 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1057 EXPECT_TRUE(WaitAndSendFrame(0)); // Should be rendered. | |
| 1058 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be dropped. | |
| 1059 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be dropped. | |
| 1060 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be rendered. | |
| 1061 frame_count += 2; | |
| 1062 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1063 | |
| 1064 // The channel requires 8 fps. The adapter adapts to 10 fps, which is the | |
| 1065 // closest factor of 30. | |
| 1066 codec.framerate = 8; | |
| 1067 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1068 EXPECT_TRUE(WaitAndSendFrame(0)); // Should be rendered. | |
| 1069 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be dropped. | |
| 1070 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be dropped. | |
| 1071 EXPECT_TRUE(WaitAndSendFrame(30)); // Should be rendered. | |
| 1072 frame_count += 2; | |
| 1073 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1074 } | |
| 1075 // Tests that adapted frames won't be upscaled to a higher resolution. | |
| 1076 void SendsLowerResolutionOnSmallerFrames() { | |
| 1077 cricket::VideoCodec codec = DefaultCodec(); | |
| 1078 codec.width = 320; | |
| 1079 codec.height = 240; | |
| 1080 EXPECT_TRUE(SetOneCodec(codec)); | |
| 1081 EXPECT_TRUE(SetSend(true)); | |
| 1082 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 1083 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 1084 EXPECT_TRUE(SendFrame()); | |
| 1085 EXPECT_FRAME_WAIT(1, codec.width, codec.height, kTimeout); | |
| 1086 | |
| 1087 // Check that we send smaller frames at the new resolution. | |
| 1088 EXPECT_TRUE(rtc::Thread::Current()->ProcessMessages(33)); | |
| 1089 EXPECT_TRUE(video_capturer_->CaptureCustomFrame( | |
| 1090 codec.width / 2, codec.height / 2, cricket::FOURCC_I420)); | |
| 1091 EXPECT_FRAME_WAIT(2, codec.width / 2, codec.height / 2, kTimeout); | |
| 1092 } | |
| 1093 | |
| 1094 // Tests that we can mute and unmute the channel properly. | |
| 1095 void MuteStream() { | |
| 1096 EXPECT_TRUE(SetDefaultCodec()); | |
| 1097 cricket::FakeVideoCapturer video_capturer; | |
| 1098 video_capturer.Start( | |
| 1099 cricket::VideoFormat( | |
| 1100 640, 480, | |
| 1101 cricket::VideoFormat::FpsToInterval(30), | |
| 1102 cricket::FOURCC_I420)); | |
| 1103 EXPECT_TRUE(channel_->SetCapturer(kSsrc, &video_capturer)); | |
| 1104 EXPECT_TRUE(SetSend(true)); | |
| 1105 EXPECT_TRUE(channel_->SetSink(kDefaultReceiveSsrc, &renderer_)); | |
| 1106 EXPECT_EQ(0, renderer_.num_rendered_frames()); | |
| 1107 // Mute the channel and expect black output frame. | |
| 1108 int frame_count = 0; | |
| 1109 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, false, nullptr)); | |
| 1110 EXPECT_TRUE(video_capturer.CaptureFrame()); | |
| 1111 ++frame_count; | |
| 1112 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1113 EXPECT_TRUE(renderer_.black_frame()); | |
| 1114 // Unmute the channel and expect non-black output frame. | |
| 1115 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, true, nullptr)); | |
| 1116 EXPECT_TRUE(rtc::Thread::Current()->ProcessMessages(30)); | |
| 1117 EXPECT_TRUE(video_capturer.CaptureFrame()); | |
| 1118 ++frame_count; | |
| 1119 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1120 EXPECT_FALSE(renderer_.black_frame()); | |
| 1121 // Test that we can also Mute using the correct send stream SSRC. | |
| 1122 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, false, nullptr)); | |
| 1123 EXPECT_TRUE(rtc::Thread::Current()->ProcessMessages(30)); | |
| 1124 EXPECT_TRUE(video_capturer.CaptureFrame()); | |
| 1125 ++frame_count; | |
| 1126 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1127 EXPECT_TRUE(renderer_.black_frame()); | |
| 1128 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, true, nullptr)); | |
| 1129 EXPECT_TRUE(rtc::Thread::Current()->ProcessMessages(30)); | |
| 1130 EXPECT_TRUE(video_capturer.CaptureFrame()); | |
| 1131 ++frame_count; | |
| 1132 EXPECT_EQ_WAIT(frame_count, renderer_.num_rendered_frames(), kTimeout); | |
| 1133 EXPECT_FALSE(renderer_.black_frame()); | |
| 1134 // Test that muting an existing stream succeeds even if it's muted. | |
| 1135 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, false, nullptr)); | |
| 1136 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, false, nullptr)); | |
| 1137 // Test that unmuting an existing stream succeeds even if it's not muted. | |
| 1138 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, true, nullptr)); | |
| 1139 EXPECT_TRUE(channel_->SetVideoSend(kSsrc, true, nullptr)); | |
| 1140 // Test that muting an invalid stream fails. | |
| 1141 EXPECT_FALSE(channel_->SetVideoSend(kSsrc+1, false, nullptr)); | |
| 1142 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL)); | |
| 1143 } | |
| 1144 | |
| 1145 // Test that multiple send streams can be created and deleted properly. | |
| 1146 void MultipleSendStreams() { | |
| 1147 // Remove stream added in Setup. I.e. remove stream corresponding to default | |
| 1148 // channel. | |
| 1149 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc)); | |
| 1150 const unsigned int kSsrcsSize = sizeof(kSsrcs4)/sizeof(kSsrcs4[0]); | |
| 1151 for (unsigned int i = 0; i < kSsrcsSize; ++i) { | |
| 1152 EXPECT_TRUE(channel_->AddSendStream( | |
| 1153 cricket::StreamParams::CreateLegacy(kSsrcs4[i]))); | |
| 1154 } | |
| 1155 // Delete one of the non default channel streams, let the destructor delete | |
| 1156 // the remaining ones. | |
| 1157 EXPECT_TRUE(channel_->RemoveSendStream(kSsrcs4[kSsrcsSize - 1])); | |
| 1158 // Stream should already be deleted. | |
| 1159 EXPECT_FALSE(channel_->RemoveSendStream(kSsrcs4[kSsrcsSize - 1])); | |
| 1160 } | |
| 1161 | |
| 1162 // Two streams one channel tests. | |
| 1163 | |
| 1164 // Tests that we can send and receive frames. | |
| 1165 void TwoStreamsSendAndReceive(const cricket::VideoCodec& codec) { | |
| 1166 SetUpSecondStream(); | |
| 1167 // Test sending and receiving on first stream. | |
| 1168 SendAndReceive(codec); | |
| 1169 // Test sending and receiving on second stream. | |
| 1170 EXPECT_EQ_WAIT(1, renderer2_.num_rendered_frames(), kTimeout); | |
| 1171 EXPECT_GT(NumRtpPackets(), 0); | |
| 1172 EXPECT_EQ(1, renderer2_.num_rendered_frames()); | |
| 1173 } | |
| 1174 | |
| 1175 // Set up 2 streams where the first stream uses the default channel. | |
| 1176 // Then disconnect the first stream and verify default channel becomes | |
| 1177 // available. | |
| 1178 // Then add a new stream with |new_ssrc|. The new stream should re-use the | |
| 1179 // default channel. | |
| 1180 void TwoStreamsReUseFirstStream(const cricket::VideoCodec& codec) { | |
| 1181 SetUpSecondStream(); | |
| 1182 // Default channel used by the first stream. | |
| 1183 EXPECT_EQ(kSsrc, channel_->GetDefaultSendChannelSsrc()); | |
| 1184 EXPECT_TRUE(channel_->RemoveRecvStream(kSsrc)); | |
| 1185 EXPECT_FALSE(channel_->RemoveRecvStream(kSsrc)); | |
| 1186 EXPECT_TRUE(channel_->RemoveSendStream(kSsrc)); | |
| 1187 EXPECT_FALSE(channel_->RemoveSendStream(kSsrc)); | |
| 1188 // Default channel is no longer used by a stream. | |
| 1189 EXPECT_EQ(0u, channel_->GetDefaultSendChannelSsrc()); | |
| 1190 uint32_t new_ssrc = kSsrc + 100; | |
| 1191 EXPECT_TRUE(channel_->AddSendStream( | |
| 1192 cricket::StreamParams::CreateLegacy(new_ssrc))); | |
| 1193 // Re-use default channel. | |
| 1194 EXPECT_EQ(new_ssrc, channel_->GetDefaultSendChannelSsrc()); | |
| 1195 EXPECT_FALSE(channel_->AddSendStream( | |
| 1196 cricket::StreamParams::CreateLegacy(new_ssrc))); | |
| 1197 EXPECT_TRUE(channel_->AddRecvStream( | |
| 1198 cricket::StreamParams::CreateLegacy(new_ssrc))); | |
| 1199 EXPECT_TRUE(channel_->SetSink(new_ssrc, &renderer_)); | |
| 1200 EXPECT_FALSE(channel_->AddRecvStream( | |
| 1201 cricket::StreamParams::CreateLegacy(new_ssrc))); | |
| 1202 | |
| 1203 EXPECT_TRUE(channel_->SetCapturer(new_ssrc, video_capturer_.get())); | |
| 1204 | |
| 1205 SendAndReceive(codec); | |
| 1206 EXPECT_TRUE(channel_->RemoveSendStream(new_ssrc)); | |
| 1207 EXPECT_EQ(0u, channel_->GetDefaultSendChannelSsrc()); | |
| 1208 } | |
| 1209 | |
| 1210 const rtc::scoped_ptr<webrtc::Call> call_; | |
| 1211 VideoEngineOverride<E> engine_; | |
| 1212 rtc::scoped_ptr<cricket::FakeVideoCapturer> video_capturer_; | |
| 1213 rtc::scoped_ptr<cricket::FakeVideoCapturer> video_capturer_2_; | |
| 1214 rtc::scoped_ptr<C> channel_; | |
| 1215 cricket::FakeNetworkInterface network_interface_; | |
| 1216 cricket::FakeVideoRenderer renderer_; | |
| 1217 cricket::VideoMediaChannel::Error media_error_; | |
| 1218 | |
| 1219 // Used by test cases where 2 streams are run on the same channel. | |
| 1220 cricket::FakeVideoRenderer renderer2_; | |
| 1221 }; | |
| 1222 | |
| 1223 #endif // TALK_MEDIA_BASE_VIDEOENGINE_UNITTEST_H_ NOLINT | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 1587193006:
Move talk/media to webrtc/media (Closed)
Base URL: https://chromium.googlesource.com/external/webrtc.git@master