freenet.client.async

Class InsertCompressor

java.lang.Object

freenet.client.async.InsertCompressor

All Implemented Interfaces:

CompressJob

public class InsertCompressor
extends java.lang.Object
implements CompressJob

Compress a file in order to insert it. This class acts as a tag in the database to ensure that inserts are not forgotten about, and also can be run on a non-database thread from an executor.

Field Summary

Fields

Modifier and Type	Field and Description
BucketFactory	bucketFactory BucketFactory
java.lang.String	compressorDescriptor
freenet.client.async.SingleFileInserter	inserter The SingleFileInserter we report to.
int	minSize If we can get it into one block, don't compress any further
boolean	persistent

Constructor Summary

Constructors

Constructor and Description
InsertCompressor(freenet.client.async.SingleFileInserter inserter, RandomAccessBucket origData, int minSize, BucketFactory bf, boolean persistent, long generateHashes, boolean pre1254, Config config)

Method Summary

Modifier and Type	Method and Description
void	init(ClientContext ctx)
void	onFailure(InsertException e, ClientPutState c, ClientContext context)
static InsertCompressor	start(ClientContext ctx, freenet.client.async.SingleFileInserter inserter, RandomAccessBucket origData, int minSize, BucketFactory bf, boolean persistent, long generateHashes, boolean pre1254, Config config) Create an InsertCompressor, add it to the database, schedule it.
void	tryCompress(ClientContext context)

Methods inherited from class java.lang.Object

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

Field Detail

inserter

public final freenet.client.async.SingleFileInserter inserter

The SingleFileInserter we report to. We were created by it and when we have compressed our data we will call a method to process it and schedule the data.

minSize

public final int minSize

If we can get it into one block, don't compress any further

bucketFactory

public final BucketFactory bucketFactory

BucketFactory

persistent

public final boolean persistent

compressorDescriptor

public final java.lang.String compressorDescriptor

Constructor Detail

InsertCompressor

public InsertCompressor(freenet.client.async.SingleFileInserter inserter,
                        RandomAccessBucket origData,
                        int minSize,
                        BucketFactory bf,
                        boolean persistent,
                        long generateHashes,
                        boolean pre1254,
                        Config config)

Method Detail

init

public void init(ClientContext ctx)

tryCompress

public void tryCompress(ClientContext context)
                 throws InsertException

Specified by:

tryCompress in interface CompressJob

Throws:

InsertException

start

public static InsertCompressor start(ClientContext ctx,
                                     freenet.client.async.SingleFileInserter inserter,
                                     RandomAccessBucket origData,
                                     int minSize,
                                     BucketFactory bf,
                                     boolean persistent,
                                     long generateHashes,
                                     boolean pre1254,
                                     Config config)

Create an InsertCompressor, add it to the database, schedule it.

Parameters:

ctx -

inserter -

origData -

minSize -

bf -

persistent -

generateHashes -

pre1254 -

Returns:

onFailure

public void onFailure(InsertException e,
                      ClientPutState c,
                      ClientContext context)

Specified by:

onFailure in interface CompressJob