From 8e6db691de95d2a25c625eff04ac16c9b2141198 Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Mon, 18 May 2020 16:33:29 +0800 Subject: [PATCH] [None-Jira]response ealier to improve writing speed --- bailongma/blm_prometheus/server.go | 5 +++-- bailongma/blm_telegraf/server.go | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/bailongma/blm_prometheus/server.go b/bailongma/blm_prometheus/server.go index ba48cec65b..a2aafd578e 100644 --- a/bailongma/blm_prometheus/server.go +++ b/bailongma/blm_prometheus/server.go @@ -184,6 +184,7 @@ func main() { } http.HandleFunc("/receive", func(w http.ResponseWriter, r *http.Request) { + w.WriteHeader(http.StatusAccepted) addr := strings.Split(r.RemoteAddr, ":") idx := TAOShashID([]byte(addr[0])) @@ -192,7 +193,7 @@ func main() { http.Error(w, err.Error(), http.StatusInternalServerError) return } - + r.Body.Close() reqBuf, err := snappy.Decode(nil, compressed) if err != nil { http.Error(w, err.Error(), http.StatusBadRequest) @@ -205,7 +206,7 @@ func main() { return } nodeChans[idx%httpworkers] <- req - w.WriteHeader(http.StatusAccepted) + }) http.HandleFunc("/check", func(w http.ResponseWriter, r *http.Request) { diff --git a/bailongma/blm_telegraf/server.go b/bailongma/blm_telegraf/server.go index e5957cfc8e..17799f2318 100644 --- a/bailongma/blm_telegraf/server.go +++ b/bailongma/blm_telegraf/server.go @@ -149,6 +149,7 @@ func main() { } http.HandleFunc("/telegraf", func(w http.ResponseWriter, r *http.Request) { + w.WriteHeader(http.StatusAccepted) addr := strings.Split(r.RemoteAddr, ":") idx := TAOShashID([]byte(addr[0])) @@ -157,7 +158,7 @@ func main() { http.Error(w, err.Error(), http.StatusInternalServerError) return } - + r.Body.Close() var req Metrics if err := json.Unmarshal(reqBuf, &req); err != nil { http.Error(w, err.Error(), http.StatusBadRequest) @@ -166,7 +167,7 @@ func main() { req.HostIP = addr[0] nodeChans[idx%httpworkers] <- req - w.WriteHeader(http.StatusAccepted) + //w.WriteHeader(http.StatusAccepted) }) http.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusNoContent) -- GitLab