try {
transaction.add(op.mutate(bridge).addMutation(bridge.getProtocolsColumn().getSchema(),
Mutator.DELETE,bridge.getProtocolsColumn().getData()));
+ LOG.info("Removed ProtocolEntry : {} for OVSDB Bridge : {} ",
+ protocolString, bridge.getName());
} catch (SchemaVersionMismatchException e) {
schemaMismatchLog("protocols", "Bridge", e);
}
Mutator.INSERT,bridge.getProtocolsColumn().getData())
.where(bridge.getNameColumn().getSchema().opEqual(bridge.getNameColumn().getData()))
.build());
+ LOG.info("Updated ProtocolEntry : {} for OVSDB Bridge : {} ",
+ protocolString, bridge.getName());
} catch (SchemaVersionMismatchException e) {
schemaMismatchLog("protocols", "Bridge", e);
}
transaction.add(op.delete(qos.getSchema())
.where(qos.getUuidColumn().getSchema().opEqual(new UUID(qosUuid.getValue())))
.build());
+ LOG.info("Removed QoS Uuid : {} for node : {} ",
+ origQosEntry.getQosId(), ovsdbNodeIid);
} else {
LOG.warn("Unable to delete QoS{} for node {} because it was not found in the "
+ "operational store, and thus we cannot retrieve its UUID",
UUID namedUuid = new UUID(SouthboundConstants.QOS_NAMED_UUID_PREFIX
+ TransactUtils.bytesToHexString(qosEntry.getQosId().getValue().getBytes()));
transaction.add(op.insert(qos).withId(namedUuid.toString())).build();
+ LOG.info("Added QoS Uuid: {} for node : {} ",
+ namedUuid, ovsdbNode);
} else {
UUID uuid = new UUID(operQosUuid.getValue());
Qos extraQos = TyperUtils.getTypedRowWrapper(
extraQos.getUuidColumn().setData(uuid);
transaction.add(op.update(qos)
.where(extraQos.getUuidColumn().getSchema().opEqual(uuid)).build());
+ LOG.info("Updated QoS Uuid : {} for node : {} ",
+ operQosUuid, ovsdbNode);
}
transaction.build();
}