OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "blimp/net/blimp_message_checkpointer.h" | 5 #include "blimp/net/blimp_message_checkpointer.h" |
6 | 6 |
7 #include "base/memory/ptr_util.h" | 7 #include "base/memory/ptr_util.h" |
8 #include "base/memory/ref_counted.h" | 8 #include "base/memory/ref_counted.h" |
9 #include "base/test/test_mock_time_task_runner.h" | 9 #include "base/test/test_mock_time_task_runner.h" |
10 #include "base/thread_task_runner_handle.h" | 10 #include "base/thread_task_runner_handle.h" |
(...skipping 16 matching lines...) Expand all Loading... |
27 MockCheckpointObserver() {} | 27 MockCheckpointObserver() {} |
28 ~MockCheckpointObserver() override {} | 28 ~MockCheckpointObserver() override {} |
29 | 29 |
30 MOCK_METHOD1(OnMessageCheckpoint, void(int64_t)); | 30 MOCK_METHOD1(OnMessageCheckpoint, void(int64_t)); |
31 }; | 31 }; |
32 | 32 |
33 } // namespace | 33 } // namespace |
34 | 34 |
35 static std::unique_ptr<BlimpMessage> CreateExpectedAckMessage(int64_t id) { | 35 static std::unique_ptr<BlimpMessage> CreateExpectedAckMessage(int64_t id) { |
36 std::unique_ptr<BlimpMessage> message = base::WrapUnique(new BlimpMessage); | 36 std::unique_ptr<BlimpMessage> message = base::WrapUnique(new BlimpMessage); |
37 message->set_type(BlimpMessage::PROTOCOL_CONTROL); | 37 message->mutable_protocol_control(); |
38 ProtocolControlMessage* protocol_control = | 38 ProtocolControlMessage* protocol_control = |
39 message->mutable_protocol_control(); | 39 message->mutable_protocol_control(); |
40 protocol_control->set_type(ProtocolControlMessage::CHECKPOINT_ACK); | 40 protocol_control->set_type(ProtocolControlMessage::CHECKPOINT_ACK); |
41 CheckpointAckMessage* checkpoint_ack = | 41 CheckpointAckMessage* checkpoint_ack = |
42 protocol_control->mutable_checkpoint_ack(); | 42 protocol_control->mutable_checkpoint_ack(); |
43 checkpoint_ack->set_checkpoint_id(id); | 43 checkpoint_ack->set_checkpoint_id(id); |
44 return message; | 44 return message; |
45 } | 45 } |
46 | 46 |
47 class BlimpMessageCheckpointerTest : public testing::Test { | 47 class BlimpMessageCheckpointerTest : public testing::Test { |
48 public: | 48 public: |
49 BlimpMessageCheckpointerTest() | 49 BlimpMessageCheckpointerTest() |
50 : runner_(new base::TestMockTimeTaskRunner), runner_handle_(runner_) {} | 50 : runner_(new base::TestMockTimeTaskRunner), runner_handle_(runner_) {} |
51 | 51 |
52 ~BlimpMessageCheckpointerTest() override {} | 52 ~BlimpMessageCheckpointerTest() override {} |
53 | 53 |
54 int64_t SimulateIncomingMessage() { | 54 int64_t SimulateIncomingMessage() { |
55 std::unique_ptr<BlimpMessage> message(new BlimpMessage); | 55 std::unique_ptr<BlimpMessage> message(new BlimpMessage); |
56 message->set_message_id(++message_id_); | 56 message->set_message_id(++message_id_); |
57 message->set_type(BlimpMessage::INPUT); | 57 message->mutable_input(); |
58 checkpointer_->ProcessMessage( | 58 checkpointer_->ProcessMessage( |
59 std::move(message), | 59 std::move(message), |
60 base::Bind(&BlimpMessageCheckpointerTest::IncomingCompletionCallback, | 60 base::Bind(&BlimpMessageCheckpointerTest::IncomingCompletionCallback, |
61 base::Unretained(this))); | 61 base::Unretained(this))); |
62 return message_id_; | 62 return message_id_; |
63 } | 63 } |
64 | 64 |
65 void SetUp() override { | 65 void SetUp() override { |
66 checkpointer_ = base::WrapUnique(new BlimpMessageCheckpointer( | 66 checkpointer_ = base::WrapUnique(new BlimpMessageCheckpointer( |
67 &incoming_processor_, &outgoing_processor_, &checkpoint_observer_)); | 67 &incoming_processor_, &outgoing_processor_, &checkpoint_observer_)); |
(...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
174 | 174 |
175 // Simulate an incoming message. | 175 // Simulate an incoming message. |
176 std::unique_ptr<BlimpMessage> ack_message = CreateCheckpointAckMessage(10); | 176 std::unique_ptr<BlimpMessage> ack_message = CreateCheckpointAckMessage(10); |
177 checkpointer_->ProcessMessage( | 177 checkpointer_->ProcessMessage( |
178 std::move(ack_message), | 178 std::move(ack_message), |
179 base::Bind(&BlimpMessageCheckpointerTest::IncomingCompletionCallback, | 179 base::Bind(&BlimpMessageCheckpointerTest::IncomingCompletionCallback, |
180 base::Unretained(this))); | 180 base::Unretained(this))); |
181 } | 181 } |
182 | 182 |
183 } // namespace blimp | 183 } // namespace blimp |
OLD | NEW |