| | |
| | | { |
| | | try |
| | | { |
| | | if ((connectionHandlerThread != null) && |
| | | (connectionHandlerThread.isAlive())) |
| | | if (connectionHandlerThread != null && connectionHandlerThread.isAlive()) |
| | | { |
| | | connectionHandlerThread.join(100); |
| | | connectionHandlerThread.interrupt(); |
| | |
| | | writer.writeComment(m, 78); |
| | | |
| | | LocalizableMessageBuilder errorMessage = operation.getErrorMessage(); |
| | | if ((errorMessage != null) && (errorMessage.length() > 0)) |
| | | if (errorMessage != null && errorMessage.length() > 0) |
| | | { |
| | | m = INFO_LDIF_CONNHANDLER_ERROR_MESSAGE.get(errorMessage); |
| | | writer.writeComment(m, 78); |
| | |
| | | } |
| | | |
| | | List<String> referralURLs = operation.getReferralURLs(); |
| | | if ((referralURLs != null) && (! referralURLs.isEmpty())) |
| | | if (referralURLs != null && !referralURLs.isEmpty()) |
| | | { |
| | | for (String url : referralURLs) |
| | | { |
| | |
| | | close(reader, writer); |
| | | } |
| | | |
| | | if (errorEncountered || (! fullyProcessed)) |
| | | if (errorEncountered || !fullyProcessed) |
| | | { |
| | | String renamedPath = inputPath + ".errors-encountered." + |
| | | TimeThread.getGMTTime(); |