We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8e33ded commit fb8eccaCopy full SHA for fb8ecca
processor/memorylimiterprocessor/internal/mock_exporter.go
@@ -51,7 +51,7 @@ func (e *MockExporter) ConsumeLogs(_ context.Context, ld plog.Logs) error {
51
func (e *MockExporter) SetDestAvailable(available bool) {
52
if available {
53
// Pretend we delivered all queued accepted logs.
54
- atomic.AddInt64(&e.deliveredLogCount, e.acceptedLogCount)
+ atomic.AddInt64(&e.deliveredLogCount, atomic.LoadInt64(&e.acceptedLogCount))
55
56
// Get rid of the delivered logs so that memory can be collected.
57
e.Logs = nil
0 commit comments