import org.opendaylight.controller.cluster.access.concepts.RequestException;
import org.opendaylight.controller.cluster.access.concepts.UnsupportedRequestException;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Read-only frontend transaction state as observed by the shard leader.
*/
@NotThreadSafe
final class FrontendReadOnlyTransaction extends FrontendTransaction {
+ private static final Logger LOG = LoggerFactory.getLogger(FrontendReadOnlyTransaction.class);
+
private final ReadOnlyShardDataTreeTransaction openTransaction;
private FrontendReadOnlyTransaction(final AbstractFrontendHistory history,
handleTransactionAbort((TransactionAbortRequest) request, envelope, now);
return null;
} else {
+ LOG.warn("Rejecting unsupported request {}", request);
throw new UnsupportedRequestException(request);
}
}
- @Override
- void purge(final Runnable callback) {
- openTransaction.purge(callback);
- }
-
private void handleTransactionAbort(final TransactionAbortRequest request, final RequestEnvelope envelope,
final long now) throws RequestException {
openTransaction.abort(() -> recordAndSendSuccess(envelope, now, new TransactionAbortSuccess(request.getTarget(),