segment message set offset on write

travisjeffery · Nov 19, 2016 · 70f7d43 · 70f7d43
1 parent 309c097
commit 70f7d43
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/commitlog/commitlog.go b/commitlog/commitlog.go
@@ -79,11 +79,13 @@ func (l *CommitLog) Append(ms MessageSet) error {
 		}
 	}
 	position := l.activeSegment().Position
+	offset := l.activeSegment().NextOffset
+	ms.PutOffset(offset)
 	if _, err := l.activeSegment().Write(ms); err != nil {
 		return err
 	}
 	e := Entry{
-		Offset:   ms.Offset(),
+		Offset:   offset,
 		Position: position,
 	}
 	if err := l.activeSegment().Index.WriteEntry(e); err != nil {