freenet.clients.fcp

Class ClientPutDir

java.lang.Object

freenet.clients.fcp.ClientRequest

freenet.clients.fcp.ClientPutBase

freenet.clients.fcp.ClientPutDir

All Implemented Interfaces:

ClientBaseCallback, ClientPutCallback, ClientEventListener, java.io.Serializable

public class ClientPutDir
extends ClientPutBase

See Also:

Serialized Form

Nested Class Summary

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	ClientPutDir()
	ClientPutDir(FCPConnectionHandler handler, ClientPutDirMessage message, java.util.HashMap<java.lang.String,java.lang.Object> manifestElements, boolean wasDiskPut, FCPServer server)
	ClientPutDir(PersistentRequestClient client, FreenetURI uri, java.lang.String identifier, int verbosity, short priorityClass, ClientRequest.Persistence persistence, java.lang.String clientToken, boolean getCHKOnly, boolean dontCompress, int maxRetries, java.io.File dir, java.lang.String defaultName, boolean allowUnreadableFiles, boolean includeHiddenFiles, boolean global, boolean earlyEncode, boolean canWriteClientCache, boolean forkOnCacheable, int extraInsertsSingleBlock, int extraInsertsSplitfileHeaderBlock, boolean realTimeFlag, byte[] overrideSplitfileCryptoKey, NodeClientCore core) Fproxy Puts a disk dir
	ClientPutDir(PersistentRequestClient client, FreenetURI uri, java.lang.String identifier, int verbosity, short priorityClass, ClientRequest.Persistence persistence, java.lang.String clientToken, boolean getCHKOnly, boolean dontCompress, int maxRetries, java.util.HashMap<java.lang.String,java.lang.Object> elements, java.lang.String defaultName, boolean global, boolean earlyEncode, boolean canWriteClientCache, boolean forkOnCacheable, int extraInsertsSingleBlock, int extraInsertsSplitfileHeaderBlock, boolean realTimeFlag, byte[] overrideSplitfileCryptoKey, NodeClientCore core)

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()
FreenetURI	getFinalURI()
int	getNumberOfFiles()
long	getTotalDataSize()
protected java.lang.String	getTypeName()
boolean	hasSucceeded()
void	innerResume(ClientContext context)
void	onFailure(FetchException e, ClientGetter state)
void	onFailure(InsertException e, BaseClientPutter state) Called on failed/canceled insert.
void	onLostConnection(ClientContext context) Lost connection
protected void	onStartCompressing()
protected void	onStopCompressing()
void	onSuccess(BaseClientPutter state) Called on successful insert.
void	onSuccess(FetchResult result, ClientGetter state)
protected FCPMessage	persistentTagMessage()
void	requestWasRemoved(ClientContext context) Called after a RemovePersistentRequest.
boolean	restart(ClientContext context, boolean disableFilterData)
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, onFetchable, onGeneratedMetadata, onGeneratedURI, receive, sendPendingMessages, setVarsRestart

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

ClientPutDir

public ClientPutDir(FCPConnectionHandler handler,
                    ClientPutDirMessage message,
                    java.util.HashMap<java.lang.String,java.lang.Object> manifestElements,
                    boolean wasDiskPut,
                    FCPServer server)
             throws IdentifierCollisionException,
                    java.net.MalformedURLException,
                    TooManyFilesInsertException

Throws:

IdentifierCollisionException

java.net.MalformedURLException

TooManyFilesInsertException

ClientPutDir

public ClientPutDir(PersistentRequestClient client,
                    FreenetURI uri,
                    java.lang.String identifier,
                    int verbosity,
                    short priorityClass,
                    ClientRequest.Persistence persistence,
                    java.lang.String clientToken,
                    boolean getCHKOnly,
                    boolean dontCompress,
                    int maxRetries,
                    java.io.File dir,
                    java.lang.String defaultName,
                    boolean allowUnreadableFiles,
                    boolean includeHiddenFiles,
                    boolean global,
                    boolean earlyEncode,
                    boolean canWriteClientCache,
                    boolean forkOnCacheable,
                    int extraInsertsSingleBlock,
                    int extraInsertsSplitfileHeaderBlock,
                    boolean realTimeFlag,
                    byte[] overrideSplitfileCryptoKey,
                    NodeClientCore core)
             throws java.io.FileNotFoundException,
                    IdentifierCollisionException,
                    java.net.MalformedURLException,
                    TooManyFilesInsertException

Fproxy Puts a disk dir

Throws:

TooManyFilesInsertException

InsertException

java.io.FileNotFoundException

IdentifierCollisionException

java.net.MalformedURLException

ClientPutDir

public ClientPutDir(PersistentRequestClient client,
                    FreenetURI uri,
                    java.lang.String identifier,
                    int verbosity,
                    short priorityClass,
                    ClientRequest.Persistence persistence,
                    java.lang.String clientToken,
                    boolean getCHKOnly,
                    boolean dontCompress,
                    int maxRetries,
                    java.util.HashMap<java.lang.String,java.lang.Object> elements,
                    java.lang.String defaultName,
                    boolean global,
                    boolean earlyEncode,
                    boolean canWriteClientCache,
                    boolean forkOnCacheable,
                    int extraInsertsSingleBlock,
                    int extraInsertsSplitfileHeaderBlock,
                    boolean realTimeFlag,
                    byte[] overrideSplitfileCryptoKey,
                    NodeClientCore core)
             throws IdentifierCollisionException,
                    java.net.MalformedURLException,
                    TooManyFilesInsertException

Throws:

IdentifierCollisionException

java.net.MalformedURLException

TooManyFilesInsertException

ClientPutDir

protected ClientPutDir()

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

onLostConnection

public void onLostConnection(ClientContext context)

Description copied from class: ClientRequest

Lost connection

Overrides:

onLostConnection in class ClientPutBase

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()

getNumberOfFiles

public int getNumberOfFiles()

getTotalDataSize

public long getTotalDataSize()

canRestart

public boolean canRestart()

Specified by:

canRestart in class ClientRequest

restart

public boolean restart(ClientContext context,
                       boolean disableFilterData)

Specified by:

restart in class ClientRequest

onFailure

public void onFailure(FetchException e,
                      ClientGetter state)

onSuccess

public void onSuccess(FetchResult result,
                      ClientGetter state)

onSuccess

public void onSuccess(BaseClientPutter state)

Description copied from interface: ClientPutCallback

Called on successful insert. In this callback you must free the Bucket which you specified for the insert!

Specified by:

onSuccess in interface ClientPutCallback

Overrides:

onSuccess in class ClientPutBase

Parameters:

state - The original BaseClientPutter object which was returned by the .insert() method which started this insert. Can be casted to the return type of that .insert() (to obtain the Bucket).

onFailure

public void onFailure(InsertException e,
                      BaseClientPutter state)

Description copied from interface: ClientPutCallback

Called on failed/canceled insert. In this callback you must free the Bucket which you specified for the insert!

Specified by:

onFailure in interface ClientPutCallback

Overrides:

onFailure in class ClientPutBase

state - The original BaseClientPutter object which was returned by the .insert() method which started this insert. Can be casted to the return type of that .insert() (to obtain the Bucket).

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

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