debug #10900

plugins/inputs/influxdb_listener/influxdb_listener.go

@@ -220,6 +220,7 @@ func (h *InfluxDBListener) handleWrite() http.HandlerFunc {
 }
 
 func (h *InfluxDBListener) handleWriteInternalParser(res http.ResponseWriter, req *http.Request) {
+	h.Log.Debugf("using internal parser")
 	defer h.writesServed.Incr(1)
 	// Check that the content length is not too large for us to handle.
 	if req.ContentLength > int64(h.MaxBodySize) {
@@ -239,6 +240,13 @@ func (h *InfluxDBListener) handleWriteInternalParser(res http.ResponseWriter, re
 		var err error
 		body, err = gzip.NewReader(body)
 		if err != nil {
+			if err == influx_upstream.ErrEOF {
+				return
+			}
+
+			h.Log.Debug("error using new internal gzip reader")
+			h.Log.Debugf("'%s': '%s'\n", err, err.Error())
+
 			h.Log.Debugf("Error decompressing request body: %v", err.Error())
 			if err := badRequest(res, err.Error()); err != nil {
 				h.Log.Debugf("error in bad-request: %v", err)
@@ -328,6 +336,7 @@ func (h *InfluxDBListener) handleWriteInternalParser(res http.ResponseWriter, re
 }
 
 func (h *InfluxDBListener) handleWriteUpstreamParser(res http.ResponseWriter, req *http.Request) {
+	h.Log.Debugf("using upstream parser")
 	defer h.writesServed.Incr(1)
 	// Check that the content length is not too large for us to handle.
 	if req.ContentLength > int64(h.MaxBodySize) {
@@ -347,6 +356,13 @@ func (h *InfluxDBListener) handleWriteUpstreamParser(res http.ResponseWriter, re
 		var err error
 		body, err = gzip.NewReader(body)
 		if err != nil {
+			if err == influx_upstream.ErrEOF {
+				return
+			}
+
+			h.Log.Debug("error using upstream gzip reader")
+			h.Log.Debugf("'%s': '%s'\n", err, err.Error())
+
 			h.Log.Debugf("Error decompressing request body: %v", err.Error())
 			if err := badRequest(res, err.Error()); err != nil {
 				h.Log.Debugf("error in bad-request: %v", err)