From 50cffac25a804216d4a2a71e4fd7835882c2fcb7 Mon Sep 17 00:00:00 2001 From: egonspace Date: Thu, 10 Jun 2021 16:11:51 +0900 Subject: [PATCH] perf: do not flush wal when receive consensus msgs (#273) * perf: do not flush wal when receive consensus msgs --- consensus/state.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/consensus/state.go b/consensus/state.go index 72e2a7a55..bd6acc035 100644 --- a/consensus/state.go +++ b/consensus/state.go @@ -844,12 +844,8 @@ func (cs *State) receiveRoutine(maxSteps int) { cs.handleMsg(mi) case mi = <-cs.internalMsgQueue: - err := cs.wal.WriteSync(mi) // NOTE: fsync - if err != nil { - panic(fmt.Sprintf( - "failed to write %v msg to consensus WAL due to %v; check your file system and restart the node", - mi, err, - )) + if err := cs.wal.Write(mi); err != nil { + cs.Logger.Error("failed writing to WAL", "err", err) } if _, ok := mi.Msg.(*VoteMessage); ok {