| 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 #include "remoting/host/heartbeat_sender.h" | 5 #include "remoting/host/heartbeat_sender.h" |
| 6 | 6 |
| 7 #include <set> | 7 #include <set> |
| 8 | 8 |
| 9 #include "base/memory/ref_counted.h" | 9 #include "base/memory/ref_counted.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 29 matching lines...) Expand all Loading... |
| 40 } // namespace | 40 } // namespace |
| 41 | 41 |
| 42 ACTION_P(AddListener, list) { | 42 ACTION_P(AddListener, list) { |
| 43 list->insert(arg0); | 43 list->insert(arg0); |
| 44 } | 44 } |
| 45 ACTION_P(RemoveListener, list) { | 45 ACTION_P(RemoveListener, list) { |
| 46 EXPECT_TRUE(list->find(arg0) != list->end()); | 46 EXPECT_TRUE(list->find(arg0) != list->end()); |
| 47 list->erase(arg0); | 47 list->erase(arg0); |
| 48 } | 48 } |
| 49 | 49 |
| 50 class HeartbeatSenderTest : public testing::Test { | 50 class HeartbeatSenderTest |
| 51 : public testing::Test, |
| 52 public HeartbeatSender::Delegate { |
| 51 protected: | 53 protected: |
| 54 // Overridden from HeartbeatSender::Delegate |
| 55 virtual void OnUnknownHostIdError() OVERRIDE { |
| 56 NOTREACHED(); |
| 57 } |
| 58 |
| 52 virtual void SetUp() OVERRIDE { | 59 virtual void SetUp() OVERRIDE { |
| 53 ASSERT_TRUE(key_pair_.LoadFromString(kTestHostKeyPair)); | 60 ASSERT_TRUE(key_pair_.LoadFromString(kTestHostKeyPair)); |
| 54 | 61 |
| 55 EXPECT_CALL(signal_strategy_, GetState()) | 62 EXPECT_CALL(signal_strategy_, GetState()) |
| 56 .WillOnce(Return(SignalStrategy::DISCONNECTED)); | 63 .WillOnce(Return(SignalStrategy::DISCONNECTED)); |
| 57 EXPECT_CALL(signal_strategy_, AddListener(NotNull())) | 64 EXPECT_CALL(signal_strategy_, AddListener(NotNull())) |
| 58 .WillRepeatedly(AddListener(&signal_strategy_listeners_)); | 65 .WillRepeatedly(AddListener(&signal_strategy_listeners_)); |
| 59 EXPECT_CALL(signal_strategy_, RemoveListener(NotNull())) | 66 EXPECT_CALL(signal_strategy_, RemoveListener(NotNull())) |
| 60 .WillRepeatedly(RemoveListener(&signal_strategy_listeners_)); | 67 .WillRepeatedly(RemoveListener(&signal_strategy_listeners_)); |
| 61 EXPECT_CALL(signal_strategy_, GetLocalJid()) | 68 EXPECT_CALL(signal_strategy_, GetLocalJid()) |
| 62 .WillRepeatedly(Return(kTestJid)); | 69 .WillRepeatedly(Return(kTestJid)); |
| 63 | 70 |
| 64 heartbeat_sender_.reset( | 71 heartbeat_sender_.reset( |
| 65 new HeartbeatSender(kHostId, &signal_strategy_, &key_pair_)); | 72 new HeartbeatSender(this, kHostId, &signal_strategy_, &key_pair_)); |
| 66 } | 73 } |
| 67 | 74 |
| 68 virtual void TearDown() OVERRIDE { | 75 virtual void TearDown() OVERRIDE { |
| 69 heartbeat_sender_.reset(); | 76 heartbeat_sender_.reset(); |
| 70 EXPECT_TRUE(signal_strategy_listeners_.empty()); | 77 EXPECT_TRUE(signal_strategy_listeners_.empty()); |
| 71 } | 78 } |
| 72 | 79 |
| 73 void ValidateHeartbeatStanza(XmlElement* stanza, | 80 void ValidateHeartbeatStanza(XmlElement* stanza, |
| 74 const char* expectedSequenceId); | 81 const char* expectedSequenceId); |
| 75 | 82 |
| (...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 229 EXPECT_TRUE(heartbeat_stanza->NextNamed(signature_tag) == NULL); | 236 EXPECT_TRUE(heartbeat_stanza->NextNamed(signature_tag) == NULL); |
| 230 | 237 |
| 231 HostKeyPair key_pair; | 238 HostKeyPair key_pair; |
| 232 key_pair.LoadFromString(kTestHostKeyPair); | 239 key_pair.LoadFromString(kTestHostKeyPair); |
| 233 std::string expected_signature = | 240 std::string expected_signature = |
| 234 key_pair.GetSignature(std::string(kTestJid) + ' ' + expectedSequenceId); | 241 key_pair.GetSignature(std::string(kTestJid) + ' ' + expectedSequenceId); |
| 235 EXPECT_EQ(expected_signature, signature->BodyText()); | 242 EXPECT_EQ(expected_signature, signature->BodyText()); |
| 236 } | 243 } |
| 237 | 244 |
| 238 } // namespace remoting | 245 } // namespace remoting |
| OLD | NEW |