Skip to content

Commit 340e063

Browse files
fix: fix unit test failure
1 parent fd98860 commit 340e063

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

delayed_spans.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,12 @@ func (ds *delayedSpans) flush() {
4242
continue
4343
}
4444

45-
if sensor.Agent().Ready() {
45+
// Get agent ready status under proper synchronization
46+
muSensor.Lock()
47+
agentReady := sensor != nil && sensor.Agent().Ready()
48+
muSensor.Unlock()
49+
50+
if agentReady {
4651
s.tracer.recorder.RecordSpan(s)
4752
} else {
4853
ds.append(s)

delayed_spans_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ func TestPartiallyFlushDelayedSpans(t *testing.T) {
5656

5757
notReadyAfter := maxDelayedSpans / 10
5858
sensor.agent = &eventuallyNotReadyClient{
59-
notReadyAfter: uint64(notReadyAfter),
59+
notReadyAfter: uint64(notReadyAfter * 2),
6060
}
6161

6262
delayed.flush()

0 commit comments

Comments
 (0)