From 32995860c32aa86b81ff096f3f3c26cb05afa05b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Peter=20=C5=A0tibran=C3=BD?= Date: Wed, 8 Jun 2022 09:45:35 +0200 Subject: [PATCH] Fix comments. --- tsdb/chunks/chunk_write_queue.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tsdb/chunks/chunk_write_queue.go b/tsdb/chunks/chunk_write_queue.go index 071c92c85d..33498654c8 100644 --- a/tsdb/chunks/chunk_write_queue.go +++ b/tsdb/chunks/chunk_write_queue.go @@ -249,7 +249,7 @@ func (c *chunkWriteQueue) queueIsEmpty() bool { } func (c *chunkWriteQueue) queueIsFull() bool { - // When the queue is full and blocked on the writer the chunkRefMap has one more job than the cap of the jobCh + // When the queue is full and blocked on the writer the chunkRefMap has one more job than the capacity of the queue // because one job is currently being processed and blocked in the writer. return c.queueSize() == c.jobs.maxSize+1 } @@ -258,7 +258,7 @@ func (c *chunkWriteQueue) queueSize() int { c.chunkRefMapMtx.Lock() defer c.chunkRefMapMtx.Unlock() - // Looking at chunkRefMap instead of jobCh because the job is popped from the chan before it has - // been fully processed, it remains in the chunkRefMap until the processing is complete. + // Looking at chunkRefMap instead of jobs queue because the job is popped from the queue before it has + // been fully processed, but it remains in the chunkRefMap until the processing is complete. return len(c.chunkRefMap) }