freenet.clients.fcp

Class ClientPut

java.lang.Object

freenet.clients.fcp.ClientRequest

freenet.clients.fcp.ClientPutBase

freenet.clients.fcp.ClientPut

All Implemented Interfaces:

ClientBaseCallback, ClientPutCallback, ClientEventListener, java.io.Serializable

public class ClientPut
extends ClientPutBase

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClientPut.COMPRESS_STATE

Nested classes/interfaces inherited from class freenet.clients.fcp.ClientPutBase

ClientPutBase.UploadFrom

Nested classes/interfaces inherited from class freenet.clients.fcp.ClientRequest

ClientRequest.Persistence

Field Summary

Fields inherited from class freenet.clients.fcp.ClientPutBase

FILE_HASH, generatedURI, progressMessage, publicURI, putFailedMessage, SALT, succeeded

Fields inherited from class freenet.clients.fcp.ClientRequest

client, clientName, clientToken, completionTime, finished, global, identifier, lowLevelClient, origHandler, persistence, priorityClass, realTime, started, startupTime, uri, verbosity

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientPut()
	ClientPut(FCPConnectionHandler handler, ClientPutMessage message, FCPServer server)
	ClientPut(PersistentRequestClient globalClient, FreenetURI uri, java.lang.String identifier, int verbosity, java.lang.String charset, short priorityClass, ClientRequest.Persistence persistence, java.lang.String clientToken, boolean getCHKOnly, boolean dontCompress, int maxRetries, ClientPutBase.UploadFrom uploadFromType, java.io.File origFilename, java.lang.String contentType, RandomAccessBucket data, FreenetURI redirectTarget, java.lang.String targetFilename, boolean earlyEncode, boolean canWriteClientCache, boolean forkOnCacheable, int extraInsertsSingleBlock, int extraInsertsSplitfileHeaderBlock, boolean realTimeFlag, InsertContext.CompatibilityMode compatMode, byte[] overrideSplitfileKey, boolean binaryBlob, NodeClientCore core) Fproxy Creates a new persistent insert.

Method Summary

Modifier and Type	Method and Description
boolean	canRestart()
protected void	freeData() Free cached data bucket(s)
boolean	fullyResumed() Return true if we resumed the original fetch from stored data (usually a file for a splitfile download), rather than having to restart it (which happens in most other cases when we resume).
protected ClientRequester	getClientRequest()
long	getDataSize()
FreenetURI	getFinalURI()
java.lang.String	getMIMEType()
java.io.File	getOrigFilename()
protected java.lang.String	getTypeName()
boolean	hasSucceeded()
void	innerResume(ClientContext context)
ClientPut.COMPRESS_STATE	isCompressing() Probably not meaningful for ClientPutDir's
boolean	isDirect()
protected void	onStartCompressing()
protected void	onStopCompressing()
protected FCPMessage	persistentTagMessage()
void	requestWasRemoved(ClientContext context) Called after a RemovePersistentRequest.
boolean	restart(ClientContext context, boolean disableFilterData)
void	setVarsRestart()
void	start(ClientContext context) Start the request, if it has not already been started.

Methods inherited from class freenet.clients.fcp.ClientPutBase

getFailedBlocks, getFailureMessage, getFailureReason, getFatalyFailedBlocks, getFetchedBlocks, getGeneratedURI, getMinBlocks, getSuccessFraction, getTotalBlocks, isTotalFinalized, onFailure, onFetchable, onGeneratedMetadata, onGeneratedURI, onLostConnection, onSuccess, receive, sendPendingMessages

Methods inherited from class freenet.clients.fcp.ClientRequest

cancel, dropped, finish, getClient, getClientDetail, getIdentifier, getLastActivity, getPriority, getRequestClient, getRequestIdentifier, hasFinished, hashCode, isGlobalQueue, isPersistent, isPersistentForever, isStarted, modifyRequest, onResume, onShutdown, restartAsync, restartFrom

Methods inherited from class java.lang.Object

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

Methods inherited from interface freenet.client.async.ClientBaseCallback

getRequestClient, onResume

Constructor Detail

ClientPut

