remove empty wal entries

Consensys · May 3, 2022 · bc0552f · bc0552f
1 parent e95f163
commit bc0552f
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/raft/wal.go b/raft/wal.go
@@ -47,8 +47,16 @@ func (pm *ProtocolManager) replayWAL(maybeRaftSnapshot *raftpb.Snapshot) (*wal.W
 		fatalf("failed to read WAL: %s", err)
 	}
 
+	// filter empty entries
+	newEntries := make([]raftpb.Entry, 0, len(entries))
+	for i := range entries {
+		if len(entries[i].Data) > 0 {
+			newEntries = append(newEntries, entries[i])
+		}
+	}
+
 	pm.raftStorage.SetHardState(hardState)
-	pm.raftStorage.Append(entries)
+	pm.raftStorage.Append(newEntries)
 
-	return wal, entries
+	return wal, newEntries
 }