gerrit.onap Code Review - dcaegen2/collectors/hv-ves.git/commit

Code Review / dcaegen2 / collectors / hv-ves.git / commit

author	Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
	Thu, 7 Jun 2018 09:52:16 +0000 (11:52 +0200)
committer	Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
	Wed, 1 Aug 2018 11:06:43 +0000 (13:06 +0200)
commit	07bbbf71cd65b29f446a1b475add87f20365db83
tree	e64fcf12c21e46358043744476d68765634d7f6f	tree \| snapshot
parent	767d0464a19e0949d2919e6df15c9653dec50503	commit \| 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

RSS Atom