From 5644fbd17af113c2d65ffbad71548eb26898ee18 Mon Sep 17 00:00:00 2001 From: Piotr Jaszczyk Date: Mon, 4 Jun 2018 13:51:29 +0200 Subject: Fix wire protocol decoder refCnt issue We should use retain + slice because every reactor-netty operator automatically releases the buffer. Change-Id: Ie0282e70fadb56d56fc410a08e036fb0ca10584c Signed-off-by: Piotr Jaszczyk Issue-ID: DCAEGEN2-601 --- .../dcae/collectors/veshv/tests/component/VesHvSpecification.kt | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'hv-collector-ct') diff --git a/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt b/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt index 2cfb785e..5990fd0a 100644 --- a/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt +++ b/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt @@ -47,21 +47,22 @@ object VesHvSpecification : Spek({ val msgWithInvalidPayload = invalidVesMessage() val msgWithInvalidFrame = invalidWireFrame() val validMessage = vesMessage(Domain.HVRANMEAS) + val refCntBeforeSending = msgWithInvalidDomain.refCnt() sut.handleConnection(msgWithInvalidDomain, msgWithInvalidPayload, msgWithInvalidFrame, validMessage) assertThat(msgWithInvalidDomain.refCnt()) .describedAs("message with invalid domain should be released") - .isEqualTo(0) + .isEqualTo(refCntBeforeSending) assertThat(msgWithInvalidPayload.refCnt()) .describedAs("message with invalid payload should be released") - .isEqualTo(0) + .isEqualTo(refCntBeforeSending) assertThat(msgWithInvalidFrame.refCnt()) .describedAs("message with invalid frame should be released") - .isEqualTo(0) + .isEqualTo(refCntBeforeSending) assertThat(validMessage.refCnt()) .describedAs("handled message should be released") - .isEqualTo(0) + .isEqualTo(refCntBeforeSending) } } -- cgit 1.2.3-korg