Skip to content
Snippets Groups Projects
Commit 46b4f33a authored by brinn's avatar brinn
Browse files

BIS-183 Ensure that SegmentedStoreUtils.getDataSetsPerShare() does not touch...

BIS-183 Ensure that SegmentedStoreUtils.getDataSetsPerShare() does not touch the datastore for every dataset.

SVN: 26555
parent 499bca51
No related branches found
No related tags found
No related merge requests found
...@@ -221,11 +221,12 @@ public class SegmentedStoreUtils ...@@ -221,11 +221,12 @@ public class SegmentedStoreUtils
+ "."); + ".");
} else } else
{ {
File dataSetInStore = new File(share.getShare(), dataSet.getDataSetLocation()); if (dataSet.getDataSetSize() == null)
if (FileOperations.getMonitoredInstanceForCurrentThread()
.exists(dataSetInStore))
{ {
if (dataSet.getDataSetSize() == null) final File dataSetInStore =
new File(share.getShare(), dataSet.getDataSetLocation());
if (FileOperations.getMonitoredInstanceForCurrentThread()
.exists(dataSetInStore))
{ {
log.log(LogLevel.INFO, "Calculating size of " + dataSetInStore); log.log(LogLevel.INFO, "Calculating size of " + dataSetInStore);
long t0 = timeProvider.getTimeInMilliseconds(); long t0 = timeProvider.getTimeInMilliseconds();
...@@ -236,12 +237,15 @@ public class SegmentedStoreUtils ...@@ -236,12 +237,15 @@ public class SegmentedStoreUtils
+ " msec)"); + " msec)");
service.updateShareIdAndSize(dataSetCode, shareId, size); service.updateShareIdAndSize(dataSetCode, shareId, size);
dataSet.setDataSetSize(size); dataSet.setDataSetSize(size);
} else
{
log.log(LogLevel.WARN, "Data set " + dataSetCode
+ " no longer exists in share " + shareId + ".");
} }
share.addDataSet(dataSet); }
} else if (dataSet.getDataSetSize() != null)
{ {
log.log(LogLevel.WARN, "Data set " + dataSetCode share.addDataSet(dataSet);
+ " no longer exists in share " + shareId + ".");
} }
} }
} }
......
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