bump version to v0.3.2

[pstop.git] / state / state.go

diff --git a/state/state.go b/state/state.go
index 8f56b4d..de0d4ff 100644 (file)
--- a/state/state.go
+++ b/state/state.go
@@ -9,14 +9,18 @@ import (
        "strings"
        "time"
 
-       "github.com/sjmudd/pstop/i_s"
+       "github.com/sjmudd/pstop/i_s/processlist"
        "github.com/sjmudd/pstop/lib"
+       ewsgben "github.com/sjmudd/pstop/p_s/events_waits_summary_global_by_event_name"
+       essgben "github.com/sjmudd/pstop/p_s/events_stages_summary_global_by_event_name"
        fsbi "github.com/sjmudd/pstop/p_s/file_summary_by_instance"
        "github.com/sjmudd/pstop/p_s/ps_table"
+       "github.com/sjmudd/pstop/p_s/setup_instruments"
        tiwsbt "github.com/sjmudd/pstop/p_s/table_io_waits_summary_by_table"
        tlwsbt "github.com/sjmudd/pstop/p_s/table_lock_waits_summary_by_table"
        "github.com/sjmudd/pstop/screen"
        "github.com/sjmudd/pstop/version"
+       "github.com/sjmudd/pstop/wait_info"
 )
 
 // what information to show
