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