From 4c3cb7a7ad698d41e397113d57043e8b6e8bae1a Mon Sep 17 00:00:00 2001 From: Haleygo Date: Thu, 27 Apr 2023 15:22:42 +0800 Subject: [PATCH] lib/opentsdbhttp: fix a typo preventing from using writeconcurrencylimiter (#4208) --- lib/protoparser/opentsdbhttp/stream/streamparser.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/protoparser/opentsdbhttp/stream/streamparser.go b/lib/protoparser/opentsdbhttp/stream/streamparser.go index e4dd2119a..03d5e4cb3 100644 --- a/lib/protoparser/opentsdbhttp/stream/streamparser.go +++ b/lib/protoparser/opentsdbhttp/stream/streamparser.go @@ -33,7 +33,7 @@ var ( func Parse(req *http.Request, callback func(rows []opentsdbhttp.Row) error) error { wcr := writeconcurrencylimiter.GetReader(req.Body) defer writeconcurrencylimiter.PutReader(wcr) - r := io.Reader(req.Body) + r := io.Reader(wcr) readCalls.Inc() if req.Header.Get("Content-Encoding") == "gzip" {