@@ -28,6 +32,8 @@ const (
        showIO      = iota
        showLocks   = iota
        showUsers   = iota
+       showMutex   = iota
+       showStages  = iota
 )
 
 type State struct {
@@ -37,13 +43,17 @@ type State struct {
        help                bool
        hostname            string
        fsbi                ps_table.Tabler // ufsbi.File_summary_by_instance
-       tiwsbt              tiwsbt.Table_io_waits_summary_by_table
+       tiwsbt              tiwsbt.Object
        tlwsbt              ps_table.Tabler // tlwsbt.Table_lock_waits_summary_by_table
-       users               i_s.Processlist
+       ewsgben             ps_table.Tabler // ewsgben.Events_waits_summary_global_by_event_name
+       essgben             ps_table.Tabler // essgben.Events_stages_summary_global_by_event_name
+       users               processlist.Object
        screen              screen.TermboxScreen
        show                Show
        mysql_version       string
        want_relative_stats bool
+       wait_info.WaitInfo  // embedded
+       setup_instruments   setup_instruments.SetupInstruments
 }
 
 func (state *State) Setup(dbh *sql.DB) {
@@ -52,10 +62,15 @@ func (state *State) Setup(dbh *sql.DB) {
 
        state.screen.Initialise()
 
+       state.setup_instruments = setup_instruments.NewSetupInstruments(dbh)
+       state.setup_instruments.EnableMonitoring()
+
        _, variables := lib.SelectAllGlobalVariablesByVariableName(state.dbh)
        // setup to their initial types/values
        state.fsbi = fsbi.NewFileSummaryByInstance(variables)
-       state.tlwsbt = new(tlwsbt.Table_lock_waits_summary_by_table)
+       state.tlwsbt = new(tlwsbt.Object)
+       state.ewsgben = new(ewsgben.Object)
+       state.essgben = new(essgben.Object)
 
        state.want_relative_stats = true // we show info from the point we start collecting data
        state.fsbi.SetWantRelativeStats(state.want_relative_stats)
@@ -64,8 +79,12 @@ func (state *State) Setup(dbh *sql.DB) {
        state.tlwsbt.SetNow()
        state.tiwsbt.SetWantRelativeStats(state.want_relative_stats)
        state.tiwsbt.SetNow()
-       state.users.SetWantRelativeStats(state.want_relative_stats) // ignored
-       state.users.SetNow()                                        // ignored
+       state.users.SetWantRelativeStats(state.want_relative_stats)   // ignored
+       state.users.SetNow()                                          // ignored
+       state.essgben.SetWantRelativeStats(state.want_relative_stats)
+       state.essgben.SetNow()
+       state.ewsgben.SetWantRelativeStats(state.want_relative_stats) // ignored
+       state.ewsgben.SetNow()                                        // ignored
 
        state.ResetDBStatistics()
 
@@ -106,6 +125,7 @@ func (state *State) SyncReferenceValues() {
        state.fsbi.SyncReferenceValues()
        state.tlwsbt.SyncReferenceValues()
        state.tiwsbt.SyncReferenceValues()
+       state.essgben.SyncReferenceValues()
        lib.Logger.Println("state.SyncReferenceValues() took", time.Duration(time.Since(start)).String())
 }
 
@@ -129,6 +149,10 @@ func (state *State) Collect() {
                state.tlwsbt.Collect(state.dbh)
        case showUsers:
                state.users.Collect(state.dbh)
+       case showMutex:
+               state.ewsgben.Collect(state.dbh)
+       case showStages:
+               state.essgben.Collect(state.dbh)
        }
        lib.Logger.Println("state.Collect() took", time.Duration(time.Since(start)).String())
 }
@@ -164,7 +188,7 @@ func (state State) Help() bool {
        return state.help
 }
 
-// states go: showLatency -> showOps -> showIO -> showLocks -> showUsers
+// states go: showLatency -> showOps -> showIO -> showLocks -> showUsers -> showMutex -> showStages
 
 // display the output according to the mode we are in
 func (state *State) Display() {
@@ -181,6 +205,10 @@ func (state *State) Display() {
                        state.displayLocks()
                case showUsers:
                        state.displayUsers()
+               case showMutex:
+                       state.displayMutex()
+               case showStages:
+                       state.displayStages()
                }
        }
 }
@@ -199,7 +227,7 @@ func (state *State) fix_latency_setting() {
 // change to the previous display mode
 func (state *State) DisplayPrevious() {
        if state.show == showLatency {
-               state.show = showUsers
+               state.show = showStages
        } else {
                state.show--
        }
@@ -210,7 +238,7 @@ func (state *State) DisplayPrevious() {
 
 // change to the next display mode
 func (state *State) DisplayNext() {
-       if state.show == showUsers {
+       if state.show == showStages {
                state.show = showLatency
        } else {
                state.show++
@@ -242,6 +270,10 @@ func (state State) displayLine0() {
                        initial = state.tlwsbt.Last()
                case showUsers:
                        initial = state.users.Last()
+               case showStages:
+                       initial = state.essgben.Last()
+               case showMutex:
+                       initial = state.ewsgben.Last()
                default:
                        // should not get here !
                }
@@ -267,6 +299,10 @@ func (state State) displayDescription() {
                description = state.tlwsbt.Description()
        case showUsers:
                description = state.users.Description()
+       case showMutex:
+               description = state.ewsgben.Description()
+       case showStages:
+               description = state.essgben.Description()
        }
 
        state.screen.PrintAt(0, 1, description)
@@ -368,6 +404,55 @@ func (state *State) displayUsers() {
        state.screen.BoldPrintAt(0, state.screen.Height()-1, state.users.TotalRowContent())
 }
 
+func (state *State) displayMutex() {
+       state.screen.BoldPrintAt(0, 2, state.ewsgben.Headings())
+
+       // print out the data
+       max_rows := state.screen.Height() - 3
+       row_content := state.ewsgben.RowContent(max_rows)
+
+       // print out rows
+       for k := range row_content {
+               y := 3 + k
+               state.screen.PrintAt(0, y, row_content[k])
+       }
+       // print out empty rows
+       for k := len(row_content); k < (state.screen.Height() - 3); k++ {
+               y := 3 + k
+               if y < state.screen.Height()-1 {
+                       state.screen.PrintAt(0, y, state.ewsgben.EmptyRowContent())
+               }
+       }
+
+       // print out the totals at the bottom
+       state.screen.BoldPrintAt(0, state.screen.Height()-1, state.ewsgben.TotalRowContent())
+}
+
+func (state *State) displayStages() {
+       state.screen.BoldPrintAt(0, 2, state.essgben.Headings())
+
+       // print out the data
+       max_rows := state.screen.Height() - 3
+       row_content := state.essgben.RowContent(max_rows)
+
+       // print out rows
+       for k := range row_content {
+               y := 3 + k
+               state.screen.PrintAt(0, y, row_content[k])
+       }
+       // print out empty rows
+       for k := len(row_content); k < (state.screen.Height() - 3); k++ {
+               y := 3 + k
+               if y < state.screen.Height()-1 {
+                       state.screen.PrintAt(0, y, state.essgben.EmptyRowContent())
+               }
+       }
+
+       // print out the totals at the bottom
+       state.screen.BoldPrintAt(0, state.screen.Height()-1, state.essgben.TotalRowContent())
+}
+
+
 // do we want to show all p_s data?
 func (state State) WantRelativeStats() bool {
        return state.want_relative_stats
@@ -380,6 +465,8 @@ func (state *State) SetWantRelativeStats(want_relative_stats bool) {
        state.fsbi.SetWantRelativeStats(want_relative_stats)
        state.tlwsbt.SetWantRelativeStats(state.want_relative_stats)
        state.tiwsbt.SetWantRelativeStats(state.want_relative_stats)
+       state.ewsgben.SetWantRelativeStats(state.want_relative_stats)
+       state.essgben.SetWantRelativeStats(state.want_relative_stats)
 }
 
 // if there's a better way of doing this do it better ...
@@ -397,6 +484,7 @@ func (state *State) ScreenSetSize(width, height int) {
 func (state *State) Cleanup() {
        state.screen.Close()
        if state.dbh != nil {
+               state.setup_instruments.RestoreConfiguration()
                _ = state.dbh.Close()
        }
 }