fix depth

nsqio · Apr 16, 2016 · 7522107 · 7522107
1 parent 71d1c3a
commit 7522107
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/nsqd/channel_test.go b/nsqd/channel_test.go
@@ -142,7 +142,7 @@ func TestChannelEmpty(t *testing.T) {
 	equal(t, len(channel.inFlightPQ), 0)
 	equal(t, len(channel.deferredMessages), 0)
 	equal(t, len(channel.deferredPQ), 0)
-	equal(t, channel.Depth(), int64(0))
+	equal(t, channel.Depth(), uint64(0))
 }
 
 func TestChannelEmptyConsumer(t *testing.T) {

diff --git a/nsqd/topic.go b/nsqd/topic.go
@@ -158,7 +158,7 @@ func (t *Topic) Pub(data [][]byte) error {
 	if err != nil {
 		return err
 	}
-	t.rs.AddRange(Range{High: int64(startIdx), Low: int64(endIdx)})
+	t.rs.AddRange(Range{Low: int64(startIdx), High: int64(endIdx)})
 	atomic.AddUint64(&t.messageCount, uint64(len(data)))
 	return nil
 }