- 0 * mockCpsDataService.saveData('NFP-Operational', 'some-cm-handle-1', jsonString, _)
+ 0 * mockCpsDataService.saveData(*_)
+ }
+
+ def 'Data Sync for Cm Handle that is already being processed.'() {
+ given: 'sync utilities returns a cm handle'
+ mockSyncUtils.getUnsynchronizedReadyCmHandles() >> [yangModelCmHandle1]
+ and: 'the shared data sync semaphore indicate it is already being processed'
+ mockDataSyncSemaphores.putIfAbsent('cm-handle-1', _, _, _) >> 'something (not null)'
+ when: 'data sync poll is executed'
+ objectUnderTest.executeUnSynchronizedReadyCmHandlePoll()
+ then: 'it is NOT processed e.g. state is not requested'
+ 0 * mockInventoryPersistence.getCmHandleState(*_)