Commit bd9f0a41 authored by Rolf Krahl's avatar Rolf Krahl

Throw an error any entry is missing from the archive file.

parent ae022e1e
......@@ -109,6 +109,9 @@ public class DsRestorer implements Runnable {
seen.add(dfName);
}
zis.close();
if (!seen.equals(nameToLocalMap.keySet())) {
throw new RuntimeException("Corrupt archive for " + dsInfo + ": missing entries");
}
Files.delete(datasetCachePath);
fsm.recordSuccess(dsInfo.getDsId());
logger.debug("Restore of " + dsInfo + " completed");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment