aboutsummaryrefslogtreecommitdiff
path: root/go/weed
diff options
context:
space:
mode:
authorchrislusf <chris.lu@gmail.com>2016-04-15 11:56:53 -0700
committerchrislusf <chris.lu@gmail.com>2016-04-15 11:56:53 -0700
commitb03e7b26b53c2c579ae13755c3fac47f67c6f40c (patch)
treee02bc29295ee90f5a9f33065175baa54353ed55b /go/weed
parent3fb98a904bf5d67e7f51797fbee0aa7ddffb5903 (diff)
downloadseaweedfs-b03e7b26b53c2c579ae13755c3fac47f67c6f40c.tar.xz
seaweedfs-b03e7b26b53c2c579ae13755c3fac47f67c6f40c.zip
add []byte caching and pooling
fixes https://github.com/chrislusf/seaweedfs/issues/211
Diffstat (limited to 'go/weed')
-rw-r--r--go/weed/weed_server/volume_server_handlers_sync.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/go/weed/weed_server/volume_server_handlers_sync.go b/go/weed/weed_server/volume_server_handlers_sync.go
index cb24f7cd6..c52c93bd2 100644
--- a/go/weed/weed_server/volume_server_handlers_sync.go
+++ b/go/weed/weed_server/volume_server_handlers_sync.go
@@ -50,8 +50,8 @@ func (vs *VolumeServer) getVolumeDataContentHandler(w http.ResponseWriter, r *ht
}
offset := uint32(util.ParseUint64(r.FormValue("offset"), 0))
size := uint32(util.ParseUint64(r.FormValue("size"), 0))
- content, rawBytes, err := storage.ReadNeedleBlob(v.DataFile(), int64(offset)*storage.NeedlePaddingSize, size)
- defer storage.ReleaseBytes(rawBytes)
+ content, block, err := storage.ReadNeedleBlob(v.DataFile(), int64(offset)*storage.NeedlePaddingSize, size)
+ defer storage.ReleaseBytes(block.Bytes)
if err != nil {
writeJsonError(w, r, http.StatusInternalServerError, err)
return