Cast: Reshuffle files under media/cast

media/cast/sender/video_sender_unittest.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include <stdint.h>
 
 #include <vector>
 
 #include "base/bind.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/test/simple_test_tick_clock.h"
 #include "media/base/video_frame.h"
 #include "media/cast/cast_environment.h"
 #include "media/cast/logging/simple_event_subscriber.h"
+#include "media/cast/net/cast_transport_config.h"
+#include "media/cast/net/cast_transport_sender_impl.h"
+#include "media/cast/net/pacing/paced_sender.h"
+#include "media/cast/sender/video_sender.h"
 #include "media/cast/test/fake_single_thread_task_runner.h"
 #include "media/cast/test/fake_video_encode_accelerator.h"
 #include "media/cast/test/utility/default_config.h"
 #include "media/cast/test/utility/video_utility.h"
-#include "media/cast/transport/cast_transport_config.h"
-#include "media/cast/transport/cast_transport_sender_impl.h"
-#include "media/cast/transport/pacing/paced_sender.h"
-#include "media/cast/video_sender/video_sender.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace media {
 namespace cast {
 
 namespace {
 static const uint8 kPixelValue = 123;
 static const int kWidth = 320;
 static const int kHeight = 240;
@@ skipping 11 matching lines @@
 void CreateSharedMemory(
     size_t size, const ReceiveVideoEncodeMemoryCallback& callback) {
   scoped_ptr<base::SharedMemory> shm(new base::SharedMemory());
   if (!shm->CreateAndMapAnonymous(size)) {
     NOTREACHED();
     return;
   }
   callback.Run(shm.Pass());
 }
 
-class TestPacketSender : public transport::PacketSender {
+class TestPacketSender : public PacketSender {
  public:
   TestPacketSender()
       : number_of_rtp_packets_(0),
         number_of_rtcp_packets_(0),
         paused_(false) {}
 
   // A singular packet implies a RTCP packet.
-  virtual bool SendPacket(transport::PacketRef packet,
+  virtual bool SendPacket(PacketRef packet,
                           const base::Closure& cb) OVERRIDE {
     if (paused_) {
       stored_packet_ = packet;
       callback_ = cb;
       return false;
     }
     if (Rtcp::IsRtcpPacket(&packet->data[0], packet->data.size())) {
       ++number_of_rtcp_packets_;
     } else {
       // Check that at least one RTCP packet was sent before the first RTP
@@ skipping 17 matching lines @@
       SendPacket(stored_packet_, callback_);
       callback_.Run();
     }
   }
 
  private:
   int number_of_rtp_packets_;
   int number_of_rtcp_packets_;
   bool paused_;
   base::Closure callback_;
-  transport::PacketRef stored_packet_;
+  PacketRef stored_packet_;
 
   DISALLOW_COPY_AND_ASSIGN(TestPacketSender);
 };
 
 class PeerVideoSender : public VideoSender {
  public:
   PeerVideoSender(
       scoped_refptr<CastEnvironment> cast_environment,
       const VideoSenderConfig& video_config,
       const CreateVideoEncodeAcceleratorCallback& create_vea_cb,
       const CreateVideoEncodeMemoryCallback& create_video_encode_mem_cb,
-      transport::CastTransportSender* const transport_sender)
+      CastTransportSender* const transport_sender)
       : VideoSender(cast_environment,
                     video_config,
                     create_vea_cb,
                     create_video_encode_mem_cb,
                     transport_sender) {}
   using VideoSender::OnReceivedCastFeedback;
 };
 }  // namespace
 
 class VideoSenderTest : public ::testing::Test {
  protected:
   VideoSenderTest() {
     testing_clock_ = new base::SimpleTestTickClock();
     testing_clock_->Advance(base::TimeTicks::Now() - base::TimeTicks());
     task_runner_ = new test::FakeSingleThreadTaskRunner(testing_clock_);
     cast_environment_ =
         new CastEnvironment(scoped_ptr<base::TickClock>(testing_clock_).Pass(),
                             task_runner_,
                             task_runner_,
                             task_runner_);
     last_pixel_value_ = kPixelValue;
     net::IPEndPoint dummy_endpoint;
-    transport_sender_.reset(new transport::CastTransportSenderImpl(
+    transport_sender_.reset(new CastTransportSenderImpl(
         NULL,
         testing_clock_,
         dummy_endpoint,
         base::Bind(&UpdateCastTransportStatus),
-        transport::BulkRawEventsCallback(),
+        BulkRawEventsCallback(),
         base::TimeDelta(),
         task_runner_,
         &transport_));
   }
 
   virtual ~VideoSenderTest() {}
 
   virtual void TearDown() OVERRIDE {
     video_sender_.reset();
     task_runner_->RunTasks();
   }
 
-  static void UpdateCastTransportStatus(transport::CastTransportStatus status) {
-    EXPECT_EQ(transport::TRANSPORT_VIDEO_INITIALIZED, status);
+  static void UpdateCastTransportStatus(CastTransportStatus status) {
+    EXPECT_EQ(TRANSPORT_VIDEO_INITIALIZED, status);
   }
 
   void InitEncoder(bool external) {
     VideoSenderConfig video_config;
     video_config.ssrc = 1;
     video_config.incoming_feedback_ssrc = 2;
     video_config.rtcp_c_name = "video_test@10.1.1.1";
     video_config.rtp_payload_type = 127;
     video_config.use_external_encoder = external;
     video_config.width = kWidth;
     video_config.height = kHeight;
     video_config.max_bitrate = 5000000;
     video_config.min_bitrate = 1000000;
     video_config.start_bitrate = 1000000;
     video_config.max_qp = 56;
     video_config.min_qp = 0;
     video_config.max_frame_rate = 30;
     video_config.max_number_of_video_buffers_used = 1;
-    video_config.codec = transport::CODEC_VIDEO_VP8;
+    video_config.codec = CODEC_VIDEO_VP8;
 
     if (external) {
       scoped_ptr<VideoEncodeAccelerator> fake_vea(
           new test::FakeVideoEncodeAccelerator(task_runner_));
       video_sender_.reset(
           new PeerVideoSender(cast_environment_,
                               video_config,
                               base::Bind(&CreateVideoEncodeAccelerator,
                                          task_runner_,
                                          base::Passed(&fake_vea)),
@@ skipping 27 matching lines @@
     PopulateVideoFrameWithNoise(video_frame);
     return video_frame;
   }
 
   void RunTasks(int during_ms) {
     task_runner_->Sleep(base::TimeDelta::FromMilliseconds(during_ms));
   }
 
   base::SimpleTestTickClock* testing_clock_;  // Owned by CastEnvironment.
   TestPacketSender transport_;
-  scoped_ptr<transport::CastTransportSenderImpl> transport_sender_;
+  scoped_ptr<CastTransportSenderImpl> transport_sender_;
   scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_;
   scoped_ptr<PeerVideoSender> video_sender_;
   scoped_refptr<CastEnvironment> cast_environment_;
   int last_pixel_value_;
 
   DISALLOW_COPY_AND_ASSIGN(VideoSenderTest);
 };
 
 TEST_F(VideoSenderTest, BuiltInEncoder) {
   InitEncoder(false);
@@ skipping 284 matching lines @@
   video_sender_->OnReceivedCastFeedback(cast_feedback);
 
   transport_.SetPause(false);
   RunTasks(33);
   // Only one packet should be retransmitted.
   EXPECT_EQ(1, transport_.number_of_rtp_packets());
 }
 
 }  // namespace cast
 }  // namespace media