diff options
author | Wisdom Omuya <deafgoat@gmail.com> | 2014-09-26 12:58:48 -0400 |
---|---|---|
committer | Wisdom Omuya <deafgoat@gmail.com> | 2014-09-26 12:58:48 -0400 |
commit | 0fb36de238e68748faab110302eca5ac098f5716 (patch) | |
tree | 495c203daf5631a51e0907123eb7379da5c42f1a /src | |
parent | 803dabf8bc0f7092c5aa6910cd7da4ac558119fc (diff) | |
download | mongo-0fb36de238e68748faab110302eca5ac098f5716.tar.gz |
fix mongostat overflow bug
Former-commit-id: 7edd195685d389d3b7a17228e2ac78c0ddbe3b9b
Diffstat (limited to 'src')
-rw-r--r-- | src/github.com/mongodb/mongo-tools/mongostat/mongostat_test.go | 8 | ||||
-rw-r--r-- | src/github.com/mongodb/mongo-tools/mongostat/stat_types.go | 100 |
2 files changed, 54 insertions, 54 deletions
diff --git a/src/github.com/mongodb/mongo-tools/mongostat/mongostat_test.go b/src/github.com/mongodb/mongo-tools/mongostat/mongostat_test.go index 8570cb6bdf8..7866982b595 100644 --- a/src/github.com/mongodb/mongo-tools/mongostat/mongostat_test.go +++ b/src/github.com/mongodb/mongo-tools/mongostat/mongostat_test.go @@ -7,8 +7,8 @@ import ( ) func TestStatLine(t *testing.T) { - faultsOld := 10 - faultsNew := 15 + faultsOld := int64(10) + faultsNew := int64(15) serverStatusOld := ServerStatus{ SampleTime: time.Now(), Host: "localhost", @@ -19,7 +19,7 @@ func TestStatLine(t *testing.T) { UptimeMillis: 1000, UptimeEstimate: 1000, LocalTime: time.Now(), - Asserts: map[string]int{}, + Asserts: map[string]int64{}, BackgroundFlushing: &FlushStats{ Flushes: 2, TotalMs: 100, @@ -113,7 +113,7 @@ func TestStatLine(t *testing.T) { UptimeMillis: 1000, UptimeEstimate: 1000, LocalTime: time.Now(), - Asserts: map[string]int{}, + Asserts: map[string]int64{}, BackgroundFlushing: &FlushStats{ Flushes: 2, TotalMs: 100, diff --git a/src/github.com/mongodb/mongo-tools/mongostat/stat_types.go b/src/github.com/mongodb/mongo-tools/mongostat/stat_types.go index 6e2e5b7543e..a821ba064ab 100644 --- a/src/github.com/mongodb/mongo-tools/mongostat/stat_types.go +++ b/src/github.com/mongodb/mongo-tools/mongostat/stat_types.go @@ -36,11 +36,11 @@ type ServerStatus struct { Version string `bson:"version"` Process string `bson:"process"` Pid int64 `bson:"pid"` - Uptime int `bson:"uptime"` + Uptime int64 `bson:"uptime"` UptimeMillis int64 `bson:"uptimeMillis"` - UptimeEstimate int `bson:"uptimeEstimate"` + UptimeEstimate int64 `bson:"uptimeEstimate"` LocalTime time.Time `bson:"localTime"` - Asserts map[string]int `bson:"asserts"` + Asserts map[string]int64 `bson:"asserts"` BackgroundFlushing *FlushStats `bson:"backgroundFlushing"` ExtraInfo *ExtraInfo `bson:"extra_info"` Connections *ConnectionStats `bson:"connections"` @@ -69,14 +69,14 @@ type ReplStatus struct { } type DBRecordStats struct { - AccessesNotInMemory int `bson:"accessesNotInMemory"` - PageFaultExceptionsThrown int `bson:"pageFaultExceptionsThrown"` + AccessesNotInMemory int64 `bson:"accessesNotInMemory"` + PageFaultExceptionsThrown int64 `bson:"pageFaultExceptionsThrown"` DBRecordAccesses map[string]RecordAccesses `bson:",inline"` } type RecordAccesses struct { - AccessesNotInMemory int `bson:"accessesNotInMemory"` - PageFaultExceptionsThrown int `bson:"pageFaultExceptionsThrown"` + AccessesNotInMemory int64 `bson:"accessesNotInMemory"` + PageFaultExceptionsThrown int64 `bson:"pageFaultExceptionsThrown"` } type MemStats struct { @@ -89,46 +89,46 @@ type MemStats struct { } type FlushStats struct { - Flushes int `bson:"flushes"` - TotalMs int `bson:"total_ms"` + Flushes int64 `bson:"flushes"` + TotalMs int64 `bson:"total_ms"` AverageMs float64 `bson:"average_ms"` - LastMs int `bson:"last_ms"` + LastMs int64 `bson:"last_ms"` LastFinished time.Time `bson:"last_finished"` } type ConnectionStats struct { - Current int `bson:"current"` - Available int `bson:"available"` + Current int64 `bson:"current"` + Available int64 `bson:"available"` TotalCreated int64 `bson:"totalCreated"` } type DurTiming struct { - Dt int `bson:"dt"` - PrepLogBuffer int `bson:"prepLogBuffer"` - WriteToJournal int `bson:"writeToJournal"` - WriteToDataFiles int `bson:"writeToDataFiles"` - RemapPrivateView int `bson:"remapPrivateView"` + Dt int64 `bson:"dt"` + PrepLogBuffer int64 `bson:"prepLogBuffer"` + WriteToJournal int64 `bson:"writeToJournal"` + WriteToDataFiles int64 `bson:"writeToDataFiles"` + RemapPrivateView int64 `bson:"remapPrivateView"` } type DurStats struct { - Commits int `bson:"commits"` - JournaledMB int `bson:"journaledMB"` - WriteToDataFilesMB int `bson:"writeToDataFilesMB"` - Compression int `bson:"compression"` - CommitsInWriteLock int `bson:"commitsInWriteLock"` - EarlyCommits int `bson:"earlyCommits"` + Commits int64 `bson:"commits"` + JournaledMB int64 `bson:"journaledMB"` + WriteToDataFilesMB int64 `bson:"writeToDataFilesMB"` + Compression int64 `bson:"compression"` + CommitsInWriteLock int64 `bson:"commitsInWriteLock"` + EarlyCommits int64 `bson:"earlyCommits"` TimeMs DurTiming } type QueueStats struct { - Total int `bson:"total"` - Readers int `bson:"readers"` - Writers int `bson:"writers"` + Total int64 `bson:"total"` + Readers int64 `bson:"readers"` + Writers int64 `bson:"writers"` } type ClientStats struct { - Total int `bson:"total"` - Readers int `bson:"readers"` - Writers int `bson:"writers"` + Total int64 `bson:"total"` + Readers int64 `bson:"readers"` + Writers int64 `bson:"writers"` } type GlobalLockStats struct { @@ -139,26 +139,26 @@ type GlobalLockStats struct { } type IndexCounterStats struct { - Accesses int `bson:"accesses"` - Hits int `bson:"hits"` - Misses int `bson:"misses"` - Resets int `bson:"resets"` - MissRatio int `bson:"missRatio"` + Accesses int64 `bson:"accesses"` + Hits int64 `bson:"hits"` + Misses int64 `bson:"misses"` + Resets int64 `bson:"resets"` + MissRatio int64 `bson:"missRatio"` } type NetworkStats struct { BytesIn int64 `bson:"bytesIn"` BytesOut int64 `bson:"bytesOut"` - NumRequests int `bson:"numRequests"` + NumRequests int64 `bson:"numRequests"` } type OpcountStats struct { - Insert int `bson:"insert"` - Query int `bson:"query"` - Update int `bson:"update"` - Delete int `bson:"delete"` - GetMore int `bson:"getmore"` - Command int `bson:"command"` + Insert int64 `bson:"insert"` + Query int64 `bson:"query"` + Update int64 `bson:"update"` + Delete int64 `bson:"delete"` + GetMore int64 `bson:"getmore"` + Command int64 `bson:"command"` } type ReadWriteLockTimes struct { @@ -174,7 +174,7 @@ type LockStats struct { } type ExtraInfo struct { - PageFaults *int `bson:"page_faults"` + PageFaults *int64 `bson:"page_faults"` } //StatHeader describes a single column for mongostat's terminal output, @@ -290,19 +290,19 @@ type StatLine struct { Host string //Opcounter fields - Insert, Query, Update, Delete, GetMore, Command int + Insert, Query, Update, Delete, GetMore, Command int64 //Replicated Opcounter fields - InsertR, QueryR, UpdateR, DeleteR, GetMoreR, CommandR int - Flushes int + InsertR, QueryR, UpdateR, DeleteR, GetMoreR, CommandR int64 + Flushes int64 Mapped, Virtual, Resident, NonMapped int64 - Faults int + Faults int64 HighestLocked *LockStatus IndexMissPercent float64 - QueuedReaders, QueuedWriters int - ActiveReaders, ActiveWriters int + QueuedReaders, QueuedWriters int64 + ActiveReaders, ActiveWriters int64 NetIn, NetOut int64 - NumConnections int + NumConnections int64 Time time.Time ReplSetName string NodeType string @@ -343,7 +343,7 @@ func computeLockDiffs(prevLocks, curLocks map[string]LockUsage) []LockUsage { } //formatOpcount returns a string for mongostat to display replset count -func formatOpcount(opcount, opcountRepl int, both bool) string { +func formatOpcount(opcount, opcountRepl int64, both bool) string { if both { return fmt.Sprintf("%v|%v", opcount, opcountRepl) } |