- ReadWriteShardDataTreeTransaction transaction = store.newReadWriteTransaction(
- new TransactionIdentifier(applyHistoryId, applyCounter++));
-
- NormalizedNode<?, ?> node = SerializationUtils.deserializeNormalizedNode(snapshotBytes);
-
- // delete everything first
- transaction.getSnapshot().delete(YangInstanceIdentifier.EMPTY);
-
- // Add everything from the remote node back
- transaction.getSnapshot().write(YangInstanceIdentifier.EMPTY, node);
- syncCommitTransaction(transaction);
- } catch (InterruptedException | ExecutionException e) {
- log.error("{}: An exception occurred when applying snapshot", logId, e);
- } finally {
- log.info("{}: Done applying snapshot", logId);
+ store.applySnapshot(snapshot);
+ } catch (Exception e) {
+ log.error("{}: Failed to apply snapshot {}", logId, snapshot, e);
+ return;