From 8f88d382a5544fdcbda3494feaf6e4b533c2436d Mon Sep 17 00:00:00 2001 From: chrislusf Date: Sat, 23 May 2015 10:16:01 -0700 Subject: [PATCH] Rename variables --- go/storage/volume.go | 16 ++++++++-------- go/storage/volume_vacuum.go | 4 ++-- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/go/storage/volume.go b/go/storage/volume.go index d5caef34a..e4cebea7c 100644 --- a/go/storage/volume.go +++ b/go/storage/volume.go @@ -24,8 +24,8 @@ type Volume struct { SuperBlock - accessLock sync.Mutex - lastModifiedTime uint64 //unix time in seconds + dataFileAccessLock sync.Mutex + lastModifiedTime uint64 //unix time in seconds } func NewVolume(dirname string, collection string, id VolumeId, needleMapKind NeedleMapType, replicaPlacement *ReplicaPlacement, ttl *TTL) (v *Volume, e error) { @@ -136,8 +136,8 @@ func (v *Volume) Size() int64 { // Close cleanly shuts down this volume func (v *Volume) Close() { - v.accessLock.Lock() - defer v.accessLock.Unlock() + v.dataFileAccessLock.Lock() + defer v.dataFileAccessLock.Unlock() v.nm.Close() _ = v.dataFile.Close() } @@ -186,8 +186,8 @@ func (v *Volume) write(n *Needle) (size uint32, err error) { err = fmt.Errorf("%s is read-only", v.dataFile.Name()) return } - v.accessLock.Lock() - defer v.accessLock.Unlock() + v.dataFileAccessLock.Lock() + defer v.dataFileAccessLock.Unlock() if v.isFileUnchanged(n) { size = n.DataSize glog.V(4).Infof("needle is unchanged!") @@ -231,8 +231,8 @@ func (v *Volume) delete(n *Needle) (uint32, error) { if v.readOnly { return 0, fmt.Errorf("%s is read-only", v.dataFile.Name()) } - v.accessLock.Lock() - defer v.accessLock.Unlock() + v.dataFileAccessLock.Lock() + defer v.dataFileAccessLock.Unlock() nv, ok := v.nm.Get(n.Id) //fmt.Println("key", n.Id, "volume offset", nv.Offset, "data_size", n.Size, "cached size", nv.Size) if ok { diff --git a/go/storage/volume_vacuum.go b/go/storage/volume_vacuum.go index 251027771..11dc30c4e 100644 --- a/go/storage/volume_vacuum.go +++ b/go/storage/volume_vacuum.go @@ -25,8 +25,8 @@ func (v *Volume) Compact() error { } func (v *Volume) commitCompact() error { glog.V(3).Infof("Committing vacuuming...") - v.accessLock.Lock() - defer v.accessLock.Unlock() + v.dataFileAccessLock.Lock() + defer v.dataFileAccessLock.Unlock() glog.V(3).Infof("Got Committing lock...") _ = v.dataFile.Close() var e error