Skip to content
Snippets Groups Projects
Commit 413c185f authored by brinn's avatar brinn
Browse files

change: improve logging

SVN: 23264
parent d8328dc2
No related branches found
No related tags found
No related merge requests found
...@@ -158,6 +158,12 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc ...@@ -158,6 +158,12 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc
public void execute() public void execute()
{ {
long freeSpace = getFreeSpace(); long freeSpace = getFreeSpace();
if (operationLog.isDebugEnabled())
{
operationLog.debug(String.format(
"Free space: %d MB, minimal free space required: %d MB", freeSpace,
minimumFreeSpace));
}
if (freeSpace >= minimumFreeSpace) if (freeSpace >= minimumFreeSpace)
{ {
return; return;
...@@ -182,27 +188,32 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc ...@@ -182,27 +188,32 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc
} }
Collections.sort(infos, new ExperimentDataSetsInfoComparator()); Collections.sort(infos, new ExperimentDataSetsInfoComparator());
StringBuilder archivingMessages = new StringBuilder(); StringBuilder archivingMessages = new StringBuilder();
if (monitorDataStoreShare()) try
{ {
for (int i = 0; i < infos.size() && freeSpace < minimumFreeSpace; i++) if (monitorDataStoreShare())
{ {
ExperimentDataSetsInfo info = infos.get(i); for (int i = 0; i < infos.size() && freeSpace < minimumFreeSpace; i++)
freeSpace += info.calculateSize(); {
archive(info, archivingMessages); ExperimentDataSetsInfo info = infos.get(i);
} freeSpace += info.calculateSize();
} else archive(info, archivingMessages);
{ }
for (int i = 0; i < infos.size() && freeSpace < minimumFreeSpace; i++) } else
{ {
if (archive(infos.get(i), archivingMessages)) for (int i = 0; i < infos.size() && freeSpace < minimumFreeSpace; i++)
{ {
freeSpace = getFreeSpace(); if (archive(infos.get(i), archivingMessages))
{
freeSpace = getFreeSpace();
}
} }
} }
} } finally
if (archivingMessages.length() > 0)
{ {
notificationLog.info("Archiving summary:" + archivingMessages); if (archivingMessages.length() > 0)
{
notificationLog.info("Archiving summary:" + archivingMessages);
}
} }
} }
...@@ -235,11 +246,11 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc ...@@ -235,11 +246,11 @@ public class ExperimentBasedArchivingTask implements IDataStoreLockingMaintenanc
dataSetCodes.add(dataSet.getCode()); dataSetCodes.add(dataSet.getCode());
} }
final String message = final String message =
"Starting archiving " + dataSetCodes.size() + " data sets of experiment " "#" + dataSetCodes.size() + " data sets of experiment "
+ info.getExperimentIdentifier() + ": " + dataSetCodes; + info.getExperimentIdentifier() + ": " + dataSetCodes;
operationLog.info(message); operationLog.info("Starting archiving " + message);
archivingMessages.append('\n').append(message);
service.archiveDataSets(dataSetCodes, true); service.archiveDataSets(dataSetCodes, true);
archivingMessages.append('\n').append("Archived " + message);
return true; return true;
} }
......
...@@ -404,7 +404,8 @@ public class ExperimentBasedArchivingTaskTest extends AbstractFileSystemTestCase ...@@ -404,7 +404,8 @@ public class ExperimentBasedArchivingTaskTest extends AbstractFileSystemTestCase
if (archivingEntries.length > 0) if (archivingEntries.length > 0)
{ {
operationLogBuilder.append("\n").append(NOTIFY_LOG_ENTRY_PREFIX); operationLogBuilder.append("\n").append(NOTIFY_LOG_ENTRY_PREFIX);
operationLogBuilder.append("Archiving summary:").append(notifyMessageBuilder); operationLogBuilder.append("Archiving summary:").append(
notifyMessageBuilder.toString().replaceAll("Starting archiving ", "Archived "));
} }
assertEquals(operationLogBuilder.toString(), logRecorder.getLogContent()); assertEquals(operationLogBuilder.toString(), logRecorder.getLogContent());
} }
...@@ -412,8 +413,7 @@ public class ExperimentBasedArchivingTaskTest extends AbstractFileSystemTestCase ...@@ -412,8 +413,7 @@ public class ExperimentBasedArchivingTaskTest extends AbstractFileSystemTestCase
private String logEntry(Experiment experiment, DataSet... dataSets) private String logEntry(Experiment experiment, DataSet... dataSets)
{ {
List<String> dataSetCodes = getDataSetCodes(dataSets); List<String> dataSetCodes = getDataSetCodes(dataSets);
return "Starting archiving " + dataSetCodes.size() return "Starting archiving #" + dataSetCodes.size() + " data sets of experiment "
+ " data sets of experiment "
+ experiment.getIdentifier() + ": " + dataSetCodes; + experiment.getIdentifier() + ": " + dataSetCodes;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment