Ensure (de)compressor is always closed.

common/isolatedclient/isolatedfake/isolatedfake.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 // Package isolatedfake implements an in-process fake Isolated server for
 // integration testing.
 package isolatedfake
 
 import (
         "bytes"
@@ skipping 175 matching lines @@
                 w.WriteHeader(405)
                 server.Fail(fmt.Errorf("invalid method: %s", r.Method))
                 return
         }
         decompressor, err := isolated.GetDecompressor(r.Body)
         if err != nil {
                 w.WriteHeader(500)
                 server.Fail(err)
                 return
         }
+        defer decompressor.Close()
         raw, err := ioutil.ReadAll(decompressor)
         if err != nil {
                 w.WriteHeader(500)
                 server.Fail(err)
                 return
         }
         digest := isolated.HexDigest(r.URL.Query().Get("digest"))
         if digest != isolated.HashBytes(raw) {
                 w.WriteHeader(400)
                 server.Fail(fmt.Errorf("invalid digest %#v", digest))
@@ skipping 60 matching lines @@
         blob, err := base64.StdEncoding.DecodeString(data.Content)
         if err != nil {
                 server.Fail(err)
                 return map[string]string{"err": err.Error()}
         }
         decompressor, err := isolated.GetDecompressor(bytes.NewReader(blob))
         if err != nil {
                 server.Fail(err)
                 return map[string]string{"err": err.Error()}
         }
+        defer decompressor.Close()
         raw, err := ioutil.ReadAll(decompressor)
         if err != nil {
                 server.Fail(err)
                 return map[string]string{"err": err.Error()}
         }
         if digest != isolated.HashBytes(raw) {
                 err := fmt.Errorf("invalid digest %#v", digest)
                 server.Fail(err)
                 return map[string]string{"err": err.Error()}
         }
 
         server.lock.Lock()
         defer server.lock.Unlock()
         server.contents[digest] = raw
         //log.Printf("  storing %s = %d bytes", digest, len(raw))
         return map[string]string{"ok": "true"}
 }