diff options
author | Geir Storli <geirst@verizonmedia.com> | 2019-03-21 13:55:00 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2019-03-21 13:55:00 +0000 |
commit | 40f7f32cda15d3d144975546169c1bcf0e4f78ae (patch) | |
tree | 822e6de97136a0225b870c7b73c22103d13dd08f /logd | |
parent | 573e322c1ac89e4c8b9f5a7f9e9784c23db2a2f0 (diff) |
Make _badLines private.
Diffstat (limited to 'logd')
-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; } } |