meh

nsqio · Apr 16, 2016 · 66d1a7f · 66d1a7f
1 parent 7522107
commit 66d1a7f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/nsqd/channel.go b/nsqd/channel.go
@@ -214,7 +214,11 @@ func (c *Channel) Empty() error {
 	}
 
 finish:
-	// TODO: (WAL) reset cursor
+	idx, err := c.cursor.Reset()
+	if err != nil {
+		return err
+	}
+	c.rs.AddRange(Range{Low: c.rs.Ranges[0].Low, High: int64(idx)})
 	return nil
 }