diff --git a/log_entry.go b/log_entry.go index dc62a1d1e7..4293fd4547 100644 --- a/log_entry.go +++ b/log_entry.go @@ -95,5 +95,5 @@ func (e *LogEntry) decode(r io.Reader) (int, error) { e.CommandName = pb.GetCommandName() e.Command = pb.Command - return length, nil + return length + 8 + 1, nil }