| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef REMOTING_HOST_HEARTBEAT_SENDER_H_ | 5 #ifndef REMOTING_HOST_HEARTBEAT_SENDER_H_ |
| 6 #define REMOTING_HOST_HEARTBEAT_SENDER_H_ | 6 #define REMOTING_HOST_HEARTBEAT_SENDER_H_ |
| 7 | 7 |
| 8 #include <memory> |
| 8 #include <string> | 9 #include <string> |
| 9 | 10 |
| 10 #include "base/callback.h" | 11 #include "base/callback.h" |
| 11 #include "base/compiler_specific.h" | 12 #include "base/compiler_specific.h" |
| 12 #include "base/gtest_prod_util.h" | 13 #include "base/gtest_prod_util.h" |
| 13 #include "base/macros.h" | 14 #include "base/macros.h" |
| 14 #include "base/memory/ref_counted.h" | 15 #include "base/memory/ref_counted.h" |
| 15 #include "base/memory/scoped_ptr.h" | |
| 16 #include "base/threading/thread_checker.h" | 16 #include "base/threading/thread_checker.h" |
| 17 #include "base/timer/timer.h" | 17 #include "base/timer/timer.h" |
| 18 #include "remoting/base/rsa_key_pair.h" | 18 #include "remoting/base/rsa_key_pair.h" |
| 19 #include "remoting/signaling/signal_strategy.h" | 19 #include "remoting/signaling/signal_strategy.h" |
| 20 | 20 |
| 21 namespace base { | 21 namespace base { |
| 22 class TimeDelta; | 22 class TimeDelta; |
| 23 } // namespace base | 23 } // namespace base |
| 24 | 24 |
| 25 namespace buzz { | 25 namespace buzz { |
| (...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 140 IqRequest* request, | 140 IqRequest* request, |
| 141 const buzz::XmlElement* response); | 141 const buzz::XmlElement* response); |
| 142 void SetInterval(int interval); | 142 void SetInterval(int interval); |
| 143 void SetSequenceId(int sequence_id); | 143 void SetSequenceId(int sequence_id); |
| 144 | 144 |
| 145 // Handlers for host-offline-reason completion and timeout. | 145 // Handlers for host-offline-reason completion and timeout. |
| 146 void OnHostOfflineReasonTimeout(); | 146 void OnHostOfflineReasonTimeout(); |
| 147 void OnHostOfflineReasonAck(); | 147 void OnHostOfflineReasonAck(); |
| 148 | 148 |
| 149 // Helper methods used by DoSendStanza() to generate heartbeat stanzas. | 149 // Helper methods used by DoSendStanza() to generate heartbeat stanzas. |
| 150 scoped_ptr<buzz::XmlElement> CreateHeartbeatMessage(); | 150 std::unique_ptr<buzz::XmlElement> CreateHeartbeatMessage(); |
| 151 scoped_ptr<buzz::XmlElement> CreateSignature(); | 151 std::unique_ptr<buzz::XmlElement> CreateSignature(); |
| 152 | 152 |
| 153 base::Closure on_heartbeat_successful_callback_; | 153 base::Closure on_heartbeat_successful_callback_; |
| 154 base::Closure on_unknown_host_id_error_; | 154 base::Closure on_unknown_host_id_error_; |
| 155 std::string host_id_; | 155 std::string host_id_; |
| 156 SignalStrategy* signal_strategy_; | 156 SignalStrategy* signal_strategy_; |
| 157 scoped_refptr<const RsaKeyPair> host_key_pair_; | 157 scoped_refptr<const RsaKeyPair> host_key_pair_; |
| 158 std::string directory_bot_jid_; | 158 std::string directory_bot_jid_; |
| 159 scoped_ptr<IqSender> iq_sender_; | 159 std::unique_ptr<IqSender> iq_sender_; |
| 160 scoped_ptr<IqRequest> request_; | 160 std::unique_ptr<IqRequest> request_; |
| 161 int interval_ms_; | 161 int interval_ms_; |
| 162 base::RepeatingTimer timer_; | 162 base::RepeatingTimer timer_; |
| 163 base::OneShotTimer timer_resend_; | 163 base::OneShotTimer timer_resend_; |
| 164 int sequence_id_; | 164 int sequence_id_; |
| 165 bool sequence_id_was_set_; | 165 bool sequence_id_was_set_; |
| 166 int sequence_id_recent_set_num_; | 166 int sequence_id_recent_set_num_; |
| 167 bool heartbeat_succeeded_; | 167 bool heartbeat_succeeded_; |
| 168 int failed_startup_heartbeat_count_; | 168 int failed_startup_heartbeat_count_; |
| 169 | 169 |
| 170 // Fields to send and indicate completion of sending host-offline-reason. | 170 // Fields to send and indicate completion of sending host-offline-reason. |
| 171 std::string host_offline_reason_; | 171 std::string host_offline_reason_; |
| 172 base::Callback<void(bool success)> host_offline_reason_ack_callback_; | 172 base::Callback<void(bool success)> host_offline_reason_ack_callback_; |
| 173 base::OneShotTimer host_offline_reason_timeout_timer_; | 173 base::OneShotTimer host_offline_reason_timeout_timer_; |
| 174 | 174 |
| 175 base::ThreadChecker thread_checker_; | 175 base::ThreadChecker thread_checker_; |
| 176 | 176 |
| 177 DISALLOW_COPY_AND_ASSIGN(HeartbeatSender); | 177 DISALLOW_COPY_AND_ASSIGN(HeartbeatSender); |
| 178 }; | 178 }; |
| 179 | 179 |
| 180 } // namespace remoting | 180 } // namespace remoting |
| 181 | 181 |
| 182 #endif // REMOTING_HOST_HEARTBEAT_SENDER_H_ | 182 #endif // REMOTING_HOST_HEARTBEAT_SENDER_H_ |
| OLD | NEW |