gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

fix metrics

Browse source 
fix https://github.com/chrislusf/seaweedfs/issues/935
This commit is contained in:
Chris Lu 2019-04-22 12:32:10 -07:00
parent 0c96cfdb2e
commit 53e2e73de2
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
weed/storage/needle_map_metric.go
View file

@ -28,33 +28,33 @@ func (mm *mapMetric) logPut(key NeedleId, oldSize uint32, newSize uint32) {
mm.LogDeletionCounter(oldSize) mm.LogDeletionCounter(oldSize)
} }
} }
func (mm mapMetric) LogFileCounter(newSize uint32) { func (mm *mapMetric) LogFileCounter(newSize uint32) {
atomic.AddUint32(&mm.FileCounter, 1) atomic.AddUint32(&mm.FileCounter, 1)
atomic.AddUint64(&mm.FileByteCounter, uint64(newSize)) atomic.AddUint64(&mm.FileByteCounter, uint64(newSize))
} }
func (mm mapMetric) LogDeletionCounter(oldSize uint32) { func (mm *mapMetric) LogDeletionCounter(oldSize uint32) {
if oldSize > 0 { if oldSize > 0 {
atomic.AddUint32(&mm.DeletionCounter, 1) atomic.AddUint32(&mm.DeletionCounter, 1)
atomic.AddUint64(&mm.DeletionByteCounter, uint64(oldSize)) atomic.AddUint64(&mm.DeletionByteCounter, uint64(oldSize))
} }
} }
func (mm mapMetric) ContentSize() uint64 { func (mm *mapMetric) ContentSize() uint64 {
return atomic.LoadUint64(&mm.FileByteCounter) return atomic.LoadUint64(&mm.FileByteCounter)
} }
func (mm mapMetric) DeletedSize() uint64 { func (mm *mapMetric) DeletedSize() uint64 {
return atomic.LoadUint64(&mm.DeletionByteCounter) return atomic.LoadUint64(&mm.DeletionByteCounter)
} }
func (mm mapMetric) FileCount() int { func (mm *mapMetric) FileCount() int {
return int(atomic.LoadUint32(&mm.FileCounter)) return int(atomic.LoadUint32(&mm.FileCounter))
} }
func (mm mapMetric) DeletedCount() int { func (mm *mapMetric) DeletedCount() int {
return int(atomic.LoadUint32(&mm.DeletionCounter)) return int(atomic.LoadUint32(&mm.DeletionCounter))
} }
func (mm mapMetric) MaxFileKey() NeedleId { func (mm *mapMetric) MaxFileKey() NeedleId {
t := uint64(mm.MaximumFileKey) t := uint64(mm.MaximumFileKey)
return NeedleId(t) return NeedleId(t)
} }
func (mm mapMetric) MaybeSetMaxFileKey(key NeedleId) { func (mm *mapMetric) MaybeSetMaxFileKey(key NeedleId) {
if key > mm.MaxFileKey() { if key > mm.MaxFileKey() {
atomic.StoreUint64(&mm.MaximumFileKey, uint64(key)) atomic.StoreUint64(&mm.MaximumFileKey, uint64(key))
} }