94     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
95     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_SUCCESS);  in TEST_F()
96     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
97     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
98     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
99     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
100     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
109     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_SUCCESS);  in TEST_F()
110     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
111     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
112     EXPECT_EQ(2222L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
113     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
114     EXPECT_EQ(44, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
122     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
123     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_SUCCESS);  in TEST_F()
124     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
125     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
126     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
127     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
128     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
136     dataHolder.clear();  in TEST_F()
137     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
138     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
142     dataHolder.clear();  in TEST_F()
143     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
144     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
154     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
155     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
156     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
163     dataHolder.clear();  in TEST_F()
164     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
165     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
173     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
174     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
175     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
184     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
185     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
186     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
194     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
195     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_SUCCESS);  in TEST_F()
196     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
197     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
198     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
199     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
200     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
207     dataHolder.clear();  in TEST_F()
208     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_SUCCESS);  in TEST_F()
209     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
210     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
211     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
212     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
213     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
221     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
222     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
223     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
230     EXPECT_EQ(puller.Pull(getElapsedRealtimeNs(), &dataHolder), PULL_FAIL);  in TEST_F()
231     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
240     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
241     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_SUCCESS);  in TEST_F()
242     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
243     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
244     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
245     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
246     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
255     dataHolder.clear();  in TEST_F()
256     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_SUCCESS);  in TEST_F()
257     ASSERT_EQ(1, dataHolder.size());  in TEST_F()
258     EXPECT_EQ(pullTagId, dataHolder[0]->GetTagId());  in TEST_F()
259     EXPECT_EQ(1111L, dataHolder[0]->GetElapsedTimestampNs());  in TEST_F()
260     ASSERT_EQ(1, dataHolder[0]->size());  in TEST_F()
261     EXPECT_EQ(33, dataHolder[0]->getValues()[0].mValue.int_value);  in TEST_F()
272     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
273     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL);  in TEST_F()
274     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
284     dataHolder.clear();  in TEST_F()
285     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL);  in TEST_F()
286     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
295     vector<std::shared_ptr<LogEvent>> dataHolder;  in TEST_F()  local
296     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL);  in TEST_F()
297     ASSERT_EQ(0, dataHolder.size());  in TEST_F()
307     EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL);  in TEST_F()
308     ASSERT_EQ(0, dataHolder.size());  in TEST_F()