perf: do not flush wal when receive consensus msgs (#273)

* perf: do not flush wal when receive consensus msgs
Finschia · Jul 8, 2021 · 50cffac · 50cffac
1 parent 162c63c
commit 50cffac
Showing 1 changed file with 2 additions and 6 deletions.
diff --git 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 {