[cast_channel] Create KeepAliveDelegate in CastSocket instead of in CastChannelOpenFunction

extensions/browser/api/cast_channel/cast_channel_apitest.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 "base/bind.h"
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/memory/ptr_util.h"
 #include "base/timer/mock_timer.h"
 #include "build/build_config.h"
@@ skipping 72 matching lines @@
   CastChannelAPITest() : ip_endpoint_(CreateIPEndPointForTest()) {}
 
   void SetUpCommandLine(base::CommandLine* command_line) override {
     ExtensionApiTest::SetUpCommandLine(command_line);
     command_line->AppendSwitchASCII(
         extensions::switches::kWhitelistedExtensionID, kTestExtensionId);
   }
 
   void SetUpMockCastSocket() {
     extensions::CastChannelAPI* api = GetApi();
-    timeout_timer_ = new base::MockTimer(true, false);
-    api->SetPingTimeoutTimerForTest(base::WrapUnique(timeout_timer_));
 
     net::IPEndPoint ip_endpoint(net::IPAddress(192, 168, 1, 1), 8009);
     mock_cast_socket_ = new MockCastSocket;
     // Transfers ownership of the socket.
     api->SetSocketForTest(base::WrapUnique<CastSocket>(mock_cast_socket_));
     ON_CALL(*mock_cast_socket_, set_id(_))
         .WillByDefault(SaveArg<0>(&channel_id_));
     ON_CALL(*mock_cast_socket_, id())
         .WillByDefault(ReturnPointee(&channel_id_));
     ON_CALL(*mock_cast_socket_, ip_endpoint())
@@ skipping 75 matching lines @@
     content::BrowserThread::PostTask(
         content::BrowserThread::IO, FROM_HERE,
         base::Bind(&CastTransport::Delegate::Start,
                    base::Unretained(message_delegate_)));
   }
 
   // Fires a timer on the IO thread.
   void FireTimeout() {
     content::BrowserThread::PostTask(
         content::BrowserThread::IO, FROM_HERE,
-        base::Bind(&base::MockTimer::Fire, base::Unretained(timeout_timer_)));
+        base::Bind(&CastTransport::Delegate::OnError,
+                   base::Unretained(message_delegate_),
+                   cast_channel::ChannelError::PING_TIMEOUT));
   }
 
   extensions::CastChannelOpenFunction* CreateOpenFunction(
         scoped_refptr<Extension> extension) {
     extensions::CastChannelOpenFunction* cast_channel_open_function =
       new extensions::CastChannelOpenFunction;
     cast_channel_open_function->set_extension(extension.get());
     return cast_channel_open_function;
   }
 
   extensions::CastChannelSendFunction* CreateSendFunction(
         scoped_refptr<Extension> extension) {
     extensions::CastChannelSendFunction* cast_channel_send_function =
       new extensions::CastChannelSendFunction;
     cast_channel_send_function->set_extension(extension.get());
     return cast_channel_send_function;
   }
 
   MockCastSocket* mock_cast_socket_;
-  base::MockTimer* timeout_timer_;
   net::IPEndPoint ip_endpoint_;
   LastError last_error_;
   CastTransport::Delegate* message_delegate_;
   net::TestNetLog capturing_net_log_;
   int channel_id_;
 };
 
 ACTION_P2(InvokeDelegateOnError, api_test, api) {
   content::BrowserThread::PostTask(
       content::BrowserThread::IO, FROM_HERE,
@@ skipping 207 matching lines @@
       "\"keepAlive\": true, "
       "\"audioOnly\": false, "
       "\"connectInfo\": "
       "{\"ipAddress\": \"127.0.0.1\", \"port\": 8009, "
       "\"auth\": \"ssl_verified\"}, \"readyState\": \"open\"}, "
       "{\"namespace_\": \"foo\", \"sourceId\": \"src\", "
       "\"destinationId\": \"\", \"data\": \"data\"}]",
       browser());
   EXPECT_EQ(error, "message_info.destination_id is required");
 }