Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/memory/ref_counted.h" | 5 #include "base/memory/ref_counted.h" |
| 6 #include "base/message_loop.h" | 6 #include "base/message_loop.h" |
| 7 #include "base/message_loop_proxy.h" | 7 #include "base/message_loop_proxy.h" |
| 8 #include "base/string_number_conversions.h" | 8 #include "base/string_number_conversions.h" |
| 9 #include "remoting/base/constants.h" | 9 #include "remoting/base/constants.h" |
| 10 #include "remoting/host/heartbeat_sender.h" | 10 #include "remoting/host/heartbeat_sender.h" |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 43 config_->SetString(kHostIdConfigPath, kHostId); | 43 config_->SetString(kHostIdConfigPath, kHostId); |
| 44 config_->SetString(kPrivateKeyConfigPath, kTestHostKeyPair); | 44 config_->SetString(kPrivateKeyConfigPath, kTestHostKeyPair); |
| 45 } | 45 } |
| 46 | 46 |
| 47 MockSignalStrategy signal_strategy_; | 47 MockSignalStrategy signal_strategy_; |
| 48 MessageLoop message_loop_; | 48 MessageLoop message_loop_; |
| 49 scoped_refptr<InMemoryHostConfig> config_; | 49 scoped_refptr<InMemoryHostConfig> config_; |
| 50 }; | 50 }; |
| 51 | 51 |
| 52 // Call Start() followed by Stop(), and makes sure an Iq stanza is | 52 // Call Start() followed by Stop(), and makes sure an Iq stanza is |
| 53 // being send. | 53 // being send. |
|
Wez
2011/08/31 03:42:34
nit: send -> sent.
Sergey Ulanov
2011/08/31 23:26:27
Done.
| |
| 54 TEST_F(HeartbeatSenderTest, DoSendStanza) { | 54 TEST_F(HeartbeatSenderTest, DoSendStanza) { |
| 55 // |iq_request| is freed by HeartbeatSender. | 55 // |iq_request| is freed by HeartbeatSender. |
| 56 MockIqRequest* iq_request = new MockIqRequest(); | 56 MockIqRequest* iq_request = new MockIqRequest(); |
| 57 iq_request->Init(); | 57 iq_request->Init(); |
| 58 | 58 |
| 59 EXPECT_CALL(*iq_request, set_callback(_)).Times(1); | 59 EXPECT_CALL(*iq_request, set_callback(_)).Times(1); |
| 60 | 60 |
| 61 scoped_ptr<HeartbeatSender> heartbeat_sender( | 61 scoped_ptr<HeartbeatSender> heartbeat_sender( |
| 62 new HeartbeatSender(base::MessageLoopProxy::current(), | 62 new HeartbeatSender(base::MessageLoopProxy::current(), |
| 63 config_)); | 63 config_)); |
| 64 ASSERT_TRUE(heartbeat_sender->Init()); | 64 ASSERT_TRUE(heartbeat_sender->Init()); |
| 65 | 65 |
| 66 EXPECT_CALL(signal_strategy_, CreateIqRequest()) | 66 EXPECT_CALL(signal_strategy_, CreateIqRequest()) |
| 67 .WillOnce(Return(iq_request)); | 67 .WillOnce(Return(iq_request)); |
| 68 | 68 |
| 69 EXPECT_CALL(*iq_request, SendIq(buzz::STR_SET, kChromotingBotJid, NotNull())) | 69 EXPECT_CALL(*iq_request, SendIq(NotNull())) |
|
Wez
2011/08/31 03:42:34
We don't care about the content for this test any
Sergey Ulanov
2011/08/31 23:26:27
Done.
| |
| 70 .WillOnce(DoAll(DeleteArg<2>(), Return())); | 70 .WillOnce(DoAll(DeleteArg<0>(), Return())); |
| 71 | 71 |
| 72 heartbeat_sender->OnSignallingConnected(&signal_strategy_, kTestJid); | 72 heartbeat_sender->OnSignallingConnected(&signal_strategy_, kTestJid); |
| 73 message_loop_.RunAllPending(); | 73 message_loop_.RunAllPending(); |
| 74 | 74 |
| 75 heartbeat_sender->OnSignallingDisconnected(); | 75 heartbeat_sender->OnSignallingDisconnected(); |
| 76 message_loop_.RunAllPending(); | 76 message_loop_.RunAllPending(); |
| 77 } | 77 } |
| 78 | 78 |
| 79 // Validate format of the heartbeat stanza. | 79 // Validate format of the heartbeat stanza. |
| 80 TEST_F(HeartbeatSenderTest, CreateHeartbeatMessage) { | 80 TEST_F(HeartbeatSenderTest, CreateHeartbeatMessage) { |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 132 | 132 |
| 133 scoped_ptr<HeartbeatSender> heartbeat_sender( | 133 scoped_ptr<HeartbeatSender> heartbeat_sender( |
| 134 new HeartbeatSender(base::MessageLoopProxy::current(), | 134 new HeartbeatSender(base::MessageLoopProxy::current(), |
| 135 config_)); | 135 config_)); |
| 136 heartbeat_sender->ProcessResponse(response.get()); | 136 heartbeat_sender->ProcessResponse(response.get()); |
| 137 | 137 |
| 138 EXPECT_EQ(kTestInterval * 1000, heartbeat_sender->interval_ms_); | 138 EXPECT_EQ(kTestInterval * 1000, heartbeat_sender->interval_ms_); |
| 139 } | 139 } |
| 140 | 140 |
| 141 } // namespace remoting | 141 } // namespace remoting |
| OLD | NEW |