meh

mreiferson · mreiferson · commit fc72e0273bf0 · 2015-12-19T11:19:10.000-05:00
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
 }
 

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,11 @@ func (c *Channel) Empty() error {`
`214`	`214`	`}`
`215`	`215`
`216`	`216`	`finish:`
`217`		`- // TODO: (WAL) reset cursor`
	`217`	`+ idx, err := c.cursor.Reset()`
	`218`	`+ if err != nil {`
	`219`	`+ return err`
	`220`	`+ }`
	`221`	`+ c.rs.AddRange(Range{Low: c.rs.Ranges[0].Low, High: int64(idx)})`
`218`	`222`	`return nil`
`219`	`223`	`}`
`220`	`224`