| 133 | }; |
| 134 | |
| 135 | TEST_F(ReadTabletTest, ParallelReadTablet) { |
| 136 | EXPECT_CALL(*mock_tablet_manager_, GetTablet(_, _, _)) |
| 137 | .WillRepeatedly(Invoke(this, &ReadTabletTest::GetTablet)); |
| 138 | EXPECT_CALL(mock_io_, ReadCells(_, _, _, _, _)) |
| 139 | .WillRepeatedly(Invoke(this, &ReadTabletTest::ReadCellsInc)); |
| 140 | |
| 141 | for (int i = 0; i != 280; ++i) { |
| 142 | auto row_info = req_.add_row_info_list(); |
| 143 | row_info->set_key(std::to_string(i)); |
| 144 | } |
| 145 | req_.set_sequence_id(2); |
| 146 | req_.set_tablet_name("read_table"); |
| 147 | |
| 148 | std::shared_ptr<ReadTabletTask> task = |
| 149 | std::make_shared<ReadTabletTask>(0, mock_tablet_manager_, &req_, &res_, |
| 150 | CreateDone(&ReadTabletTest::CheckIncDone), thread_pool_); |
| 151 | task->StartRead(); |
| 152 | done_event_.Wait(); |
| 153 | EXPECT_EQ(task->row_results_list_.size(), 10); |
| 154 | } |
| 155 | |
| 156 | TEST_F(ReadTabletTest, ParallelReadTabletWithNullValue) { |
| 157 | EXPECT_CALL(*mock_tablet_manager_, GetTablet(_, _, _)) |