fix race condition

7 years ago · 0e27fac290
parent ac6a0f7511
commit 0e27fac290
1 changed files with 1 additions and 1 deletions
--- a/transport/internet/udp/dispatcher_test.go
+++ b/transport/internet/udp/dispatcher_test.go
@ -72,5 +72,5 @@ func TestSameDestinationDispatching(t *testing.T) {
 	cancel()
 	assert(count, Equals, uint32(1))
-	assert(msgCount, Equals, uint32(6))
+	assert(atomic.LoadUint32(&msgCount), Equals, uint32(6))
 }