mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2024-11-15 01:54:06 -08:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Fix comments. (#248)

Browse source
This commit is contained in:
Peter Štibraný 2022-06-08 10:01:05 +02:00 committed by GitHub
parent 1e2d2fb2d8
commit 55236be04a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
tsdb/chunks/chunk_write_queue.go
View file

@ -249,7 +249,7 @@ func (c *chunkWriteQueue) queueIsEmpty() bool {
} }
func (c *chunkWriteQueue) queueIsFull() 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. // because one job is currently being processed and blocked in the writer.
return c.queueSize() == c.jobs.maxSize+1 return c.queueSize() == c.jobs.maxSize+1
} }
@ -258,7 +258,7 @@ func (c *chunkWriteQueue) queueSize() int {
c.chunkRefMapMtx.Lock() c.chunkRefMapMtx.Lock()
defer c.chunkRefMapMtx.Unlock() defer c.chunkRefMapMtx.Unlock()
// Looking at chunkRefMap instead of jobCh because the job is popped from the chan before it has // Looking at chunkRefMap instead of jobs queue because the job is popped from the queue before it has
// been fully processed, it remains in the chunkRefMap until the processing is complete. // been fully processed, but it remains in the chunkRefMap until the processing is complete.
return len(c.chunkRefMap) return len(c.chunkRefMap)
} }