summaryrefslogtreecommitdiffstats
path: root/logd
diff options
context:
space:
mode:
authorGeir Storli <geirst@verizonmedia.com>2019-03-21 13:55:00 +0000
committerGeir Storli <geirst@verizonmedia.com>2019-03-21 13:55:00 +0000
commit40f7f32cda15d3d144975546169c1bcf0e4f78ae (patch)
tree822e6de97136a0225b870c7b73c22103d13dd08f /logd
parent573e322c1ac89e4c8b9f5a7f9e9784c23db2a2f0 (diff)
Make _badLines private.
Diffstat (limited to 'logd')
-rw-r--r--logd/src/logd/forwarder.h4
-rw-r--r--logd/src/logd/watcher.cpp6
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;
}
}