fix(gateway): settle qualification enqueue evidence

2026-07-30 05:38:51 +07:00
parent 99d9d7f85a
commit ff23fc9876
1 changed files with 2 additions and 1 deletions
@@ -835,7 +835,8 @@ func (p *qualificationPath) traverse(t *testing.T, payload []byte) (qualificatio
 	afterMetrics := p.server.Metrics()
 	deadline := time.Now().Add(2 * time.Second)
 	for (afterMetrics.ProcessingSamples < beforeMetrics.ProcessingSamples+1 ||
-		afterMetrics.MediaPackets <= beforeMetrics.MediaPackets) && time.Now().Before(deadline) {
+		afterMetrics.MediaPackets <= beforeMetrics.MediaPackets ||
+		p.session.mediaEnqueued.Load() <= beforeEnqueued) && time.Now().Before(deadline) {
 		runtime.Gosched()
 		afterMetrics = p.server.Metrics()
 	}