X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FFrontendReadOnlyTransaction.java;h=881518308c021af10b27006c00faffcd5cc214c2;hb=f41c5e6e6f6e10b36b1e4b1992877e38e718c8fb;hp=e5680c500c669453cefd99e5a5857d8411de2fe4;hpb=0d638425a57e0edbb4f9f8a4661ded8aa391189c;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/FrontendReadOnlyTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/FrontendReadOnlyTransaction.java index e5680c500c..881518308c 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/FrontendReadOnlyTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/FrontendReadOnlyTransaction.java @@ -51,7 +51,7 @@ final class FrontendReadOnlyTransaction extends FrontendTransaction { // Sequence has already been checked @Override - @Nullable TransactionSuccess handleRequest(final TransactionRequest request, final RequestEnvelope envelope, + @Nullable TransactionSuccess doHandleRequest(final TransactionRequest request, final RequestEnvelope envelope, final long now) throws RequestException { if (request instanceof ExistsTransactionRequest) { return handleExistsTransaction((ExistsTransactionRequest) request); @@ -66,6 +66,11 @@ final class FrontendReadOnlyTransaction extends FrontendTransaction { } } + @Override + void retire() { + // No-op + } + private void handleModifyTransaction(final ModifyTransactionRequest request, final RequestEnvelope envelope, final long now) { // The only valid request here is with abort protocol @@ -79,14 +84,16 @@ final class FrontendReadOnlyTransaction extends FrontendTransaction { private ExistsTransactionSuccess handleExistsTransaction(final ExistsTransactionRequest request) throws RequestException { - final Optional> data = openTransaction.getSnapshot().readNode(request.getPath()); + final Optional> data = Optional.fromJavaUtil(openTransaction.getSnapshot() + .readNode(request.getPath())); return recordSuccess(request.getSequence(), new ExistsTransactionSuccess(openTransaction.getIdentifier(), request.getSequence(), data.isPresent())); } private ReadTransactionSuccess handleReadTransaction(final ReadTransactionRequest request) throws RequestException { - final Optional> data = openTransaction.getSnapshot().readNode(request.getPath()); + final Optional> data = Optional.fromJavaUtil(openTransaction.getSnapshot().readNode( + request.getPath())); return recordSuccess(request.getSequence(), new ReadTransactionSuccess(openTransaction.getIdentifier(), request.getSequence(), data)); }