From d492504d704a4ef5c03b89185d4ad12b246090a1 Mon Sep 17 00:00:00 2001 From: Aravind Srinivasan Date: Mon, 15 May 2017 09:01:48 -0700 Subject: [PATCH] Address CR comments --- services/outputhost/deadletterqueue.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/services/outputhost/deadletterqueue.go b/services/outputhost/deadletterqueue.go index 658942b8..a135fad8 100644 --- a/services/outputhost/deadletterqueue.go +++ b/services/outputhost/deadletterqueue.go @@ -82,7 +82,7 @@ type deadLetterQueue struct { closeCh chan struct{} consumerM3Client metrics.Client m3Client metrics.Client - dlqWG sync.WaitGroup + wg sync.WaitGroup } func newDeadLetterQueue(ctx thrift.Context, lclLg bark.Logger, cgDesc shared.ConsumerGroupDescription, metaClient metadata.TChanMetadataService, m3Client metrics.Client, consumerM3Client metrics.Client) (dlq *deadLetterQueue, err error) { @@ -96,7 +96,7 @@ func newDeadLetterQueue(ctx thrift.Context, lclLg bark.Logger, cgDesc shared.Con m3Client: m3Client, } - dlq.dlqWG.Add(2) + dlq.wg.Add(2) go dlq.publishBuffer() go dlq.publish() @@ -142,7 +142,7 @@ func newDeadLetterQueue(ctx thrift.Context, lclLg bark.Logger, cgDesc shared.Con } func (dlq *deadLetterQueue) publishBuffer() { - defer dlq.dlqWG.Done() + defer dlq.wg.Done() var buffer []*cherami.ConsumerMessage var peekVal *cherami.ConsumerMessage var dlqPublishBufferOutCh chan *cherami.ConsumerMessage @@ -191,7 +191,7 @@ func (dlq *deadLetterQueue) publishBuffer() { } func (dlq *deadLetterQueue) publish() { - defer dlq.dlqWG.Done() + defer dlq.wg.Done() var err error for { select { @@ -261,6 +261,6 @@ func (dlq *deadLetterQueue) close() { dlq.publisher.Close() } close(dlq.closeCh) - dlq.dlqWG.Wait() + dlq.wg.Wait() } }