[media] Replace MessageLoopProxy usage with ThreadTaskRunnerHandle

media/cast/test/utility/tap_proxy.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 <fcntl.h>
 #include <linux/if_tun.h>
 #include <linux/types.h>
 #include <math.h>
 #include <net/if.h>
 #include <netinet/in.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <sys/ioctl.h>
 #include <sys/stat.h>
 #include <sys/types.h>
 #include <unistd.h>
 
 #include <deque>
 #include <map>
 
 #include "base/at_exit.h"
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/logging.h"
 #include "base/rand_util.h"
+#include "base/single_thread_task_runner.h"
 #include "base/synchronization/waitable_event.h"
+#include "base/thread_task_runner_handle.h"
 #include "base/threading/thread.h"
 #include "base/time/default_tick_clock.h"
 #include "media/cast/test/utility/udp_proxy.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/udp/udp_socket.h"
 
 namespace media {
 namespace cast {
 namespace test {
@@ skipping 37 matching lines @@
     CHECK(base::MessageLoopForIO::current()->WatchFileDescriptor(
         input_fd_, true, base::MessageLoopForIO::WATCH_READ,
         &read_socket_watcher_, this));
 
     scoped_ptr<PacketPipe> tmp(new SendToFDPipe(output_fd));
     if (packet_pipe_) {
       packet_pipe_->AppendToPipe(tmp.Pass());
     } else {
       packet_pipe_ = tmp.Pass();
     }
-    packet_pipe_->InitOnIOThread(base::MessageLoopProxy::current(),
+    packet_pipe_->InitOnIOThread(base::ThreadTaskRunnerHandle::Get(),
                                  &tick_clock_);
   }
 
   ~QueueManager() final {}
 
   // MessageLoopForIO::Watcher methods
   void OnFileCanReadWithoutBlocking(int fd) final {
     scoped_ptr<Packet> packet(new Packet(kMaxPacketSize));
     int nread = read(input_fd_,
                      reinterpret_cast<char*>(&packet->front()),
@@ skipping 107 matching lines @@
             in_pipe_output_counter.packets_per_second(),
             in_pipe_input_counter.packets_per_second());
     fprintf(stderr, "Receiving: %5.2f / %5.2f mbps %6.2f / %6.2f packets / s\n",
             out_pipe_output_counter.megabits_per_second(),
             out_pipe_input_counter.megabits_per_second(),
             out_pipe_output_counter.packets_per_second(),
             out_pipe_input_counter.packets_per_second());
 
     last_printout = now;
   }
-  base::MessageLoopProxy::current()->PostDelayedTask(
+  base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&CheckByteCounters),
       base::TimeDelta::FromMilliseconds(100));
 }
 
 int tun_alloc(char *dev, int flags) {
   struct ifreq ifr;
   int fd, err;
   const char *clonedev = "/dev/net/tun";
 
@@ skipping 82 matching lines @@
   int fd2 = tun_alloc(argv[2], IFF_TAP);
 
   base::MessageLoopForIO message_loop;
   last_printout = base::TimeTicks::Now();
   media::cast::test::QueueManager qm1(fd1, fd2, in_pipe.Pass());
   media::cast::test::QueueManager qm2(fd2, fd1, out_pipe.Pass());
   CheckByteCounters();
   printf("Press Ctrl-C when done.\n");
   message_loop.Run();
 }