From c9ea5f13de416ce74f62a9cbbeb3bd7b37069c9d Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Tue, 14 Apr 2015 13:15:54 -0700 Subject: [PATCH] Correct out-of-date comment --- messaging/broker.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/messaging/broker.go b/messaging/broker.go index 3d6cb3da6a..b4ffa88c1f 100644 --- a/messaging/broker.go +++ b/messaging/broker.go @@ -542,12 +542,11 @@ func (b *Broker) SetTopicMaxIndex(topicID, index uint64, u url.URL) error { func (b *Broker) applySetTopicMaxIndex(m *Message) { topicID, index, u := unmarshalTopicIndex(m.Data) - // Set index if it's not already set higher. + // Track the highest replicated index for the topic, per data node URL. if t := b.topics[topicID]; t != nil { t.mu.Lock() defer t.mu.Unlock() - // Track the highest replicated index per data node URL t.indexByURL[u] = index } }