Chromoting: stopping the service if the host ID is permanently not recognized by the could.

remoting/host/heartbeat_sender.h

 // Copyright (c) 2012 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 REMOTING_HOST_HEARTBEAT_SENDER_H_
 #define REMOTING_HOST_HEARTBEAT_SENDER_H_
 
 #include <string>
 
 #include "base/compiler_specific.h"
@@ skipping 61 matching lines @@
 // stanza of this form:
 //
 //  <iq type="set" from="remoting@bot.talk.google.com"
 //      to="user@gmail.com/chromoting123123" id="5" xmlns="jabber:client">
 //    <rem:heartbeat-result xmlns:rem="google:remoting">
 //      <rem:expected-sequence-id>654</rem:expected-sequence-id>
 //    </rem:heartbeat-result>
 //  </iq>
 class HeartbeatSender : public SignalStrategy::Listener {
  public:
-  // |signal_strategy| and |key_pair| must outlive this
+  class Listener {
+   public:
+    virtual ~Listener() { }
+    // Invoked when the host ID is permanently not recognized by the server.
+    virtual void OnUnknownHostIdError() = 0;
+  };
+
+  // |signal_strategy|, |key_pair| and |delegate| must outlive this
   // object. Heartbeats will start when the supplied SignalStrategy
   // enters the CONNECTED state.
-  HeartbeatSender(const std::string& host_id,
+  HeartbeatSender(Listener* listener,
+                  const std::string& host_id,
                   SignalStrategy* signal_strategy,
                   HostKeyPair* key_pair);
   virtual ~HeartbeatSender();
 
   // SignalStrategy::Listener interface.
   virtual void OnSignalStrategyStateChange(
       SignalStrategy::State state) OVERRIDE;
 
  private:
   FRIEND_TEST_ALL_PREFIXES(HeartbeatSenderTest, DoSendStanza);
   FRIEND_TEST_ALL_PREFIXES(HeartbeatSenderTest,
                            DoSendStanzaWithExpectedSequenceId);
   FRIEND_TEST_ALL_PREFIXES(HeartbeatSenderTest, CreateHeartbeatMessage);
   FRIEND_TEST_ALL_PREFIXES(HeartbeatSenderTest, ProcessResponseSetInterval);
   FRIEND_TEST_ALL_PREFIXES(HeartbeatSenderTest,
                            ProcessResponseExpectedSequenceId);
 
   void SendStanza();
   void ResendStanza();
   void DoSendStanza();
   void ProcessResponse(IqRequest* request, const buzz::XmlElement* response);
   void SetInterval(int interval);
   void SetSequenceId(int sequence_id);
 
   // Helper methods used by DoSendStanza() to generate heartbeat stanzas.
   scoped_ptr<buzz::XmlElement> CreateHeartbeatMessage();
   scoped_ptr<buzz::XmlElement> CreateSignature();
 
+  Listener* listener_;
   std::string host_id_;
   SignalStrategy* signal_strategy_;
   HostKeyPair* key_pair_;
   scoped_ptr<IqSender> iq_sender_;
   scoped_ptr<IqRequest> request_;
   int interval_ms_;
   base::RepeatingTimer<HeartbeatSender> timer_;
   base::OneShotTimer<HeartbeatSender> timer_resend_;
   int sequence_id_;
   bool sequence_id_was_set_;
   int sequence_id_recent_set_num_;
   bool heartbeat_succeeded_;
   int failed_startup_heartbeat_count_;
 
   DISALLOW_COPY_AND_ASSIGN(HeartbeatSender);
 };
 
 }  // namespace remoting
 
 #endif  // REMOTING_HOST_HEARTBEAT_SENDER_H_