freenet.store

Class ProxyFreenetStore<T extends StorableBlock>

java.lang.Object

freenet.store.ProxyFreenetStore<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

CachingFreenetStore

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

Nested Class Summary

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

FreenetStore.StoreType

Field Summary

Fields

Modifier and Type	Field and Description
protected FreenetStore<T>	backDatastore

Constructor Summary

Constructors

Constructor and Description
ProxyFreenetStore(FreenetStore<T> backDatastore)

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()
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
void	put(T block, byte[] data, byte[] header, boolean overwrite, boolean oldBlock) Store a block.
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

Field Detail

backDatastore

protected final FreenetStore<T extends StorableBlock> backDatastore

Constructor Detail

ProxyFreenetStore

public ProxyFreenetStore(FreenetStore<T> backDatastore)

Method Detail

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>

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>

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>

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>

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:

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.

put

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

Description copied from interface: FreenetStore

Store a block.

Specified by:

put in interface FreenetStore<T extends StorableBlock>

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

oldBlock - 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

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.

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

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