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 |