meh

nsqio · Dec 19, 2015 · af55c2a · af55c2a
1 parent d20e1b8
commit af55c2a
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
 }