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

Side by Side Diff: media/cast/net/cast_transport_sender_impl_unittest.cc

Issue 765643006: Cast: Make receiver use cast_transport (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix end2end test Created 6 years 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 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 <gtest/gtest.h> 5 #include <gtest/gtest.h>
6 #include <stdint.h> 6 #include <stdint.h>
7 7
8 #include "base/bind.h" 8 #include "base/bind.h"
9 #include "base/bind_helpers.h" 9 #include "base/bind_helpers.h"
10 #include "base/memory/scoped_ptr.h" 10 #include "base/memory/scoped_ptr.h"
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after
73 task_runner_ = new test::FakeSingleThreadTaskRunner(&testing_clock_); 73 task_runner_ = new test::FakeSingleThreadTaskRunner(&testing_clock_);
74 } 74 }
75 75
76 ~CastTransportSenderImplTest() override {} 76 ~CastTransportSenderImplTest() override {}
77 77
78 void InitWithoutLogging() { 78 void InitWithoutLogging() {
79 transport_sender_.reset( 79 transport_sender_.reset(
80 new CastTransportSenderImpl(NULL, 80 new CastTransportSenderImpl(NULL,
81 &testing_clock_, 81 &testing_clock_,
82 net::IPEndPoint(), 82 net::IPEndPoint(),
83 net::IPEndPoint(),
83 make_scoped_ptr(new base::DictionaryValue), 84 make_scoped_ptr(new base::DictionaryValue),
84 base::Bind(&UpdateCastTransportStatus), 85 base::Bind(&UpdateCastTransportStatus),
85 BulkRawEventsCallback(), 86 BulkRawEventsCallback(),
86 base::TimeDelta(), 87 base::TimeDelta(),
87 task_runner_, 88 task_runner_,
89 PacketReceiverCallback(),
88 &transport_)); 90 &transport_));
89 task_runner_->RunTasks(); 91 task_runner_->RunTasks();
90 } 92 }
91 93
92 void InitWithOptions() { 94 void InitWithOptions() {
93 scoped_ptr<base::DictionaryValue> options( 95 scoped_ptr<base::DictionaryValue> options(
94 new base::DictionaryValue); 96 new base::DictionaryValue);
95 options->SetBoolean("DHCP", true); 97 options->SetBoolean("DHCP", true);
96 options->SetBoolean("disable_wifi_scan", true); 98 options->SetBoolean("disable_wifi_scan", true);
97 options->SetBoolean("media_streaming_mode", true); 99 options->SetBoolean("media_streaming_mode", true);
98 options->SetInteger("pacer_target_burst_size", 20); 100 options->SetInteger("pacer_target_burst_size", 20);
99 options->SetInteger("pacer_max_burst_size", 100); 101 options->SetInteger("pacer_max_burst_size", 100);
100 transport_sender_.reset( 102 transport_sender_.reset(
101 new CastTransportSenderImpl(NULL, 103 new CastTransportSenderImpl(NULL,
102 &testing_clock_, 104 &testing_clock_,
103 net::IPEndPoint(), 105 net::IPEndPoint(),
106 net::IPEndPoint(),
104 options.Pass(), 107 options.Pass(),
105 base::Bind(&UpdateCastTransportStatus), 108 base::Bind(&UpdateCastTransportStatus),
106 BulkRawEventsCallback(), 109 BulkRawEventsCallback(),
107 base::TimeDelta(), 110 base::TimeDelta(),
108 task_runner_, 111 task_runner_,
112 PacketReceiverCallback(),
109 &transport_)); 113 &transport_));
110 task_runner_->RunTasks(); 114 task_runner_->RunTasks();
111 } 115 }
112 116
113 void InitWithLogging() { 117 void InitWithLogging() {
114 transport_sender_.reset(new CastTransportSenderImpl( 118 transport_sender_.reset(new CastTransportSenderImpl(
115 NULL, 119 NULL,
116 &testing_clock_, 120 &testing_clock_,
117 net::IPEndPoint(), 121 net::IPEndPoint(),
122 net::IPEndPoint(),
118 make_scoped_ptr(new base::DictionaryValue), 123 make_scoped_ptr(new base::DictionaryValue),
119 base::Bind(&UpdateCastTransportStatus), 124 base::Bind(&UpdateCastTransportStatus),
120 base::Bind(&CastTransportSenderImplTest::LogRawEvents, 125 base::Bind(&CastTransportSenderImplTest::LogRawEvents,
121 base::Unretained(this)), 126 base::Unretained(this)),
122 base::TimeDelta::FromMilliseconds(10), 127 base::TimeDelta::FromMilliseconds(10),
123 task_runner_, 128 task_runner_,
129 PacketReceiverCallback(),
124 &transport_)); 130 &transport_));
125 task_runner_->RunTasks(); 131 task_runner_->RunTasks();
126 } 132 }
127 133
128 void InitializeVideo() { 134 void InitializeVideo() {
129 CastTransportRtpConfig rtp_config; 135 CastTransportRtpConfig rtp_config;
130 rtp_config.ssrc = kVideoSsrc; 136 rtp_config.ssrc = kVideoSsrc;
131 rtp_config.feedback_ssrc = 2; 137 rtp_config.feedback_ssrc = 2;
132 rtp_config.rtp_payload_type = 3; 138 rtp_config.rtp_payload_type = 3;
133 transport_sender_->InitializeVideo(rtp_config, 139 transport_sender_->InitializeVideo(rtp_config,
(...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after
367 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(2)); 373 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(2));
368 transport_sender_->OnReceivedCastMessage(kVideoSsrc, 374 transport_sender_->OnReceivedCastMessage(kVideoSsrc,
369 RtcpCastMessageCallback(), 375 RtcpCastMessageCallback(),
370 cast_message); 376 cast_message);
371 task_runner_->RunTasks(); 377 task_runner_->RunTasks();
372 EXPECT_EQ(7, transport_.packets_sent()); 378 EXPECT_EQ(7, transport_.packets_sent());
373 } 379 }
374 380
375 } // namespace cast 381 } // namespace cast
376 } // namespace media 382 } // namespace media
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698