usm: http2: Fixed a flaky test (#21260)

* usm: http2: Fixed a flaky test

* Fixed CR comment

Author: guyarb

pkg/network/usm/monitor_test.go

@@ -825,14 +825,11 @@ func (s *USMHTTP2Suite) TestHTTP2KernelTelemetry() {
 			},
 
 			expectedTelemetry: &usmhttp2.HTTP2Telemetry{
-				Request_seen:                     8,
-				Response_seen:                    8,
-				End_of_stream:                    16,
-				End_of_stream_rst:                0,
-				Path_exceeds_frame:               0,
-				Exceeding_max_interesting_frames: 0,
-				Exceeding_max_frames_to_filter:   0,
-				Path_size_bucket:                 [8]uint64{1, 1, 1, 1, 1, 1, 1, 1},
+				Request_seen:      8,
+				Response_seen:     8,
+				End_of_stream:     16,
+				End_of_stream_rst: 0,
+				Path_size_bucket:  [8]uint64{1, 1, 1, 1, 1, 1, 1, 1},
 			},
 		},
 	}
@@ -845,11 +842,22 @@ func (s *USMHTTP2Suite) TestHTTP2KernelTelemetry() {
 
 			tt.runClients(t, 1)
 
+			// We cannot predict if the client will send an RST frame or not, thus we cannot predict the number of
+			// frames with EOS or RST frames, which leads into a flaking test. Therefore, we are asserting that the
+			// gotten number of EOS or RST frames is at least the number of expected EOS frames.
+			expectedEOSOrRST := tt.expectedTelemetry.End_of_stream + tt.expectedTelemetry.End_of_stream_rst
 			var telemetry *usmhttp2.HTTP2Telemetry
 			assert.Eventually(t, func() bool {
 				telemetry, err = usmhttp2.Spec.Instance.(*usmhttp2.Protocol).GetHTTP2KernelTelemetry()
 				require.NoError(t, err)
-				return reflect.DeepEqual(tt.expectedTelemetry, telemetry)
+
+				return telemetry.Request_seen == tt.expectedTelemetry.Request_seen &&
+					telemetry.Response_seen == tt.expectedTelemetry.Response_seen &&
+					telemetry.Path_exceeds_frame == tt.expectedTelemetry.Path_exceeds_frame &&
+					telemetry.Exceeding_max_interesting_frames == tt.expectedTelemetry.Exceeding_max_interesting_frames &&
+					telemetry.Exceeding_max_frames_to_filter == tt.expectedTelemetry.Exceeding_max_frames_to_filter &&
+					telemetry.End_of_stream+telemetry.End_of_stream_rst >= expectedEOSOrRST &&
+					reflect.DeepEqual(telemetry.Path_size_bucket, tt.expectedTelemetry.Path_size_bucket)
 			}, time.Second*5, time.Millisecond*100)
 			if t.Failed() {
 				t.Logf("expected telemetry: %+v;\ngot: %+v", tt.expectedTelemetry, telemetry)