aboutsummaryrefslogtreecommitdiffhomepage
path: root/modules/caddyhttp/encode/encode.go
diff options
context:
space:
mode:
authorMatthew Holt <[email protected]>2019-06-27 13:09:10 -0600
committerMatthew Holt <[email protected]>2019-06-27 13:09:10 -0600
commita63cb3e3fdea70991a95c3f0bc8f3866a5aec6ef (patch)
treedbb40f0f0edb26ab3e16b6671b155f8cd0785728 /modules/caddyhttp/encode/encode.go
parent2b22d2e6ea7ffd17ae769bd8a2adae60e5a7d0bf (diff)
downloadcaddy-a63cb3e3fdea70991a95c3f0bc8f3866a5aec6ef.tar.gz
caddy-a63cb3e3fdea70991a95c3f0bc8f3866a5aec6ef.zip
Implement etag; fix related bugs in encode and templates middlewares
Diffstat (limited to 'modules/caddyhttp/encode/encode.go')
-rw-r--r--modules/caddyhttp/encode/encode.go26
1 files changed, 20 insertions, 6 deletions
diff --git a/modules/caddyhttp/encode/encode.go b/modules/caddyhttp/encode/encode.go
index b7ab73718..792940522 100644
--- a/modules/caddyhttp/encode/encode.go
+++ b/modules/caddyhttp/encode/encode.go
@@ -135,6 +135,17 @@ func (rw *responseWriter) Write(p []byte) (int, error) {
}()
}
+ // before we write to the response, we need to make
+ // sure the header is written exactly once; we do
+ // that by checking if a status code has been set,
+ // and if so, that means we haven't written the
+ // header OR the default status code will be written
+ // by the standard library
+ if rw.statusCode > 0 {
+ rw.ResponseWriter.WriteHeader(rw.statusCode)
+ rw.statusCode = 0
+ }
+
switch {
case rw.w != nil:
n, err = rw.w.Write(p)
@@ -148,7 +159,7 @@ func (rw *responseWriter) Write(p []byte) (int, error) {
return n, err
}
-// init should be called before we write a response, if rw.buf is not nil.
+// init should be called before we write a response, if rw.buf has contents.
func (rw *responseWriter) init() {
if rw.Header().Get("Content-Encoding") == "" && rw.buf.Len() >= rw.config.MinLength {
rw.w = rw.config.writerPools[rw.encodingName].Get().(Encoder)
@@ -157,11 +168,6 @@ func (rw *responseWriter) init() {
rw.Header().Set("Content-Encoding", rw.encodingName)
}
rw.Header().Del("Accept-Ranges") // we don't know ranges for dynamically-encoded content
- status := rw.statusCode
- if status == 0 {
- status = http.StatusOK
- }
- rw.ResponseWriter.WriteHeader(status)
}
// Close writes any remaining buffered response and
@@ -187,6 +193,14 @@ func (rw *responseWriter) Close() error {
default:
_, err = rw.ResponseWriter.Write(p)
}
+ } else if rw.statusCode != 0 {
+ // it is possible that a body was not written, and
+ // a header was not even written yet, even though
+ // we are closing; ensure the proper status code is
+ // written exactly once, or we risk breaking requests
+ // that rely on If-None-Match, for example
+ rw.ResponseWriter.WriteHeader(rw.statusCode)
+ rw.statusCode = 0
}
if rw.w != nil {
err2 := rw.w.Close()