test: TestHostNetwork Wait for results until go test times out

instrumentation/host/host_test.go

@@ -28,9 +28,10 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"go.opentelemetry.io/contrib/instrumentation/host"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric/metrictest"
+
+	"go.opentelemetry.io/contrib/instrumentation/host"
 )
 
 func getMetric(impl *metrictest.MeterImpl, name string, lbl attribute.KeyValue) float64 {
@@ -220,20 +221,18 @@ func TestHostNetwork(t *testing.T) {
 	require.NoError(t, err)
 
 	// As we are going to read the /proc file system for this info, sleep a while:
-	time.Sleep(time.Second)
-
-	impl.RunAsyncInstruments()
+	require.Eventually(t, func() bool {
+		hostAfter, err := net.IOCountersWithContext(ctx, false)
+		require.NoError(t, err)
 
-	hostAfter, err := net.IOCountersWithContext(ctx, false)
-	require.NoError(t, err)
+		return uint64(howMuch) <= hostAfter[0].BytesSent-hostBefore[0].BytesSent &&
+			uint64(howMuch) <= hostAfter[0].BytesRecv-hostBefore[0].BytesRecv
+	}, 30*time.Second, time.Second/2)
 
+	impl.RunAsyncInstruments()
 	hostTransmit := getMetric(impl, "system.network.io", host.AttributeNetworkTransmit[0])
 	hostReceive := getMetric(impl, "system.network.io", host.AttributeNetworkReceive[0])
 
-	// Check that the network transmit/receive used is greater than before:
-	require.LessOrEqual(t, uint64(howMuch), hostAfter[0].BytesSent-hostBefore[0].BytesSent)
-	require.LessOrEqual(t, uint64(howMuch), hostAfter[0].BytesRecv-hostBefore[0].BytesRecv)
-
 	// Check that the recorded measurements reflect the same change:
 	require.LessOrEqual(t, uint64(howMuch), uint64(hostTransmit)-hostBefore[0].BytesSent)
 	require.LessOrEqual(t, uint64(howMuch), uint64(hostReceive)-hostBefore[0].BytesRecv)