X-Git-Url: http://git.iain.cx/?a=blobdiff_plain;f=state%2Fstate.go;h=de0d4ff7b1992065bba6885ba92d45d3e7076671;hb=ac65d456eb98d64e3262ce8c3ac3d1ee0a27ee9f;hp=124b88425ccfb012db032c08a14d751323986787;hpb=99e8324ae6cc0c84dd9ced4486b4d7b6c049790c;p=pstop.git diff --git a/state/state.go b/state/state.go index 124b884..de0d4ff 100644 --- 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,32 +32,45 @@ const ( showIO = iota showLocks = iota showUsers = iota + showMutex = iota + showStages = iota ) type State struct { + finished bool datadir string dbh *sql.DB 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) { state.dbh = dbh + state.finished = false 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) @@ -62,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() @@ -83,6 +104,16 @@ func (state *State) Setup(dbh *sql.DB) { state.SetDatadir(datadir) } +// have we finished ? +func (state State) Finished() bool { + return state.finished +} + +// indicate we have finished +func (state *State) SetFinished() { + state.finished = true +} + // do a fresh collection of data and then update the initial values based on that. func (state *State) ResetDBStatistics() { state.CollectAll() @@ -94,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()) } @@ -117,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()) } @@ -152,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() { @@ -169,6 +205,10 @@ func (state *State) Display() { state.displayLocks() case showUsers: state.displayUsers() + case showMutex: + state.displayMutex() + case showStages: + state.displayStages() } } } @@ -187,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-- } @@ -198,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++ @@ -230,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 ! } @@ -255,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) @@ -356,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 @@ -368,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 ... @@ -385,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() } }