diff options
-rw-r--r-- | logd/src/logd/forwarder.h | 4 | ||||
-rw-r--r-- | logd/src/logd/watcher.cpp | 6 |
2 files changed, 6 insertions, 4 deletions
diff --git a/logd/src/logd/forwarder.h b/logd/src/logd/forwarder.h index 59c8fcb933f..b5c57fea8cd 100644 --- a/logd/src/logd/forwarder.h +++ b/logd/src/logd/forwarder.h @@ -32,6 +32,7 @@ private: Metrics &_metrics; ForwardMap _forwardMap; LevelParser _levelparser; + int _badLines; const char *copystr(const char *b, const char *e) { int len = e - b; char *ret = new char[len+1]; @@ -41,7 +42,6 @@ private: } bool parseline(const char *linestart, const char *lineend); public: - int _badLines; Forwarder(Metrics &metrics); ~Forwarder(); void forwardText(const char *text, int len); @@ -50,6 +50,8 @@ public: void setLogserverFD(int fd) { _logserverfd = fd; } int getLogserverFD() { return _logserverfd; } void sendMode(); + int badLines() const { return _badLines; } + void resetBadLines() { _badLines = 0; } }; } diff --git a/logd/src/logd/watcher.cpp b/logd/src/logd/watcher.cpp index 750d8b1914d..a8264328b2c 100644 --- a/logd/src/logd/watcher.cpp +++ b/logd/src/logd/watcher.cpp @@ -300,9 +300,9 @@ Watcher::watchfile() throw SigTermException("caught signal"); } if (++sleepcount > 99) { - if (_forwarder._badLines) { - LOG(info, "seen %d bad loglines in %d iterations", _forwarder._badLines, sleepcount); - _forwarder._badLines = 0; + if (_forwarder.badLines()) { + LOG(info, "seen %d bad loglines in %d iterations", _forwarder.badLines(), sleepcount); + _forwarder.resetBadLines(); sleepcount=0; } } |