dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add internal metric for line too long in influxdb_listener (#5396)

This commit is contained in:
Greg 2019-02-11 13:49:06 -07:00 committed by Daniel Nelson
parent 516a5898fd
commit 16a7ce39da
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/inputs/influxdb_listener/http_listener.go
View File

@ -72,6 +72,8 @@ type HTTPListener struct {
NotFoundsServed selfstat.Stat NotFoundsServed selfstat.Stat
BuffersCreated selfstat.Stat BuffersCreated selfstat.Stat
AuthFailures selfstat.Stat AuthFailures selfstat.Stat
longLines selfstat.Stat
} }
const sampleConfig = ` const sampleConfig = `
@ -138,6 +140,7 @@ func (h *HTTPListener) Start(acc telegraf.Accumulator) error {
h.NotFoundsServed = selfstat.Register("http_listener", "not_founds_served", tags) h.NotFoundsServed = selfstat.Register("http_listener", "not_founds_served", tags)
h.BuffersCreated = selfstat.Register("http_listener", "buffers_created", tags) h.BuffersCreated = selfstat.Register("http_listener", "buffers_created", tags)
h.AuthFailures = selfstat.Register("http_listener", "auth_failures", tags) h.AuthFailures = selfstat.Register("http_listener", "auth_failures", tags)
h.longLines = selfstat.Register("http_listener", "long_lines", tags)
if h.MaxBodySize.Size == 0 { if h.MaxBodySize.Size == 0 {
h.MaxBodySize.Size = DEFAULT_MAX_BODY_SIZE h.MaxBodySize.Size = DEFAULT_MAX_BODY_SIZE
@ -325,6 +328,7 @@ func (h *HTTPListener) serveWrite(res http.ResponseWriter, req *http.Request) {
// final newline, then push the rest of the bytes into the next buffer. // final newline, then push the rest of the bytes into the next buffer.
i := bytes.LastIndexByte(buf, '\n') i := bytes.LastIndexByte(buf, '\n')
if i == -1 { if i == -1 {
h.longLines.Incr(1)
// drop any line longer than the max buffer size // drop any line longer than the max buffer size
log.Printf("D! http_listener received a single line longer than the maximum of %d bytes", log.Printf("D! http_listener received a single line longer than the maximum of %d bytes",
len(buf)) len(buf))