Skip to content

Commit

Permalink
Fix comments. (#248)
Browse files Browse the repository at this point in the history
  • Loading branch information
pstibrany authored Jun 8, 2022
1 parent 1e2d2fb commit 55236be
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tsdb/chunks/chunk_write_queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand All @@ -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)
}

0 comments on commit 55236be

Please sign in to comment.