[GCM] Add heartbeat manager and reconnection logic due to heartbeat failure

google_apis/gcm/engine/connection_handler_impl.h

 // 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.
 
 #ifndef GOOGLE_APIS_GCM_ENGINE_CONNECTION_HANDLER_IMPL_H_
 #define GOOGLE_APIS_GCM_ENGINE_CONNECTION_HANDLER_IMPL_H_
 
 #include "base/memory/weak_ptr.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
@@ skipping 16 matching lines @@
   // encountered.
   ConnectionHandlerImpl(
       base::TimeDelta read_timeout,
       const ProtoReceivedCallback& read_callback,
       const ProtoSentCallback& write_callback,
       const ConnectionChangedCallback& connection_callback);
   virtual ~ConnectionHandlerImpl();
 
   // ConnectionHandler implementation.
   virtual void Init(const mcs_proto::LoginRequest& login_request,
-                    scoped_ptr<net::StreamSocket> socket) OVERRIDE;
+                    net::StreamSocket* socket) OVERRIDE;
   virtual bool CanSendMessage() const OVERRIDE;
   virtual void SendMessage(const google::protobuf::MessageLite& message)
       OVERRIDE;
 
  private:
   // State machine for handling incoming data. See WaitForData(..) for usage.
   enum ProcessingState {
     // Processing the version, tag, and size packets (assuming minimum length
     // size packet). Only used during the login handshake.
     MCS_VERSION_TAG_AND_SIZE = 0,
@@ skipping 41 matching lines @@
   // Timeout policy: the timeout is only enforced while waiting on the
   // handshake (version and/or LoginResponse) or once at least a tag packet has
   // been received. It is reset every time new data is received, and is
   // only stopped when a full message is processed.
   // TODO(zea): consider enforcing a separate timeout when waiting for
   // a message to send.
   const base::TimeDelta read_timeout_;
   base::OneShotTimer<ConnectionHandlerImpl> read_timeout_timer_;
 
   // This connection's socket and the input/output streams attached to it.
-  scoped_ptr<net::StreamSocket> socket_;
+  net::StreamSocket* socket_;
   scoped_ptr<SocketInputStream> input_stream_;
   scoped_ptr<SocketOutputStream> output_stream_;
 
   // Whether the MCS login handshake has successfully completed. See Init(..)
   // description for more info on what the handshake involves.
   bool handshake_complete_;
 
   // State for the message currently being processed, if there is one.
   uint8 message_tag_;
   uint32 message_size_;
 
   ProtoReceivedCallback read_callback_;
   ProtoSentCallback write_callback_;
   ConnectionChangedCallback connection_callback_;
 
   base::WeakPtrFactory<ConnectionHandlerImpl> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(ConnectionHandlerImpl);
 };
 
 }  // namespace gcm
 
 #endif  // GOOGLE_APIS_GCM_ENGINE_CONNECTION_HANDLER_IMPL_H_