X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-persister-directory-xml-adapter%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fpersist%2Fstorage%2Fdirectory%2Fxml%2FXmlDirectoryPersister.java;h=da4fbfbd2303b9749b186ae86d2fdf0529d1c454;hp=3ea432e1739a7ed83047091f0a392e8918c8e45e;hb=f43b01b81319959b1907e3e04537f5169e7f33d8;hpb=b0648268f5f85e2533d39e37b01b35487823cac3;ds=sidebyside diff --git a/opendaylight/config/config-persister-directory-xml-adapter/src/main/java/org/opendaylight/controller/config/persist/storage/directory/xml/XmlDirectoryPersister.java b/opendaylight/config/config-persister-directory-xml-adapter/src/main/java/org/opendaylight/controller/config/persist/storage/directory/xml/XmlDirectoryPersister.java index 3ea432e173..da4fbfbd23 100644 --- a/opendaylight/config/config-persister-directory-xml-adapter/src/main/java/org/opendaylight/controller/config/persist/storage/directory/xml/XmlDirectoryPersister.java +++ b/opendaylight/config/config-persister-directory-xml-adapter/src/main/java/org/opendaylight/controller/config/persist/storage/directory/xml/XmlDirectoryPersister.java @@ -11,6 +11,7 @@ import static com.google.common.base.Preconditions.checkArgument; import com.google.common.base.Optional; import com.google.common.io.Files; + import java.io.File; import java.io.FilenameFilter; import java.io.IOException; @@ -20,6 +21,7 @@ import java.util.Collections; import java.util.List; import java.util.Set; import java.util.SortedSet; + import javax.xml.bind.JAXBContext; import javax.xml.bind.JAXBException; import javax.xml.bind.Unmarshaller; @@ -27,6 +29,7 @@ import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import javax.xml.transform.stream.StreamSource; + import org.opendaylight.controller.config.persist.api.ConfigSnapshotHolder; import org.opendaylight.controller.config.persist.api.Persister; import org.opendaylight.controller.config.persist.storage.file.xml.model.ConfigSnapshot; @@ -40,14 +43,14 @@ public class XmlDirectoryPersister implements Persister { private final Optional extensionsFilter; /** - * Creates XmlDirectoryPersister that picks up all files in specified folder + * Creates XmlDirectoryPersister that picks up all files in specified folder. */ public XmlDirectoryPersister(final File storage) { this(storage, Optional.absent()); } /** - * Creates XmlDirectoryPersister that picks up files only with specified file extension + * Creates XmlDirectoryPersister that picks up files only with specified file extension. */ public XmlDirectoryPersister(final File storage, final Set fileExtensions) { this(storage, Optional.of(getFilter(fileExtensions))); @@ -66,7 +69,8 @@ public class XmlDirectoryPersister implements Persister { @Override public List loadLastConfigs() throws IOException { - File[] filesArray = extensionsFilter.isPresent() ? storage.listFiles(extensionsFilter.get()) : storage.listFiles(); + File[] filesArray = + extensionsFilter.isPresent() ? storage.listFiles(extensionsFilter.get()) : storage.listFiles(); if (filesArray == null || filesArray.length == 0) { return Collections.emptyList(); } @@ -78,13 +82,13 @@ public class XmlDirectoryPersister implements Persister { List result = new ArrayList<>(); for (File file : sortedFiles) { LOG.trace("Adding file '{}' to combined result", file); - Optional h = fromXmlSnapshot(file); + Optional configSnapshotHolderOptional = fromXmlSnapshot(file); // Ignore non valid snapshot - if(h.isPresent() == false) { + if (!configSnapshotHolderOptional.isPresent()) { continue; } - result.add(h.get()); + result.add(configSnapshotHolderOptional.get()); } return result; } @@ -92,10 +96,11 @@ public class XmlDirectoryPersister implements Persister { private Optional fromXmlSnapshot(final File file) { try { return Optional.of(loadLastConfig(file)); - } catch (JAXBException e) { + } catch (final JAXBException e) { // In case of parse error, issue a warning, ignore and continue LOG.warn( - "Unable to parse configuration snapshot from {}. Initial config from {} will be IGNORED in this run. ", + "Unable to parse configuration snapshot from {}. " + + "Initial config from {} will be IGNORED in this run. ", file, file); LOG.warn( "Note that subsequent config files may fail due to this problem. ", @@ -139,28 +144,21 @@ public class XmlDirectoryPersister implements Persister { }; } - private static FilenameFilter getFilter(final SetfileExtensions) { - checkArgument(fileExtensions.isEmpty() == false, "No file extension provided", fileExtensions); + private static FilenameFilter getFilter(final Set fileExtensions) { + checkArgument(!fileExtensions.isEmpty(), "No file extension provided", fileExtensions); - return new FilenameFilter() { - @Override - public boolean accept(final File dir, final String name) { - String ext = Files.getFileExtension(name); - return fileExtensions.contains(ext); - } + return (dir, name) -> { + String ext = Files.getFileExtension(name); + return fileExtensions.contains(ext); }; } @Override public void close() { - } @Override public String toString() { - final StringBuffer sb = new StringBuffer("XmlDirectoryPersister{"); - sb.append("storage=").append(storage); - sb.append('}'); - return sb.toString(); + return "XmlDirectoryPersister{storage=" + storage + "}"; } } \ No newline at end of file