From 8c58b1633262cc9aa58e44dd18bf4e371c540a6f Mon Sep 17 00:00:00 2001 From: Jian Shen Date: Mon, 20 Apr 2020 10:38:06 -0700 Subject: [PATCH] add locks while accessing redolog internal maps --- redolog/file_redolog_manager.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/redolog/file_redolog_manager.go b/redolog/file_redolog_manager.go index 08aa33a0..9698b19f 100644 --- a/redolog/file_redolog_manager.go +++ b/redolog/file_redolog_manager.go @@ -162,9 +162,11 @@ func (r *FileRedoLogManager) AppendToRedoLog(upsertBatch *common.UpsertBatch) (i } // update current redo log size + r.Lock() r.CurrentRedoLogSize += uint32(len(upsertBatch.GetBuffer())) + 4 r.SizePerFile[r.CurrentFileCreationTime] += uint32(len(upsertBatch.GetBuffer())) + 4 r.TotalRedoLogSize += uint(len(upsertBatch.GetBuffer())) + 4 + r.Unlock() utils.GetReporter(r.tableName, r.shard).GetGauge(utils.CurrentRedologSize).Update(float64(r.CurrentRedoLogSize)) utils.GetReporter(r.tableName, r.shard).GetGauge(utils.SizeOfRedologs).Update(float64(r.TotalRedoLogSize))