freenet.store

Class SlashdotStore<T extends StorableBlock>

java.lang.Object

freenet.store.SlashdotStore<T>

All Implemented Interfaces:

FreenetStore<T>, java.io.Closeable, java.lang.AutoCloseable

public class SlashdotStore<T extends StorableBlock>
extends java.lang.Object
implements FreenetStore<T>

Short-term cache. Used to cache all blocks retrieved in the last 30 minutes (on low security levels), or just to cache data fetched through ULPRs (on higher security levels). - Strict LRU. - Size limit. - Strictly enforced time limit. - Blocks are encrypted, and kept in temp files.

Nested Class Summary

Nested classes/interfaces inherited from interface freenet.store.FreenetStore

FreenetStore.StoreType

Constructor Summary

Constructors

Constructor and Description
SlashdotStore(StoreCallback<T> callback, int maxKeys, long maxLifetime, long purgePeriod, Ticker ticker, TempBucketFactory tbf)

Method Summary

Modifier and Type	Method and Description
void	close()
T	fetch(byte[] routingKey, byte[] fullKey, boolean dontPromote, boolean canReadClientCache, boolean canReadSlashdotCache, boolean ignoreOldBlocks, BlockMetadata meta) Retrieve a block.
long	getBloomFalsePositive()
java.lang.Long	getLifetime()
long	getMaxKeys()
StoreAccessStats	getSessionAccessStats()
StoreAccessStats	getTotalAccessStats()
FreenetStore<T>	getUnderlyingStore()
long	hits()
long	keyCount()
long	misses()
boolean	probablyInStore(byte[] routingKey) Check if a routing key probably
protected void	purgeOldData()
protected void	purgeOldData(ByteArrayWrapper key, freenet.store.SlashdotStore.DiskBlock addFirst)
void	put(T block, byte[] data, byte[] header, boolean overwrite, boolean isOldBlock) Store a block.
void	setLifetime(java.lang.Long val)
void	setMaxKeys(long maxStoreKeys, boolean shrinkNow) Change the store size.
void	setUserAlertManager(UserAlertManager userAlertManager)
boolean	start(Ticker ticker, boolean longStart)
long	writes()

Methods inherited from class java.lang.Object

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

Constructor Detail

SlashdotStore

public SlashdotStore(StoreCallback<T> callback,
                     int maxKeys,
                     long maxLifetime,
                     long purgePeriod,
                     Ticker ticker,
                     TempBucketFactory tbf)

Method Detail

fetch

public T fetch(byte[] routingKey,
               byte[] fullKey,
               boolean dontPromote,
               boolean canReadClientCache,
               boolean canReadSlashdotCache,
               boolean ignoreOldBlocks,
               BlockMetadata meta)
        throws java.io.IOException

Description copied from interface: FreenetStore

Retrieve a block. Use the StoreCallback to convert it to the appropriate type of block.

Specified by:

fetch in interface FreenetStore<T extends StorableBlock>

Parameters:

meta - IGNORED!

routingKey - The routing key i.e. the database key under which the block is stored.

dontPromote - If true, don't promote the block to the top of the LRU.

canReadClientCache - Whether we can read the client-cache, for purposes of finding the pubkey for an SSK.

Returns:

A StorableBlock, or null if the key cannot be found.

Throws:

java.io.IOException - If a disk I/O error occurs.

getBloomFalsePositive

public long getBloomFalsePositive()

Specified by:

getBloomFalsePositive in interface FreenetStore<T extends StorableBlock>

getMaxKeys

public long getMaxKeys()

Specified by:

getMaxKeys in interface FreenetStore<T extends StorableBlock>

hits

public long hits()

Specified by:

hits in interface FreenetStore<T extends StorableBlock>

keyCount

public long keyCount()

Specified by:

keyCount in interface FreenetStore<T extends StorableBlock>

misses

public long misses()

Specified by:

misses in interface FreenetStore<T extends StorableBlock>

probablyInStore

public boolean probablyInStore(byte[] routingKey)

Description copied from interface: FreenetStore

Check if a routing key probably

Specified by:

probablyInStore in interface FreenetStore<T extends StorableBlock>

Returns:

false only if the key does not exist in store.

put

public void put(T block,
                byte[] data,
                byte[] header,
                boolean overwrite,
                boolean isOldBlock)
         throws java.io.IOException,
                KeyCollisionException

Description copied from interface: FreenetStore

Store a block.

Specified by:

put in interface FreenetStore<T extends StorableBlock>

Parameters:

isOldBlock - Ignored, we don't distinguish between stuff that should be cached and stuff that shouldn't be cached; really it's all in the latter category anyway here!

overwrite - If true, overwrite old content rather than throwing a KeyCollisionException.

Throws:

KeyCollisionException - If the key already exists and callback.collisionPossible() is true.

java.io.IOException

setMaxKeys

public void setMaxKeys(long maxStoreKeys,
                       boolean shrinkNow)
                throws java.io.IOException

Description copied from interface: FreenetStore

Change the store size.

Specified by:

setMaxKeys in interface FreenetStore<T extends StorableBlock>

Parameters:

maxStoreKeys - The maximum number of keys to be cached.

shrinkNow - If false, don't shrink the store immediately.

Throws:

java.io.IOException

writes

public long writes()

Specified by:

writes in interface FreenetStore<T extends StorableBlock>

purgeOldData

protected void purgeOldData()

purgeOldData

protected void purgeOldData(ByteArrayWrapper key,
                            freenet.store.SlashdotStore.DiskBlock addFirst)

getLifetime

public java.lang.Long getLifetime()

setLifetime

public void setLifetime(java.lang.Long val)

getSessionAccessStats

public StoreAccessStats getSessionAccessStats()

Specified by:

getSessionAccessStats in interface FreenetStore<T extends StorableBlock>

getTotalAccessStats

public StoreAccessStats getTotalAccessStats()

Specified by:

getTotalAccessStats in interface FreenetStore<T extends StorableBlock>

start

public boolean start(Ticker ticker,
                     boolean longStart)
              throws java.io.IOException

Specified by:

start in interface FreenetStore<T extends StorableBlock>

Throws:

java.io.IOException

setUserAlertManager

public void setUserAlertManager(UserAlertManager userAlertManager)

Specified by:

setUserAlertManager in interface FreenetStore<T extends StorableBlock>

getUnderlyingStore

public FreenetStore<T> getUnderlyingStore()

Specified by:

getUnderlyingStore in interface FreenetStore<T extends StorableBlock>

close

public void close()

Specified by:

close in interface FreenetStore<T extends StorableBlock>

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable