* @return read date
*/
public NormalizedNode readConfigurationData(final YangInstanceIdentifier path, final String withDefa) {
- try (DOMDataTreeReadTransaction tx = this.domDataBroker.newReadOnlyTransaction()) {
+ try (DOMDataTreeReadTransaction tx = domDataBroker.newReadOnlyTransaction()) {
return readDataViaTransaction(tx, CONFIGURATION, path, withDefa);
}
}
* @return read data
*/
public NormalizedNode readOperationalData(final YangInstanceIdentifier path) {
- try (DOMDataTreeReadTransaction tx = this.domDataBroker.newReadOnlyTransaction()) {
+ try (DOMDataTreeReadTransaction tx = domDataBroker.newReadOnlyTransaction()) {
return readDataViaTransaction(tx, OPERATIONAL, path);
}
}
requireNonNull(payload);
isMounted.set(false);
- final DOMDataTreeReadWriteTransaction newReadWriteTransaction = this.domDataBroker.newReadWriteTransaction();
+ final DOMDataTreeReadWriteTransaction newReadWriteTransaction = domDataBroker.newReadWriteTransaction();
final Status status = readDataViaTransaction(newReadWriteTransaction, CONFIGURATION, path) != null ? Status.OK
: Status.CREATED;
final FluentFuture<? extends CommitInfo> future = putDataViaTransaction(
final DOMDataTreeReadWriteTransaction patchTransaction;
if (mountPoint == null) {
schemaContext = patchContext.getInstanceIdentifierContext().getSchemaContext();
- patchTransaction = this.domDataBroker.newReadWriteTransaction();
+ patchTransaction = domDataBroker.newReadWriteTransaction();
} else {
schemaContext = modelContext(mountPoint);
final NormalizedNode payload, final String insert, final String point) {
isMounted.set(false);
FluentFuture<? extends CommitInfo> future =
- postDataViaTransaction(this.domDataBroker.newReadWriteTransaction(), CONFIGURATION, path, payload,
+ postDataViaTransaction(domDataBroker.newReadWriteTransaction(), CONFIGURATION, path, payload,
globalSchema, insert, point);
isMounted.remove();
return future;
// DELETE configuration
public FluentFuture<? extends CommitInfo> commitConfigurationDataDelete(final YangInstanceIdentifier path) {
- return deleteDataViaTransaction(this.domDataBroker.newReadWriteTransaction(), CONFIGURATION, path);
+ return deleteDataViaTransaction(domDataBroker.newReadWriteTransaction(), CONFIGURATION, path);
}
public FluentFuture<? extends CommitInfo> commitConfigurationDataDelete(
// RPC
public ListenableFuture<? extends DOMRpcResult> invokeRpc(final @NonNull QName type,
final @NonNull NormalizedNode input) {
- if (this.rpcService == null) {
+ if (rpcService == null) {
throw new RestconfDocumentedException(Status.SERVICE_UNAVAILABLE);
}
LOG.trace("Invoke RPC {} with input: {}", type, input);
- return this.rpcService.invokeRpc(type, input);
+ return rpcService.invokeRpc(type, input);
}
public void registerToListenDataChanges(final LogicalDatastoreType datastore, final Scope scope,
}
final YangInstanceIdentifier path = listener.getPath();
- DOMDataTreeChangeService changeService = this.domDataBroker.getExtensions()
+ DOMDataTreeChangeService changeService = domDataBroker.getExtensions()
.getInstance(DOMDataTreeChangeService.class);
if (changeService == null) {
throw new UnsupportedOperationException("DOMDataBroker does not support the DOMDataTreeChangeService"
- + this.domDataBroker);
+ + domDataBroker);
}
DOMDataTreeIdentifier root = new DOMDataTreeIdentifier(datastore, path);
ListenerRegistration<ListenerAdapter> registration =
final SchemaContext schemaContext, final String point, final UserLeafSetNode<?> readLeafList,
final boolean before) {
rwTransaction.delete(datastore, path.getParent().getParent());
- final InstanceIdentifierContext<?> instanceIdentifier = controllerContext.toInstanceIdentifier(point);
+ final InstanceIdentifierContext instanceIdentifier = controllerContext.toInstanceIdentifier(point);
int lastItemPosition = 0;
for (final LeafSetEntryNode<?> nodeChild : readLeafList.body()) {
if (nodeChild.getIdentifier().equals(instanceIdentifier.getInstanceIdentifier().getLastPathArgument())) {
final YangInstanceIdentifier path, final NormalizedNode payload, final SchemaContext schemaContext,
final String point, final MapNode readList, final boolean before) {
rwTransaction.delete(datastore, path.getParent().getParent());
- final InstanceIdentifierContext<?> instanceIdentifier = controllerContext.toInstanceIdentifier(point);
+ final InstanceIdentifierContext instanceIdentifier = controllerContext.toInstanceIdentifier(point);
int lastItemPosition = 0;
for (final MapEntryNode mapEntryNode : readList.body()) {
if (mapEntryNode.getIdentifier()
final SchemaContext schemaContext, final String point, final UserLeafSetNode<?> readLeafList,
final boolean before) {
tx.delete(datastore, path.getParent());
- final InstanceIdentifierContext<?> instanceIdentifier = controllerContext.toInstanceIdentifier(point);
+ final InstanceIdentifierContext instanceIdentifier = controllerContext.toInstanceIdentifier(point);
int index1 = 0;
for (final LeafSetEntryNode<?> nodeChild : readLeafList.body()) {
if (nodeChild.getIdentifier().equals(instanceIdentifier.getInstanceIdentifier().getLastPathArgument())) {
final YangInstanceIdentifier path, final NormalizedNode payload, final SchemaContext schemaContext,
final String point, final UserMapNode readList, final boolean before) {
tx.delete(datastore, path.getParent());
- final InstanceIdentifierContext<?> instanceIdentifier = controllerContext.toInstanceIdentifier(point);
+ final InstanceIdentifierContext instanceIdentifier = controllerContext.toInstanceIdentifier(point);
int index1 = 0;
for (final MapEntryNode mapEntryNode : readList.body()) {
if (mapEntryNode.getIdentifier().equals(instanceIdentifier.getInstanceIdentifier().getLastPathArgument())) {
}
final SchemaPath path = listener.getSchemaPath();
- final ListenerRegistration<DOMNotificationListener> registration = this.domNotification
+ final ListenerRegistration<DOMNotificationListener> registration = domNotification
.registerNotificationListener(listener, Absolute.of(ImmutableList.copyOf(path.getPathFromRoot())));
listener.setRegistration(registration);
PatchStatusContext status;
public PatchStatusContext getStatus() {
- return this.status;
+ return status;
}
public void setStatus(final PatchStatusContext status) {