diff options
| author | chrislusf <chris.lu@gmail.com> | 2016-04-14 01:30:26 -0700 |
|---|---|---|
| committer | chrislusf <chris.lu@gmail.com> | 2016-04-14 01:30:26 -0700 |
| commit | 0649d778a72d4c0c27b3f2049fdb6f6e18956a65 (patch) | |
| tree | fd8f58c8639aba6038cf6bef0d382fc806a8b48c /go/storage/volume.go | |
| parent | 95e0d2f1b236f97f70d51a62c3df6a937a27286d (diff) | |
| download | seaweedfs-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.go | 3 |
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") } |
