- private void updateReconciliationState(State state) {
- ReadWriteTransaction tx = broker.newReadWriteTransaction();
- InstanceIdentifier<ReconciliationStateList> instanceIdentifier = InstanceIdentifier
- .builder(ReconciliationState.class).child(ReconciliationStateList.class,
- new ReconciliationStateListKey(nodeId)).build();
- ReconciliationStateListBuilder stateBuilder = new ReconciliationStateListBuilder()
- .withKey(new ReconciliationStateListKey(nodeId))
- .setState(state);
- try {
- tx.merge(LogicalDatastoreType.OPERATIONAL, instanceIdentifier, stateBuilder.build(), true);
- tx.commit().get();
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("Exception while updating reconciliation state: {}", nodeId, e);
- }
+ private void updateReconciliationState(final ReconciliationState.ReconciliationStatus status) {
+ ReconciliationState state = new ReconciliationState(status, LocalDateTime.now());
+ reconciliationStates.put(nodeId.toString(),state);