From 9f146ac7d224f46dfa61af1f0c77750351e2ae96 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Mon, 20 Nov 2017 11:27:33 +0100 Subject: [PATCH] cleanup --- proxy/http/server.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/proxy/http/server.go b/proxy/http/server.go index 76970517d..ab96f7319 100644 --- a/proxy/http/server.go +++ b/proxy/http/server.go @@ -167,7 +167,7 @@ func (s *Server) handleConnect(ctx context.Context, request *http.Request, reade if reader.Buffered() > 0 { payload := buf.New() common.Must(payload.Reset(func(b []byte) (int, error) { - return reader.Read(b[:reader.Buffered()]) + return reader.Read(b) })) if err := ray.InboundInput().WriteMultiBuffer(buf.NewMultiBufferValue(payload)); err != nil { return err @@ -274,7 +274,7 @@ func (s *Server) handlePlainHTTP(ctx context.Context, request *http.Request, wri }) responseDone := signal.ExecuteAsync(func() error { - responseReader := bufio.NewReaderSize(buf.NewBufferedReader(ray.InboundOutput()), 2048) + responseReader := bufio.NewReaderSize(buf.NewBufferedReader(ray.InboundOutput()), buf.Size) response, err := http.ReadResponse(responseReader, request) if err == nil { StripHopByHopHeaders(response.Header)