aboutsummaryrefslogtreecommitdiff
path: root/go/storage/volume.go
diff options
context:
space:
mode:
authorchrislusf <chris.lu@gmail.com>2016-04-14 01:30:26 -0700
committerchrislusf <chris.lu@gmail.com>2016-04-14 01:30:26 -0700
commit0649d778a72d4c0c27b3f2049fdb6f6e18956a65 (patch)
treefd8f58c8639aba6038cf6bef0d382fc806a8b48c /go/storage/volume.go
parent95e0d2f1b236f97f70d51a62c3df6a937a27286d (diff)
downloadseaweedfs-0649d778a72d4c0c27b3f2049fdb6f6e18956a65.tar.xz
seaweedfs-0649d778a72d4c0c27b3f2049fdb6f6e18956a65.zip
pooling []byte
reduce the number of requests to make([]byte)
Diffstat (limited to 'go/storage/volume.go')
-rw-r--r--go/storage/volume.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/go/storage/volume.go b/go/storage/volume.go
index 5c6b12e9b..af552a10f 100644
--- a/go/storage/volume.go
+++ b/go/storage/volume.go
@@ -159,6 +159,7 @@ func (v *Volume) isFileUnchanged(n *Needle) bool {
if ok && nv.Offset > 0 {
oldNeedle := new(Needle)
err := oldNeedle.ReadData(v.dataFile, int64(nv.Offset)*NeedlePaddingSize, nv.Size, v.Version())
+ defer oldNeedle.ReleaseMemory()
if err != nil {
glog.V(0).Infof("Failed to check updated file %v", err)
return false
@@ -288,6 +289,7 @@ func (v *Volume) readNeedle(n *Needle) (int, error) {
}
err := n.ReadData(v.dataFile, int64(nv.Offset)*NeedlePaddingSize, nv.Size, v.Version())
if err != nil {
+ n.ReleaseMemory()
return 0, err
}
bytesRead := len(n.Data)
@@ -304,6 +306,7 @@ func (v *Volume) readNeedle(n *Needle) (int, error) {
if uint64(time.Now().Unix()) < n.LastModified+uint64(ttlMinutes*60) {
return bytesRead, nil
}
+ n.ReleaseMemory()
return -1, errors.New("Not Found")
}