From 9a089482dcf0d26788b1d991034799cac0b4fc85 Mon Sep 17 00:00:00 2001 From: Jae Kwon Date: Fri, 28 Oct 2016 11:58:09 -0700 Subject: [PATCH] Unnest --- consensus/wal.go | 31 ++++++++++++++++--------------- 1 file changed, 16 insertions(+), 15 deletions(-) diff --git a/consensus/wal.go b/consensus/wal.go index 78a7f1d24..aa2dabe32 100644 --- a/consensus/wal.go +++ b/consensus/wal.go @@ -70,23 +70,24 @@ func (wal *WAL) Exists() bool { // called in newStep and for each pass in receiveRoutine func (wal *WAL) Save(clm ConsensusLogMessageInterface) { - if wal != nil { - if wal.light { - // in light mode we only write new steps, timeouts, and our own votes (no proposals, block parts) - if mi, ok := clm.(msgInfo); ok { - _ = mi - if mi.PeerKey != "" { - return - } + if wal == nil { + return + } + if wal.light { + // in light mode we only write new steps, timeouts, and our own votes (no proposals, block parts) + if mi, ok := clm.(msgInfo); ok { + _ = mi + if mi.PeerKey != "" { + return } } - var clmBytes = wire.JSONBytes(ConsensusLogMessage{time.Now(), clm}) - var n int - var err error - wire.WriteTo(append(clmBytes, byte('\n')), wal.fp, &n, &err) // one message per line - if err != nil { - PanicQ(Fmt("Error writing msg to consensus wal. Error: %v \n\nMessage: %v", err, clm)) - } + } + var clmBytes = wire.JSONBytes(ConsensusLogMessage{time.Now(), clm}) + var n int + var err error + wire.WriteTo(append(clmBytes, byte('\n')), wal.fp, &n, &err) // one message per line + if err != nil { + PanicQ(Fmt("Error writing msg to consensus wal. Error: %v \n\nMessage: %v", err, clm)) } }