Code Review / cps.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: e2a699f) | patch
Performance Improvement: Use hazelcast blocking queue 50/130450/8
authorToineSiebelink <toine.siebelink@est.tech>
Mon, 29 Aug 2022 11:35:33 +0000 (12:35 +0100)
committerToineSiebelink <toine.siebelink@est.tech>
Mon, 29 Aug 2022 11:35:33 +0000 (12:35 +0100)
commit6b2cdc63c02cc2d1a9bc9d43997ab14e740d7973
tree68bb0534bf74db93d8c0756ec210c0efa502eb91tree | snapshot
parente2a699f90d9b755230ea960df21abef55bc305cecommit | diff
Performance Improvement: Use hazelcast blocking queue

- Introducing hazelcast for queue and progress map
- process batch of 100 at the time
- decreased module sync watchdog sleeptime to 5 seconds
- separate module sync tasks in new class and some other async preparations and easier testing
- tests for batching in module sync watchdog
- remove qualifiers annotation (support) where no longer needed

Issue-ID: CPS-1210
Issue-ID: CPS-1126
Signed-off-by: ToineSiebelink <toine.siebelink@est.tech>
Change-Id: I0a7d3755bf774e27c5688741bddb01f427d4a8a7
16 files changed:
cps-application/src/main/resources/application.yml diff | blob | history
cps-ncmp-service/lombok.config diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/embeddedcache/SynchronizationCacheConfig.java [new file with mode: 0644] blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/embeddedcache/SynchronizationSemaphoresConfig.java [deleted file] blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/inventory/sync/DataSyncWatchdog.java diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncService.java diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncTasks.java [new file with mode: 0644] blob
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncWatchdog.java diff | blob | history
cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/inventory/sync/SyncUtils.java diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/config/embeddedcache/SynchronizationCacheConfigSpec.groovy [moved from cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/config/embeddedcache/SynchronizationSemaphoresConfigSpec.groovy with 53% similarity] diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncServiceSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncTasksSpec.groovy [new file with mode: 0644] blob
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/inventory/sync/ModuleSyncWatchdogSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/inventory/sync/SyncUtilsSpec.groovy diff | blob | history
cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/utils/YangDataConverterSpec.groovy [new file with mode: 0644] blob
cps-service/src/main/java/org/onap/cps/spi/model/DataNode.java diff | blob | history
"cps"