Implement IPP model support in udp_proxy

media/cast/test/utility/udp_proxy_main.cc

 // Copyright 2014 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 <cstdio>
 #include <cstdlib>
 #include <deque>
 #include <string>
 
 #include "base/at_exit.h"
@@ skipping 102 matching lines @@
       base::Bind(&CheckByteCounters),
       base::TimeDelta::FromMilliseconds(100));
 }
 
 int main(int argc, char** argv) {
   if (argc != 5 && argc != 3) {
     fprintf(stderr,
             "Usage: udp_proxy <localport> <remotehost> <remoteport> <type>\n"
             "or:\n"
             "       udp_proxy <localport> <type>\n"
-            "Where type is one of: perfect, wifi, bad, evil\n");
+            "Where type is one of: perfect, wifi, bad, evil, ipp\n");

[hubbe, 2014/11/10 19:31:48]

ipp is not very descriptive
Is there a better name for it?

     exit(1);
   }
 
   base::AtExitManager exit_manager;
   CommandLine::Init(argc, argv);
   InitLogging(logging::LoggingSettings());
 
   net::IPAddressNumber remote_ip_number;
   net::IPAddressNumber local_ip_number;
   std::string network_type;
   int local_port = atoi(argv[1]);
   int remote_port = 0;
   CHECK(net::ParseIPLiteralToNumber("0.0.0.0", &local_ip_number));
 
   if (argc == 5) {
     // V2 proxy
     CHECK(net::ParseIPLiteralToNumber(argv[2], &remote_ip_number));
     remote_port = atoi(argv[3]);
     network_type = argv[4];
   } else {
     // V1 proxy
     network_type = argv[2];
   }
   net::IPEndPoint remote_endpoint(remote_ip_number, remote_port);
   net::IPEndPoint local_endpoint(local_ip_number, local_port);
   scoped_ptr<media::cast::test::PacketPipe> in_pipe, out_pipe;
+  scoped_ptr<media::cast::test::InterruptedPoissonProcess> ipp(
+      media::cast::test::DefaultInterruptedPoissonProcess());
 
   if (network_type == "perfect") {
     // No action needed.
   } else if (network_type == "wifi") {
     in_pipe = media::cast::test::WifiNetwork().Pass();
     out_pipe = media::cast::test::WifiNetwork().Pass();
   } else if (network_type == "bad") {
     in_pipe = media::cast::test::BadNetwork().Pass();
     out_pipe = media::cast::test::BadNetwork().Pass();
   } else if (network_type == "evil") {
     in_pipe = media::cast::test::EvilNetwork().Pass();
     out_pipe = media::cast::test::EvilNetwork().Pass();
+  } else if (network_type == "ipp") {
+    in_pipe = ipp->NewBuffer(128 * 1024).Pass();
+    out_pipe = ipp->NewBuffer(128 * 1024).Pass();
   } else {
     fprintf(stderr, "Unknown network type.\n");
     exit(1);
   }
 
   SetupByteCounters(&in_pipe, &in_pipe_input_counter, &in_pipe_output_counter);
   SetupByteCounters(
       &out_pipe, &out_pipe_input_counter, &out_pipe_output_counter);
 
   printf("Press Ctrl-C when done.\n");
   scoped_ptr<media::cast::test::UDPProxy> proxy(
       media::cast::test::UDPProxy::Create(local_endpoint,
                                           remote_endpoint,
                                           in_pipe.Pass(),
                                           out_pipe.Pass(),
                                           NULL));
   base::MessageLoop message_loop;
   last_printout = base::TimeTicks::Now();
   CheckByteCounters();
   message_loop.Run();
   return 1;
 }