public ClientPut(PersistentRequestClient globalClient,
                 FreenetURI uri,
                 java.lang.String identifier,
                 int verbosity,
                 java.lang.String charset,
                 short priorityClass,
                 ClientRequest.Persistence persistence,
                 java.lang.String clientToken,
                 boolean getCHKOnly,
                 boolean dontCompress,
                 int maxRetries,
                 ClientPutBase.UploadFrom uploadFromType,
                 java.io.File origFilename,
                 java.lang.String contentType,
                 RandomAccessBucket data,
                 FreenetURI redirectTarget,
                 java.lang.String targetFilename,
                 boolean earlyEncode,
                 boolean canWriteClientCache,
                 boolean forkOnCacheable,
                 int extraInsertsSingleBlock,
                 int extraInsertsSplitfileHeaderBlock,
                 boolean realTimeFlag,
                 InsertContext.CompatibilityMode compatMode,
                 byte[] overrideSplitfileKey,
                 boolean binaryBlob,
                 NodeClientCore core)
          throws IdentifierCollisionException,
                 NotAllowedException,
                 MetadataUnresolvedException,
                 java.io.IOException

Fproxy Creates a new persistent insert.

Parameters:

uri - The URI to insert data to

identifier - The identifier of the insert

verbosity - The verbosity bitmask

charset - TODO

priorityClass - The priority for this insert

persistence - The persistence type of this insert

clientToken - The client token of this insert

getCHKOnly - Whether only the resulting CHK is requested

dontCompress - Whether the file should not be compressed

maxRetries - The maximum number of retries

uploadFromType - Where the file is uploaded from

origFilename - The original filename

contentType - The content type of the data

data - The data (may be null if uploadFromType is UPLOAD_FROM_REDIRECT)

redirectTarget - The URI to redirect to (if uploadFromType is UPLOAD_FROM_REDIRECT)

handler - The FCP connection handler

global - Whether this insert appears on the global queue

Throws:

IdentifierCollisionException

NotAllowedException

MetadataUnresolvedException

java.io.IOException

InsertException

ClientPut

public ClientPut(FCPConnectionHandler handler,
                 ClientPutMessage message,
                 FCPServer server)
          throws IdentifierCollisionException,
                 MessageInvalidException,
                 java.io.IOException

Throws:

IdentifierCollisionException

MessageInvalidException

java.io.IOException

ClientPut

protected ClientPut()

Method Detail

start

public void start(ClientContext context)

Description copied from class: ClientRequest

Start the request, if it has not already been started.

Specified by:

start in class ClientRequest

freeData

protected void freeData()

Description copied from class: ClientRequest

Free cached data bucket(s)

Specified by:

freeData in class ClientRequest

getClientRequest

protected ClientRequester getClientRequest()

Specified by:

getClientRequest in class ClientRequest

persistentTagMessage

protected FCPMessage persistentTagMessage()

Specified by:

persistentTagMessage in class ClientPutBase

getTypeName

protected java.lang.String getTypeName()

Specified by:

getTypeName in class ClientPutBase

hasSucceeded

public boolean hasSucceeded()

Specified by:

hasSucceeded in class ClientRequest

getFinalURI

public FreenetURI getFinalURI()

isDirect

public boolean isDirect()

getOrigFilename

public java.io.File getOrigFilename()

getDataSize

public long getDataSize()

getMIMEType

public java.lang.String getMIMEType()

canRestart

public boolean canRestart()

Specified by:

canRestart in class ClientRequest

restart

public boolean restart(ClientContext context,
                       boolean disableFilterData)

Specified by:

restart in class ClientRequest

setVarsRestart

public void setVarsRestart()

Overrides:

setVarsRestart in class ClientPutBase

requestWasRemoved

public void requestWasRemoved(ClientContext context)

Description copied from class: ClientRequest

Called after a RemovePersistentRequest. Send a PersistentRequestRemoved to the clients. If the request is in the database, delete it.

Overrides:

requestWasRemoved in class ClientPutBase

isCompressing

public ClientPut.COMPRESS_STATE isCompressing()

Probably not meaningful for ClientPutDir's

onStartCompressing

protected void onStartCompressing()

Specified by:

onStartCompressing in class ClientPutBase

onStopCompressing

protected void onStopCompressing()

Specified by:

onStopCompressing in class ClientPutBase

innerResume

public void innerResume(ClientContext context)
                 throws ResumeFailedException

Specified by:

innerResume in class ClientRequest

Throws:

ResumeFailedException

fullyResumed

public boolean fullyResumed()

Description copied from class: ClientRequest

Return true if we resumed the original fetch from stored data (usually a file for a splitfile download), rather than having to restart it (which happens in most other cases when we resume).

Specified by:

fullyResumed in class ClientRequest