git://git.iain.cx/iain
/
pstop.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
bump up version to 0.0.15
[pstop.git]
/
performance_schema
/
file_summary_by_instance
/
file_summary_by_instance.go
diff --git
a/performance_schema/file_summary_by_instance/file_summary_by_instance.go
b/performance_schema/file_summary_by_instance/file_summary_by_instance.go
index
5340ed7
..
737caa8
100644
(file)
--- a/
performance_schema/file_summary_by_instance/file_summary_by_instance.go
+++ b/
performance_schema/file_summary_by_instance/file_summary_by_instance.go
@@
-6,8
+6,10
@@
package file_summary_by_instance
import (
"database/sql"
import (
"database/sql"
+ "fmt"
+ "time"
-
//
"github.com/sjmudd/pstop/lib"
+ "github.com/sjmudd/pstop/lib"
ps "github.com/sjmudd/pstop/performance_schema"
)
ps "github.com/sjmudd/pstop/performance_schema"
)
@@
-55,7
+57,7
@@
type File_summary_by_instance struct {
}
// reset the statistics to current values
}
// reset the statistics to current values
-func (t *File_summary_by_instance)
UpdateInitial
Values() {
+func (t *File_summary_by_instance)
SyncReference
Values() {
t.SetNow()
t.initial = make(file_summary_by_instance_rows, len(t.current))
copy(t.initial, t.current)
t.SetNow()
t.initial = make(file_summary_by_instance_rows, len(t.current))
copy(t.initial, t.current)
@@
-73,6
+75,7
@@
func (t *File_summary_by_instance) UpdateInitialValues() {
// Collect data from the db, then merge it in.
func (t *File_summary_by_instance) Collect(dbh *sql.DB) {
// Collect data from the db, then merge it in.
func (t *File_summary_by_instance) Collect(dbh *sql.DB) {
+ start := time.Now()
// UPDATE current from db handle
t.current = merge_by_table_name(select_fsbi_rows(dbh), t.global_variables)
// UPDATE current from db handle
t.current = merge_by_table_name(select_fsbi_rows(dbh), t.global_variables)
@@
-102,6
+105,7
@@
func (t *File_summary_by_instance) Collect(dbh *sql.DB) {
// setup the totals
t.totals = t.results.totals()
// setup the totals
t.totals = t.results.totals()
+ lib.Logger.Println("File_summary_by_instance.Collect() took:", time.Duration(time.Since(start)).String())
}
// return the headings for a table
}
// return the headings for a table
@@
-136,7
+140,8
@@
func (t File_summary_by_instance) EmptyRowContent() string {
}
func (t File_summary_by_instance) Description() string {
}
func (t File_summary_by_instance) Description() string {
- return "File I/O by filename (file_summary_by_instance)"
+ count := t.count_rows()
+ return fmt.Sprintf("File I/O by filename (file_summary_by_instance) %4d row(s) ", count)
}
// create a new structure and include various variable values:
}
// create a new structure and include various variable values:
@@
-149,3
+154,13
@@
func NewFileSummaryByInstance(global_variables map[string]string) *File_summary_
return n
}
return n
}
+
+func (t File_summary_by_instance) count_rows() int {
+ var count int
+ for row := range t.results {
+ if t.results[row].SUM_TIMER_WAIT > 0 {
+ count++
+ }
+ }
+ return count
+}