Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 1383775) | patch
Enhance wire protocol 89/58689/1
authorfkrzywka <filip.krzywka@nokia.com>
Tue, 3 Jul 2018 08:14:38 +0000 (10:14 +0200)
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Thu, 2 Aug 2018 11:41:04 +0000 (13:41 +0200)
commitf8a9a10a75bf139203fe9ea48a01708c7bda0781
tree634321d472c69d67f817cd2e689dc25c10af7c1atree | snapshot
parent1383775f3df00bd08a7ac14fe1278858bdef6487commit | diff
Enhance wire protocol

Handle new wire frame message type which should allow clients to
indicate that all data has been sent to collector

Change xNF Simulator to send end-of-transmission message
after sending all messages

Close ves-hv-collector stream after encountering EOT message

Remove duplicated file in project

Closes ONAP-391

Change-Id: Idb6afc41d4bb0220a29df10c2aecfd76acd3ad16
Signed-off-by: fkrzywka <filip.krzywka@nokia.com>
Issue-ID: DCAEGEN2-601
16 files changed:
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/impl/VesHvCollector.kt diff | blob | history
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/WireChunkDecoder.kt diff | blob | history
hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/wire/WireChunkDecoderTest.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/messages.kt diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/WireFrameMessages.kt [moved from hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/WireFrame.kt with 81% similarity] diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/codec.kt diff | blob | history
hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/errors.kt diff | blob | history
hv-collector-domain/src/test/kotlin/org/onap/dcae/collectors/veshv/domain/WireFrameCodecsTest.kt diff | blob | history
hv-collector-xnf-simulator/sample-request.json [deleted file] blob | history
hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/api/MessageGenerator.kt diff | blob | history
hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/HttpServer.kt diff | blob | history
hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/MessageGeneratorImpl.kt diff | blob | history
hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt diff | blob | history
High Volume VES Collector