freenet.store.caching

Class CachingFreenetStoreTracker

java.lang.Object

freenet.store.caching.CachingFreenetStoreTracker

public class CachingFreenetStoreTracker
extends java.lang.Object

Tracks the memory used by a bunch of CachingFreenetStore's, and writes blocks to disk when full or after 5 minutes. One major objective here is we should not do disk I/O inside a lock, all methods should be non-blocking, even if it means the caller needs to do a blocking disk write.

Constructor Summary

Constructors

Constructor and Description
CachingFreenetStoreTracker(long maxSize, long period, Ticker ticker)

Method Summary

Modifier and Type	Method and Description
boolean	add(long sizeBlock) If we are close to the limit, we will schedule an off-thread job to flush ALL the caches.
long	getSizeOfCache()
void	registerCachingFS(CachingFreenetStore<?> fs) register a CachingFreenetStore to be called when we get full or to flush all after a setted period.
void	unregisterCachingFS(CachingFreenetStore<?> fs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CachingFreenetStoreTracker

public CachingFreenetStoreTracker(long maxSize,
                                  long period,
                                  Ticker ticker)

Method Detail

registerCachingFS

public void registerCachingFS(CachingFreenetStore<?> fs)

register a CachingFreenetStore to be called when we get full or to flush all after a setted period.

unregisterCachingFS

public void unregisterCachingFS(CachingFreenetStore<?> fs)

add

public boolean add(long sizeBlock)

If we are close to the limit, we will schedule an off-thread job to flush ALL the caches. Even if we are not, we schedule one after period. If we are at the limit, we will return false, and the caller should write directly to the underlying store.

getSizeOfCache

public long getSizeOfCache()