| | |
| | | try { |
| | | task = recurringTask.scheduleNextIteration(new GregorianCalendar()); |
| | | } catch (DirectoryException de) { |
| | | logError(de.getMessageObject()); |
| | | logger.error(de.getMessageObject()); |
| | | } |
| | | if (task != null) { |
| | | try { |
| | |
| | | // and thus got initialized from backing file, otherwise |
| | | // log error and continue. |
| | | if (de.getResultCode() != ResultCode.ENTRY_ALREADY_EXISTS) { |
| | | logError(de.getMessageObject()); |
| | | logger.error(de.getMessageObject()); |
| | | } |
| | | } |
| | | } |
| | |
| | | try { |
| | | newIteration = recurringTask.scheduleNextIteration(calendar); |
| | | } catch (DirectoryException de) { |
| | | logError(de.getMessageObject()); |
| | | logger.error(de.getMessageObject()); |
| | | } |
| | | if (newIteration != null) |
| | | { |
| | |
| | | logger.traceException(de); |
| | | |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_ERROR_SCHEDULING_RECURRING_ITERATION. |
| | | get(recurringTaskID, de.getMessageObject()); |
| | | logError(message); |
| | | ERR_TASKSCHED_ERROR_SCHEDULING_RECURRING_ITERATION.get( |
| | | recurringTaskID, de.getMessageObject()); |
| | | logger.error(message); |
| | | |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_SCHEDULE_RECURRING_ITERATION, |
| | |
| | | |
| | | if (le.canContinueReading()) |
| | | { |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_PARSE_ENTRY_RECOVERABLE.get( |
| | | logger.error(ERR_TASKSCHED_CANNOT_PARSE_ENTRY_RECOVERABLE, |
| | | backingFilePath, le.getLineNumber(), le.getMessage()); |
| | | logError(message); |
| | | |
| | | continue; |
| | | } |
| | |
| | | DN parentDN = entryDN.getParentDNInSuffix(); |
| | | if (parentDN == null) |
| | | { |
| | | LocalizableMessage message = ERR_TASKSCHED_ENTRY_HAS_NO_PARENT. |
| | | get(String.valueOf(entryDN), |
| | | logger.error(ERR_TASKSCHED_ENTRY_HAS_NO_PARENT, String.valueOf(entryDN), |
| | | String.valueOf(taskBackend.getTaskRootDN())); |
| | | logError(message); |
| | | } |
| | | else if (parentDN.equals(taskBackend.getScheduledTasksParentDN())) |
| | | { |
| | |
| | | String id = task.getTaskID(); |
| | | if (tasks.containsKey(id)) |
| | | { |
| | | LocalizableMessage message = |
| | | WARN_TASKSCHED_DUPLICATE_TASK_ID.get( |
| | | String.valueOf(id)); |
| | | logError(message); |
| | | logger.warn(WARN_TASKSCHED_DUPLICATE_TASK_ID, String.valueOf(id)); |
| | | } |
| | | else |
| | | { |
| | |
| | | { |
| | | logger.traceException(de); |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_SCHEDULE_TASK_FROM_ENTRY. |
| | | get(String.valueOf(entryDN), de.getMessageObject()); |
| | | logError(message); |
| | | logger.error(ERR_TASKSCHED_CANNOT_SCHEDULE_TASK_FROM_ENTRY, |
| | | String.valueOf(entryDN), de.getMessageObject()); |
| | | } |
| | | } |
| | | else if (parentDN.equals(taskBackend.getRecurringTasksParentDN())) |
| | |
| | | { |
| | | logger.traceException(de); |
| | | |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_CANNOT_SCHEDULE_RECURRING_TASK_FROM_ENTRY. |
| | | get(String.valueOf(entryDN), de.getMessageObject()); |
| | | logError(message); |
| | | logger.error( |
| | | ERR_TASKSCHED_CANNOT_SCHEDULE_RECURRING_TASK_FROM_ENTRY, |
| | | String.valueOf(entryDN), de.getMessageObject()); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LocalizableMessage message = ERR_TASKSCHED_INVALID_TASK_ENTRY_DN.get( |
| | | String.valueOf(entryDN), backingFilePath); |
| | | logError(message); |
| | | logger.error(ERR_TASKSCHED_INVALID_TASK_ENTRY_DN, String.valueOf(entryDN), backingFilePath); |
| | | } |
| | | } |
| | | } |
| | |
| | | catch (LDIFException le) |
| | | { |
| | | logger.traceException(le); |
| | | |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_CREATE_BACKING_FILE.get( |
| | | backingFile, le.getMessage()); |
| | | throw new InitializationException(message, le); |
| | |
| | | { |
| | | logger.traceException(e); |
| | | |
| | | LocalizableMessage message = WARN_TASKSCHED_CANNOT_RENAME_CURRENT_BACKING_FILE. |
| | | get(String.valueOf(backingFilePath), |
| | | String.valueOf(saveFile.getAbsolutePath()), |
| | | stackTraceToSingleLineString(e)); |
| | | logError(message); |
| | | |
| | | LocalizableMessage message = |
| | | WARN_TASKSCHED_CANNOT_RENAME_CURRENT_BACKING_FILE.get(String |
| | | .valueOf(backingFilePath), String.valueOf(saveFile |
| | | .getAbsolutePath()), stackTraceToSingleLineString(e)); |
| | | logger.warn(message); |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_RENAME_CURRENT_TASK_FILE, |
| | | message); |
| | |
| | | { |
| | | logger.traceException(e); |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_RENAME_NEW_BACKING_FILE. |
| | | get(String.valueOf(tmpFilePath), String.valueOf(backingFilePath), |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_CANNOT_RENAME_NEW_BACKING_FILE.get(String |
| | | .valueOf(tmpFilePath), String.valueOf(backingFilePath), |
| | | stackTraceToSingleLineString(e)); |
| | | logError(message); |
| | | |
| | | logger.error(message); |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_RENAME_NEW_TASK_FILE, |
| | | message); |
| | |
| | | catch (IOException ioe) |
| | | { |
| | | logger.traceException(ioe); |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get( |
| | | tmpFilePath, stackTraceToSingleLineString(ioe)); |
| | | logError(message); |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get(tmpFilePath, |
| | | stackTraceToSingleLineString(ioe)); |
| | | logger.error(message); |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_WRITE_TASK_FILE, message); |
| | | } |
| | | catch (LDIFException le) |
| | | { |
| | | logger.traceException(le); |
| | | |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get( |
| | | tmpFilePath, le.getMessage()); |
| | | logError(message); |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get(tmpFilePath, le |
| | | .getMessage()); |
| | | logger.error(message); |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_WRITE_TASK_FILE, message); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | logger.traceException(e); |
| | | |
| | | LocalizableMessage message = ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get( |
| | | tmpFilePath, stackTraceToSingleLineString(e)); |
| | | logError(message); |
| | | LocalizableMessage message = |
| | | ERR_TASKSCHED_CANNOT_WRITE_BACKING_FILE.get(tmpFilePath, |
| | | stackTraceToSingleLineString(e)); |
| | | logger.error(message); |
| | | DirectoryServer.sendAlertNotification(this, |
| | | ALERT_TYPE_CANNOT_WRITE_TASK_FILE, message); |
| | | } |