Remove time.Ticker and adjust polling mechanism

[pstop.git] / performance_schema / table_lock_waits_summary_by_table / table_lock_waits_summary_by_table.go

diff --git a/performance_schema/table_lock_waits_summary_by_table/table_lock_waits_summary_by_table.go b/performance_schema/table_lock_waits_summary_by_table/table_lock_waits_summary_by_table.go
index 2977298..5ae561f 100644 (file)
--- a/performance_schema/table_lock_waits_summary_by_table/table_lock_waits_summary_by_table.go
+++ b/performance_schema/table_lock_waits_summary_by_table/table_lock_waits_summary_by_table.go
@@ -5,8 +5,9 @@ package table_lock_waits_summary_by_table
 import (
        "database/sql"
        _ "github.com/go-sql-driver/mysql"
+       "time"
 
-       // "github.com/sjmudd/pstop/lib"
+       "github.com/sjmudd/pstop/lib"
        ps "github.com/sjmudd/pstop/performance_schema"
 )
 
@@ -22,6 +23,7 @@ type Table_lock_waits_summary_by_table struct {
 
 // Collect data from the db, then merge it in.
 func (t *Table_lock_waits_summary_by_table) Collect(dbh *sql.DB) {
+       start := time.Now()
        t.current = select_tlwsbt_rows(dbh)
 
        if len(t.initial) == 0 && len(t.current) > 0 {
@@ -36,6 +38,7 @@ func (t *Table_lock_waits_summary_by_table) Collect(dbh *sql.DB) {
        }
 
        t.make_results()
+       lib.Logger.Println("Table_lock_waits_summary_by_table.Collect() took:", time.Duration(time.Since(start)).String())
 }
 
 func (t *Table_lock_waits_summary_by_table) make_results() {
@@ -54,7 +57,7 @@ func (t *Table_lock_waits_summary_by_table) make_results() {
 }
 
 // reset the statistics to current values
-func (t *Table_lock_waits_summary_by_table) UpdateInitialValues() {
+func (t *Table_lock_waits_summary_by_table) SyncReferenceValues() {
        t.SetNow()
        t.initial = make(table_lock_waits_summary_by_table_rows, len(t.current))
        copy(t.initial, t.current)