Lines Matching refs:reader
225 auto reader = GetReader(id); in Query() local
226 if (!reader) { in Query()
233 if (reader->m_msgList != &hilogDataList) { in Query()
234 reader->m_msgList = &hilogDataList; in Query()
236 reader->m_pos = hilogDataList.begin(); in Query()
238 reader->m_pos = hilogDataList.end(); in Query()
239 reader->m_pos--; in Query()
241 for (int i = 0; (i < tailCount) && (reader->m_pos != hilogDataList.begin());) { in Query()
242 if (LogMatchFilter(filter, (*reader->m_pos))) { in Query()
245 reader->m_pos--; in Query()
249 if (reader->skipped) { in Query()
251 const string tmpStr = msg + to_string(reader->skipped); in Query()
256 reader->skipped = 0; in Query()
261 while (reader->m_pos != hilogDataList.end()) { in Query()
262 const HilogData& logData = *reader->m_pos; in Query()
263 reader->m_pos++; in Query()
301 auto reader = std::make_shared<BufferReader>(); in CreateBufReader() local
302 if (reader != nullptr) { in CreateBufReader()
303 reader->skipped = 0; in CreateBufReader()
304 reader->m_onNewDataCallback = onNewDataCallback; in CreateBufReader()
306 ReaderId id = reinterpret_cast<ReaderId>(reader.get()); in CreateBufReader()
307 m_logReaders.insert(std::make_pair(id, reader)); in CreateBufReader()