percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-15 07:55:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed PT-69

Browse Source
This commit is contained in:
Carlos Salguero
2017-02-13 13:08:54 -03:00
parent cfc705bf91
commit 92b1109804
7 changed files with 43 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/go/pt-mongodb-summary/main.go
View File

@@ -190,7 +190,10 @@ func main() {
if err != nil {
message := fmt.Sprintf("Cannot connect to %q", di.Addrs[0])
if di.Username != "" || di.Password != "" {
message += fmt.Sprintf(" using user: %q, password: %q", di.Username, di.Password)
message += fmt.Sprintf(" using user: %q", di.Username)
if strings.HasPrefix(di.Password, "=") {
message += " (probably you are using = with -p or -u instead of a blank space)"
}
}
message += fmt.Sprintf(". %s", err.Error())
log.Errorf(message)
@@ -198,6 +201,13 @@ func main() {
}
defer session.Close()
hostInfo, err := GetHostinfo(session)
if err != nil {
message := fmt.Sprintf("Cannot connect to %q: %s", di.Addrs[0], err.Error())
log.Errorf(message)
os.Exit(2)
}
if replicaMembers, err := util.GetReplicasetMembers(dialer, di); err != nil {
log.Warnf("[Error] cannot get replicaset members: %v\n", err)
os.Exit(2)
@@ -207,13 +217,9 @@ func main() {
t.Execute(os.Stdout, replicaMembers)
}
hostInfo, err := GetHostinfo(session)
if err != nil {
log.Warnf("[Error] cannot get host info: %v\n", err)
} else {
t := template.Must(template.New("hosttemplateData").Parse(templates.HostInfo))
t.Execute(os.Stdout, hostInfo)
}
// Host Info
t := template.Must(template.New("hosttemplateData").Parse(templates.HostInfo))
t.Execute(os.Stdout, hostInfo)
if opts.RunningOpsSamples > 0 {
if rops, err := GetOpCountersStats(session, opts.RunningOpsSamples, time.Duration(opts.RunningOpsInterval)*time.Millisecond); err != nil {
@@ -247,11 +253,14 @@ func main() {
}
}
if cwi, err := GetClusterwideInfo(session); err != nil {
log.Printf("[Error] cannot get cluster wide info: %v\n", err)
} else {
t := template.Must(template.New("clusterwide").Parse(templates.Clusterwide))
t.Execute(os.Stdout, cwi)
// individual servers won't know about this info
if hostInfo.NodeType == "mongos" {
if cwi, err := GetClusterwideInfo(session); err != nil {
log.Printf("[Error] cannot get cluster wide info: %v\n", err)
} else {
t := template.Must(template.New("clusterwide").Parse(templates.Clusterwide))
t.Execute(os.Stdout, cwi)
}
}
if bs, err := GetBalancerStats(session); err != nil {
@@ -351,6 +360,7 @@ func GetClusterwideInfo(session pmgo.SessionManager) (*clusterwideInfo, error) {
if err != nil {
continue
}
cwi.TotalCollectionsCount += len(collections)
for _, collName := range collections {
var collStats proto.CollStats