From af55c2a719fa0fea05019de0c9fbb645f55f5158 Mon Sep 17 00:00:00 2001 From: Matt Reiferson Date: Sat, 19 Dec 2015 11:19:10 -0500 Subject: [PATCH] meh --- nsqd/channel.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/nsqd/channel.go b/nsqd/channel.go index 073a80803..d7b56581e 100644 --- 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 }