inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merged BRANCHES/DEV/THOR1 to HEAD:

Browse Source 
32579: Caching Content Store: fixes bug where cache-usage.ser wasn't loaded on startup.


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@32630 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Matt Ward
2011-12-08 10:07:22 +00:00
parent a411eb6fe0
commit fde60b548c
1 changed files with 23 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
source/java/org/alfresco/repo/content/caching/quota/StandardQuotaStrategy.java
View File

@@ -27,6 +27,8 @@ import java.util.concurrent.atomic.AtomicLong;
import org.alfresco.repo.content.caching.ContentCacheImpl;
import org.alfresco.repo.content.caching.cleanup.CachedContentCleaner;
import org.alfresco.repo.content.filestore.FileContentReader;
import org.alfresco.repo.content.filestore.FileContentWriter;
import org.alfresco.util.PropertyCheck;
import org.apache.commons.io.FileUtils;
import org.apache.commons.logging.Log;
@@ -53,7 +55,7 @@ import org.springframework.beans.factory.annotation.Required;
*/
public class StandardQuotaStrategy implements QuotaManagerStrategy, UsageTracker
{
private static final String CACHE_USAGE_FILENAME = "cache-usage.ser";
private static final String CACHE_USAGE_FILENAME = "cache-usage.txt";
private final static Log log = LogFactory.getLog(StandardQuotaStrategy.class);
private static final long DEFAULT_DISK_USAGE_ESTIMATE = 0L;
private int panicThresholdPct = 90;
@@ -108,45 +110,37 @@ public class StandardQuotaStrategy implements QuotaManagerStrategy, UsageTracker
private void loadDiskUsage()
{
// Load the last known disk usage value.
try
File usageFile = new File(cache.getCacheRoot(), CACHE_USAGE_FILENAME);
if (!usageFile.exists())
{
FileInputStream fis = new FileInputStream(new File(cache.getCacheRoot(), CACHE_USAGE_FILENAME));
ObjectInputStream ois = new ObjectInputStream(fis);
currentUsageBytes.set(ois.readLong());
ois.close();
if (log.isInfoEnabled())
{
log.info("Using last known disk usage estimate: " + getCurrentUsageBytes());
}
}
catch (Throwable e)
{
// Assume disk usage
setCurrentUsageBytes(DEFAULT_DISK_USAGE_ESTIMATE);
if (log.isInfoEnabled())
{
log.info("Unable to load last known disk usage estimate so assuming: " + getCurrentUsageBytes());
log.info("No previous usage file found (" + usageFile + ") so assuming: " +
getCurrentUsageBytes() + " bytes.");
}
}
}
else
{
FileContentReader reader = new FileContentReader(usageFile);
String usageStr = reader.getContentString();
long usage = Long.parseLong(usageStr);
currentUsageBytes.set(usage);
if (log.isInfoEnabled())
{
log.info("Using last known disk usage estimate: " + getCurrentUsageBytes());
}
}
}
private void saveDiskUsage()
{
// Persist the last known disk usage value.
try
{
FileOutputStream fos = new FileOutputStream(new File(cache.getCacheRoot(), CACHE_USAGE_FILENAME));
ObjectOutputStream out = new ObjectOutputStream(fos);
out.writeObject(currentUsageBytes);
out.close();
}
catch (Throwable e)
{
throw new RuntimeException("Unable to save content cache disk usage statistics.", e);
}
File usageFile = new File(cache.getCacheRoot(), CACHE_USAGE_FILENAME);
FileContentWriter writer = new FileContentWriter(usageFile);
writer.putContent(currentUsageBytes.toString());
}