Skip to content

Commit

Permalink
A Leader issue in MARCXML can block the processing the rest of the fi…
Browse files Browse the repository at this point in the history
…le, and also other files #518
  • Loading branch information
pkiraly committed Sep 24, 2024
1 parent 33dbb42 commit af05dc9
Showing 1 changed file with 31 additions and 17 deletions.
48 changes: 31 additions & 17 deletions src/main/java/de/gwdg/metadataqa/marc/cli/utils/RecordIterator.java
Original file line number Diff line number Diff line change
Expand Up @@ -119,38 +119,53 @@ private void processFile(String inputFileName) {
System.exit(1);
} catch (Exception ex) {
if (!processor.getParameters().doLog()) {
logger.log(Level.SEVERE, "start", ex);
System.exit(1);
logger.log(Level.SEVERE, "error in processFile()", ex);
// System.exit(1);
}

logger.severe("Other exception: " + ex);
ex.printStackTrace();

for (StackTraceElement element : ex.getStackTrace()) {
logger.severe(element.toString());
// logger.severe(element.toString());
System.err.println(element.toString());
}
Throwable exa = ex;
while (exa.getCause() != null) {
logger.severe("cause");
exa = exa.getCause();
for (StackTraceElement element : exa.getStackTrace()) {
logger.severe(element.toString());
System.err.println(element.toString());
}
}
logger.log(Level.SEVERE, "start", ex);
System.exit(1);
// logger.log(Level.SEVERE, "start2", ex);
// System.exit(1);
}
}

private void processContent(MarcReader reader, String fileName) {
while (reader.hasNext()) {
if (!processor.readyToProcess()
|| isOverLimit(processor.getParameters().getLimit(), recordNumber)) {
break;
}
try {
while (reader.hasNext()) {
if (!processor.readyToProcess()
|| isOverLimit(processor.getParameters().getLimit(), recordNumber)) {
break;
}

IteratorResponse iteratorResponse = getNextMarc4jRecord(recordNumber, lastKnownId, reader);
recordNumber++;
processIteratorResponse(iteratorResponse, fileName);
try {
IteratorResponse iteratorResponse = getNextMarc4jRecord(recordNumber, lastKnownId, reader);
recordNumber++;
processIteratorResponse(iteratorResponse, fileName);
} catch (MarcException ex) {
logger.log(Level.SEVERE, "catched MarcException", ex);
} catch (Exception ex) {
logger.log(Level.SEVERE, "catched Exception", ex);
}
}
} catch (MarcException ex) {
String msg = String.format("Error during processing the file content." +
" File: %s, last known record number: %s, last known record identifier: %s",
fileName, recordNumber, lastKnownId);
logger.log(Level.SEVERE, msg, ex);
}
}

Expand All @@ -164,7 +179,6 @@ private void processIteratorResponse(IteratorResponse iteratorResponse, String f
return;
}


if (marc4jRecord.getControlNumber() == null) {
logger.log(Level.SEVERE, "No record number at {0}, last known ID: {1}", new Object[]{recordNumber, lastKnownId});
if (marc4jRecord.getLeader() != null) {
Expand Down Expand Up @@ -261,7 +275,7 @@ private IteratorResponse getNextMarc4jRecord(int i, String lastKnownId, MarcRead
logger.severe(msg);
} catch (Exception e) {
response.addError(lastKnownId, e.getLocalizedMessage());
logger.log(Level.SEVERE, "start", e);
logger.log(Level.SEVERE, "error in getNextMarc4jRecord()", e);
}
return response;
}
Expand All @@ -276,7 +290,7 @@ private void extracted(int i, Record marc4jRecord, Exception e, String message)
logger.log(Level.SEVERE, "No record number at {0}", i);
if (processor.getParameters().doLog())
logger.log(Level.SEVERE, String.format(message, marc4jRecord.getControlNumber(), e.getMessage()));
logger.log(Level.SEVERE, "start", e);
logger.log(Level.SEVERE, "error in extracted()", e);
}

private static boolean isOverLimit(int limit, int i) {
Expand Down

0 comments on commit af05dc9

Please sign in to comment.