From 7720d7df980cfce198040dfb00cb078d97e47722 Mon Sep 17 00:00:00 2001 From: Qiannan Date: Wed, 5 Feb 2020 02:16:30 +1300 Subject: [PATCH] util: resolve data race (#14610) --- util/stmtsummary/statement_summary.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/util/stmtsummary/statement_summary.go b/util/stmtsummary/statement_summary.go index ee148603596d8..0248388180162 100644 --- a/util/stmtsummary/statement_summary.go +++ b/util/stmtsummary/statement_summary.go @@ -727,9 +727,10 @@ func (ssElement *stmtSummaryByDigestElement) add(sei *StmtExecInfo, intervalSeco if commitDetails.GetCommitTsTime > ssElement.maxGetCommitTsTime { ssElement.maxGetCommitTsTime = commitDetails.GetCommitTsTime } - ssElement.sumCommitBackoffTime += commitDetails.CommitBackoffTime - if commitDetails.CommitBackoffTime > ssElement.maxCommitBackoffTime { - ssElement.maxCommitBackoffTime = commitDetails.CommitBackoffTime + commitBackoffTime := atomic.LoadInt64(&commitDetails.CommitBackoffTime) + ssElement.sumCommitBackoffTime += commitBackoffTime + if commitBackoffTime > ssElement.maxCommitBackoffTime { + ssElement.maxCommitBackoffTime = commitBackoffTime } resolveLockTime := atomic.LoadInt64(&commitDetails.ResolveLockTime) ssElement.sumResolveLockTime += resolveLockTime