From 66d1a7fde27aa3200b6a60e2428827b74b0e3cfc 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 d1376570d..dbddc690e 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 }