Cast: Make receiver use cast_transport

media/cast/test/utility/in_process_receiver.cc

Index: media/cast/test/utility/in_process_receiver.cc
diff --git a/media/cast/test/utility/in_process_receiver.cc b/media/cast/test/utility/in_process_receiver.cc
index fb4184355100e063771cabbd82932f55412a69ae..5a84fad43e534a9bb0287a64b6e7ce25a0f02c53 100644
--- a/media/cast/test/utility/in_process_receiver.cc
+++ b/media/cast/test/utility/in_process_receiver.cc
@@ -7,6 +7,7 @@
 #include "base/bind_helpers.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/time/time.h"
+#include "base/values.h"
 #include "media/base/video_frame.h"
 #include "media/cast/cast_config.h"
 #include "media/cast/cast_environment.h"
@@ -76,20 +77,24 @@ void InProcessReceiver::StartOnMainThread() {
   DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN));
 
   DCHECK(!transport_ && !cast_receiver_);
-  transport_.reset(
-      new UdpTransport(NULL,
-                       cast_environment_->GetTaskRunner(CastEnvironment::MAIN),
-                       local_end_point_,
-                       remote_end_point_,
-                       65536,
-                       base::Bind(&InProcessReceiver::UpdateCastTransportStatus,
-                                  base::Unretained(this))));
+
+  transport_ = CastTransportSender::Create(
+      NULL,
+      cast_environment_->Clock(),
+      local_end_point_,
+      remote_end_point_,
+      scoped_ptr<base::DictionaryValue>(),
+      base::Bind(&InProcessReceiver::UpdateCastTransportStatus,
+                 base::Unretained(this)),
+      BulkRawEventsCallback(),
+      base::TimeDelta(),
+      base::Bind(&InProcessReceiver::ReceivePacket,
+                 base::Unretained(this)),
+      cast_environment_->GetTaskRunner(CastEnvironment::MAIN));
+
   cast_receiver_ = CastReceiver::Create(
       cast_environment_, audio_config_, video_config_, transport_.get());
 
-  // TODO(hubbe): Make the cast receiver do this automatically.
-  transport_->StartReceiving(cast_receiver_->packet_receiver());
-
   PullNextAudioFrame();
   PullNextVideoFrame();
 }
@@ -126,5 +131,10 @@ void InProcessReceiver::PullNextVideoFrame() {
       &InProcessReceiver::GotVideoFrame, weak_factory_.GetWeakPtr()));
 }
 
+void InProcessReceiver::ReceivePacket(scoped_ptr<Packet> packet) {
+  // TODO(Hubbe): Make an InsertPacket method instead.
+  cast_receiver_->ReceivePacket(packet.Pass());
+}
+
 }  // namespace cast
 }  // namespace media