.ifPresent(writer -> writer.write(reply, false));
} catch (final Exception ex) {
LOG.warn("Stats processing of type {} for node {} failed during write-to-tx step",
- getMultipartType(), deviceInfo.getLOGValue(), ex);
+ getMultipartType(), deviceInfo, ex);
}
});
} catch (final Exception ex) {
getTxFacade(),
instanceIdentifier,
deviceRegistry.getDeviceFlowRegistry());
+ deviceRegistry.getDeviceFlowRegistry().processMarks();
break;
case OFPMPMETERCONFIG:
StatisticsGatheringUtils.deleteAllKnownMeters(
getTxFacade(),
instanceIdentifier,
deviceRegistry.getDeviceMeterRegistry());
+ deviceRegistry.getDeviceMeterRegistry().processMarks();
break;
case OFPMPGROUPDESC:
StatisticsGatheringUtils.deleteAllKnownGroups(
getTxFacade(),
instanceIdentifier,
deviceRegistry.getDeviceGroupRegistry());
+ deviceRegistry.getDeviceGroupRegistry().processMarks();
break;
default:
// no operation