X-Git-Url: http://git.iain.cx/?a=blobdiff_plain;f=state%2Fstate.go;h=de0d4ff7b1992065bba6885ba92d45d3e7076671;hb=ac65d456eb98d64e3262ce8c3ac3d1ee0a27ee9f;hp=c799ccdf3bac228c3b35b2fd8bc3848b3390a845;hpb=9c17baa1e5fb1582c5bbed49280a9ee672142332;p=pstop.git diff --git a/state/state.go b/state/state.go index c799ccd..de0d4ff 100644 --- a/state/state.go +++ b/state/state.go @@ -9,15 +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/wait_info" + "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 @@ -29,6 +32,8 @@ const ( showIO = iota showLocks = iota showUsers = iota + showMutex = iota + showStages = iota ) type State struct { @@ -38,14 +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 + wait_info.WaitInfo // embedded + setup_instruments setup_instruments.SetupInstruments } func (state *State) Setup(dbh *sql.DB) { @@ -54,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) @@ -66,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() @@ -108,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()) } @@ -131,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()) } @@ -166,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() { @@ -183,6 +205,10 @@ func (state *State) Display() { state.displayLocks() case showUsers: state.displayUsers() + case showMutex: + state.displayMutex() + case showStages: + state.displayStages() } } } @@ -201,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-- } @@ -212,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++ @@ -244,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 ! } @@ -269,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) @@ -370,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 @@ -382,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 ... @@ -399,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() } }