freenet.store.caching

Class CachingFreenetStore<T extends StorableBlock>

java.lang.Object

freenet.store.ProxyFreenetStore<T>

freenet.store.caching.CachingFreenetStore<T>

All Implemented Interfaces:

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

public class CachingFreenetStore<T extends StorableBlock>
extends ProxyFreenetStore<T>

CachingFreenetStore

Nested Class Summary

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

FreenetStore.StoreType

Field Summary

Fields inherited from class freenet.store.ProxyFreenetStore

backDatastore

Constructor Summary

Constructors

Constructor and Description
CachingFreenetStore(StoreCallback<T> callback, FreenetStore<T> backDatastore, CachingFreenetStoreTracker tracker)

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.
boolean	probablyInStore(byte[] routingKey) Check if a routing key probably
void	put(T block, byte[] data, byte[] header, boolean overwrite, boolean isOldBlock) Store a block.
boolean	start(Ticker ticker, boolean longStart)

Methods inherited from class freenet.store.ProxyFreenetStore

getBloomFalsePositive, getMaxKeys, getSessionAccessStats, getTotalAccessStats, getUnderlyingStore, hits, keyCount, misses, setMaxKeys, setUserAlertManager, writes

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingFreenetStore

public CachingFreenetStore(StoreCallback<T> callback,
                           FreenetStore<T> backDatastore,
                           CachingFreenetStoreTracker tracker)

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>

Overrides:

fetch in class ProxyFreenetStore<T extends StorableBlock>

Parameters:

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.

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>

Overrides:

probablyInStore in class ProxyFreenetStore<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>

Overrides:

put in class ProxyFreenetStore<T extends StorableBlock>

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

isOldBlock - If true, the block really shouldn't be in the datastore, but we are storing it anyway; it should not have the new block flag, so it should be excluded from Bloom filter sharing.

Throws:

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

java.io.IOException

start

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

Specified by:

start in interface FreenetStore<T extends StorableBlock>

Overrides:

start in class ProxyFreenetStore<T extends StorableBlock>

Throws:

java.io.IOException

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

Overrides:

close in class ProxyFreenetStore<T extends StorableBlock>