From c83be540a912f4017c6cb20750910f68be330a71 Mon Sep 17 00:00:00 2001 From: Aleksandr Bezobchuk Date: Mon, 12 Jul 2021 15:01:11 -0400 Subject: [PATCH] consensus: avoid flushing WAL --- internal/consensus/state.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/internal/consensus/state.go b/internal/consensus/state.go index a20f488e4..bc3861aee 100644 --- a/internal/consensus/state.go +++ b/internal/consensus/state.go @@ -801,12 +801,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 {