prometheus/storage/remote
Chris Marchbanks e970acb085
Fix deadlock between adding to queue and getting batch
Do not block when trying to write a batch to the queue. This can cause
appends to lock forever if the only thing reading from the queue needs
the mutex to write. Instead, if batchQueue is full pop the sample that
was just added from the partial batch and return false. The code doing
the appending already handles retries with backoff.

Signed-off-by: Chris Marchbanks <csmarchbanks@gmail.com>
2022-03-07 17:15:57 -07:00
..
chunked.go Fix some warnings: 'redundant type from array, slice, or map composite literal' (#7109) 2020-04-15 11:17:41 +01:00
chunked_test.go Testify: move to require (#8122) 2020-10-29 09:43:23 +00:00
client.go Enable HTTP2 again (#9398) 2021-09-26 23:16:12 +02:00
client_test.go tests: Move from t.Errorf and others. (Part 2) (#9309) 2021-09-13 21:19:20 +02:00
codec.go storage: fix bug #10027 in iterators' Seek method 2021-12-16 12:07:35 +01:00
codec_test.go storage: expose bug in iterators #10027 2021-12-16 12:02:15 +01:00
ewma.go Replace sync/atomic with uber-go/atomic (#7683) 2020-07-30 13:15:42 +05:30
intern.go Move away from testutil, refactor imports (#8087) 2020-10-22 11:00:08 +02:00
intern_test.go Testify: move to require (#8122) 2020-10-29 09:43:23 +00:00
max_timestamp.go Remote: Do not collect non-initialized timestamp metrics (#8060) 2020-10-15 23:53:59 +02:00
metadata_watcher.go Fix imports formatting 2021-11-02 19:52:34 +01:00
metadata_watcher_test.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
queue_manager.go Fix deadlock between adding to queue and getting batch 2022-03-07 17:15:57 -07:00
queue_manager_test.go Write a test that reproduces the deadlock 2022-03-07 17:15:51 -07:00
read.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
read_handler.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
read_handler_test.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
read_test.go storage/remote: use t.TempDir instead of ioutil.TempDir on tests (#9811) 2021-11-19 15:21:45 -05:00
storage.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
storage_test.go storage/remote: use t.TempDir instead of ioutil.TempDir on tests (#9811) 2021-11-19 15:21:45 -05:00
write.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
write_handler.go Log time series details for out-of-order samples in remote write receiver (#9894) 2021-12-08 15:07:51 +00:00
write_handler_test.go Move packages out of deprecated pkg directory 2021-11-09 08:03:10 +01:00
write_test.go storage/remote: use t.TempDir instead of ioutil.TempDir on tests (#9811) 2021-11-19 15:21:45 -05:00