Add LeakDetection to StreamChannelConnectionCaptureSerializerTest

Signed-off-by: Andre Kurait <[email protected]>
opensearch-project · May 2, 2024 · 751d880 · 751d880
1 parent 48c1051
commit 751d880
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/TrafficCapture/captureOffloader/build.gradle b/TrafficCapture/captureOffloader/build.gradle
@@ -28,6 +28,7 @@ dependencies {
     implementation group: 'org.projectlombok', name: 'lombok', version: '1.18.26'
     implementation group: 'org.slf4j', name: 'slf4j-api', version: '2.0.7'
 
+    testImplementation testFixtures(project(path: ':testUtilities'))
     testImplementation project(':coreUtilities')
     testImplementation group: 'org.apache.logging.log4j', name: 'log4j-api', version: '2.20.0'
     testImplementation group: 'org.apache.logging.log4j', name: 'log4j-core', version: '2.20.0'

diff --git a/...rg/opensearch/migrations/trafficcapture/StreamChannelConnectionCaptureSerializerTest.java b/...rg/opensearch/migrations/trafficcapture/StreamChannelConnectionCaptureSerializerTest.java
@@ -25,6 +25,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.CsvSource;
 import org.junit.jupiter.params.provider.ValueSource;
+import org.opensearch.migrations.testutils.WrapWithNettyLeakDetection;
 import org.opensearch.migrations.trafficcapture.StreamChannelConnectionCaptureSerializerTest.StreamManager.NullStreamManager;
 import org.opensearch.migrations.trafficcapture.protos.CloseObservation;
 import org.opensearch.migrations.trafficcapture.protos.ConnectionExceptionObservation;
@@ -37,6 +38,7 @@
 import org.opensearch.migrations.trafficcapture.protos.WriteSegmentObservation;
 
 @Slf4j
+@WrapWithNettyLeakDetection(repetitions = 4)
 class StreamChannelConnectionCaptureSerializerTest {
 
     public static final String TEST_TRAFFIC_STREAM_ID_STRING = "Test";