From f4e6cf4439b38f6e84d33d84dc8ea915c1e71d8c Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Thu, 22 Dec 2016 15:01:02 -0500 Subject: [PATCH] consensus: sync wal.writeHeight --- consensus/wal.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/consensus/wal.go b/consensus/wal.go index 2c03027cd..099e3c1aa 100644 --- a/consensus/wal.go +++ b/consensus/wal.go @@ -104,4 +104,9 @@ func (wal *WAL) Save(wmsg WALMessage) { func (wal *WAL) writeHeight(height int) { wal.group.WriteLine(Fmt("#HEIGHT: %v", height)) + + // TODO: only flush when necessary + if err := wal.group.Flush(); err != nil { + PanicQ(Fmt("Error flushing consensus wal buf to file. Error: %v \n", err)) + } }