Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 767d046) | patch
Fix TCP stream framing issue 09/58409/1
authorPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Thu, 7 Jun 2018 09:52:16 +0000 (11:52 +0200)
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Wed, 1 Aug 2018 11:06:43 +0000 (13:06 +0200)
commit07bbbf71cd65b29f446a1b475add87f20365db83
treee64fcf12c21e46358043744476d68765634d7f6ftree | snapshot
parent767d0464a19e0949d2919e6df15c9653dec50503commit | diff
Fix TCP stream framing issue

Because of the nature of TCP protocol we receive consecutive IO buffer
snapshots - not separate messages. That means that we need to join
incomming buffers and then split it into separate WireFrames.

Closes ONAP-312
Change-Id: I84ba0ec58a41ff9026f2fca24d2b15f3adcf0a19
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
Issue-ID: DCAEGEN2-601
39 files changed:
docker-compose.yml diff | blob | history
hv-collector-client-simulator/Dockerfile diff | blob | history
hv-collector-client-simulator/pom.xml diff | blob | history
hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/config/ArgBasedClientConfiguration.kt diff | blob | history
hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/config/ClientConfiguration.kt diff | blob | history
hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/MessageFactory.kt diff | blob | history
hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/VesHvClient.kt diff | blob | history
hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/main.kt diff | blob | history
hv-collector-client-simulator/src/test/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/MessageFactoryTest.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/CollectorFactory.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidator.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoder.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesHvCollector.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/AdapterFactory.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/KafkaSinkProvider.kt [new file with mode: 0644] blob
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/LoggingSinkProvider.kt [new file with mode: 0644] blob
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/socket/NettyTcpServer.kt diff | blob | history
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/wire/StreamBufferEmitter.kt [new file with mode: 0644] blob
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/wire/WireDecoder.kt [new file with mode: 0644] blob
hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/wire/WireFrameSink.kt [new file with mode: 0644] blob
hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoderTest.kt diff | blob | history
hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/WireDecoderTest.kt [deleted file] blob | history
hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/wire/WireDecoderTest.kt [new file with mode: 0644] blob
hv-collector-core/src/test/resources/logback-test.xml [moved from hv-collector-core/src/test/resources/logback.xml with 93% similarity] diff | blob | history
hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt diff | blob | history
hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt diff | blob | history
hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/utils.kt diff | blob | history
hv-collector-ct/src/test/resources/logback-test.xml diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/WireFrame.kt diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/exceptions/EmptyWireFrameException.kt [new file with mode: 0644] blob
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/exceptions/InvalidWireFrameMarkerException.kt [moved from hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/WireDecoder.kt with 62% similarity] diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/exceptions/MissingWireFrameBytesException.kt [new file with mode: 0644] blob
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/exceptions/WireFrameDecodingException.kt [new file with mode: 0644] blob
hv-collector-domain/src/test/kotlin/org/onap/dcae/collectors/veshv/domain/WireFrameTest.kt diff | blob | history
hv-collector-main/Dockerfile diff | blob | history
hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt diff | blob | history
hv-collector-main/src/main/resources/logback.xml diff | blob | history
hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/logging/Logger.kt diff | blob | history
High Volume VES Collector