Add new mutex page inspired by: http://www.percona.com/blog/2015/01/06/getting-mutex...

[pstop.git] / p_s / events_waits_summary_global_by_event_name / events_waits_summary_global_by_event_name.go

diff --git a/p_s/events_waits_summary_global_by_event_name/events_waits_summary_global_by_event_name.go b/p_s/events_waits_summary_global_by_event_name/events_waits_summary_global_by_event_name.go
new file mode 100644 (file)
index 0000000..7560cdb
--- /dev/null
+++ b/p_s/events_waits_summary_global_by_event_name/events_waits_summary_global_by_event_name.go
@@ -0,0 +1,141 @@
+// p_s - library routines for pstop.
+//
+// This file contains the library routines for managing the
+// events_waits_summary_global_by_event_name table.
+package events_waits_summary_global_by_event_name
+
+import (
+       "database/sql"
+       "fmt"
+       "time"
+
+       "github.com/sjmudd/pstop/lib"
+       "github.com/sjmudd/pstop/p_s"
+)
+
+// a table of rows
+type Table_events_waits_summary_global_by_event_name struct {
+       p_s.RelativeStats
+       p_s.InitialTime
+       want_latency bool
+       initial      events_waits_summary_global_by_event_name_rows // initial data for relative values
+       current      events_waits_summary_global_by_event_name_rows // last loaded values
+       results      events_waits_summary_global_by_event_name_rows // results (maybe with subtraction)
+       totals       events_waits_summary_global_by_event_name_row  // totals of results
+}
+
+func (t *Table_events_waits_summary_global_by_event_name) SetWantsLatency(want_latency bool) {
+       t.want_latency = want_latency
+}
+
+func (t Table_events_waits_summary_global_by_event_name) WantsLatency() bool {
+       return t.want_latency
+}
+
+// Collect() collects data from the db, updating initial
+// values if needed, and then subtracting initial values if we want
+// relative values, after which it stores totals.
+func (t *Table_events_waits_summary_global_by_event_name) Collect(dbh *sql.DB) {
+       start := time.Now()
+       // lib.Logger.Println("Table_events_waits_summary_global_by_event_name.Collect() BEGIN")
+       t.current = select_tiwsbt_rows(dbh)
+       lib.Logger.Println("t.current collected", len(t.current), "row(s) from SELECT")
+
+       if len(t.initial) == 0 && len(t.current) > 0 {
+               lib.Logger.Println("t.initial: copying from t.current (initial setup)")
+               t.initial = make(events_waits_summary_global_by_event_name_rows, len(t.current))
+               copy(t.initial, t.current)
+       }
+
+       // check for reload initial characteristics
+       if t.initial.needs_refresh(t.current) {
+               lib.Logger.Println("t.initial: copying from t.current (data needs refreshing)")
+               t.initial = make(events_waits_summary_global_by_event_name_rows, len(t.current))
+               copy(t.initial, t.current)
+       }
+
+       t.make_results()
+
+       // lib.Logger.Println( "t.initial:", t.initial )
+       // lib.Logger.Println( "t.current:", t.current )
+       lib.Logger.Println("t.initial.totals():", t.initial.totals())
+       lib.Logger.Println("t.current.totals():", t.current.totals())
+       // lib.Logger.Println("t.results:", t.results)
+       // lib.Logger.Println("t.totals:", t.totals)
+       lib.Logger.Println("Table_events_waits_summary_global_by_event_name.Collect() END, took:", time.Duration(time.Since(start)).String())
+}
+
+func (t *Table_events_waits_summary_global_by_event_name) make_results() {
+       // lib.Logger.Println( "- t.results set from t.current" )
+       t.results = make(events_waits_summary_global_by_event_name_rows, len(t.current))
+       copy(t.results, t.current)
+       if t.WantRelativeStats() {
+               // lib.Logger.Println( "- subtracting t.initial from t.results as WantRelativeStats()" )
+               t.results.subtract(t.initial)
+       }
+
+       // lib.Logger.Println( "- sorting t.results" )
+       t.results.Sort()
+       // lib.Logger.Println( "- collecting t.totals from t.results" )
+       t.totals = t.results.totals()
+}
+
+// reset the statistics to current values
+func (t *Table_events_waits_summary_global_by_event_name) SyncReferenceValues() {
+       // lib.Logger.Println( "Table_events_waits_summary_global_by_event_name.SyncReferenceValues() BEGIN" )
+
+       t.SetNow()
+       t.initial = make(events_waits_summary_global_by_event_name_rows, len(t.current))
+       copy(t.initial, t.current)
+
+       t.make_results()
+
+       // lib.Logger.Println( "Table_events_waits_summary_global_by_event_name.SyncReferenceValues() END" )
+}
+
+func (t Table_events_waits_summary_global_by_event_name) EmptyRowContent() string {
+       return t.emptyRowContent()
+}
+
+func (t *Table_events_waits_summary_global_by_event_name) Headings() string {
+       var r events_waits_summary_global_by_event_name_row
+
+       return r.headings()
+}
+
+func (t Table_events_waits_summary_global_by_event_name) RowContent(max_rows int) []string {
+       rows := make([]string, 0, max_rows)
+
+       for i := range t.results {
+               if i < max_rows {
+                       rows = append(rows, t.results[i].row_content(t.totals))
+               }
+       }
+
+       return rows
+}
+
+func (t Table_events_waits_summary_global_by_event_name) emptyRowContent() string {
+       var r events_waits_summary_global_by_event_name_row
+
+       return r.row_content(r)
+}
+
+func (t Table_events_waits_summary_global_by_event_name) TotalRowContent() string {
+       return t.totals.row_content(t.totals)
+}
+
+func (t Table_events_waits_summary_global_by_event_name) Description() string {
+       count := t.count_rows()
+       return fmt.Sprintf("Mutex Latency (events_waits_summary_global_by_event_name) %d rows", count)
+}
+
+func (t Table_events_waits_summary_global_by_event_name) count_rows() int {
+       var count int
+       for row := range t.results {
+               if t.results[row].SUM_TIMER_WAIT > 0 {
+                       count++
+               }
+       }
+       return count
+}