public class HTTPUploadTransfer extends HTTPTransfer implements java.lang.Runnable
AbstractTransferController.HeadInfo| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ACCOUNT |
static java.lang.String |
ALTCHUNKBASE |
protected boolean |
cancelled |
static java.lang.String |
CHUNKACTION |
static java.lang.String |
CHUNKAMOUNT |
static java.lang.String |
CHUNKBASE |
static java.lang.String |
CHUNKBASESIZE |
static java.lang.String |
CHUNKEXTENSION |
static java.lang.String |
CHUNKID |
static java.lang.String |
CHUNKONFLY |
static java.lang.String |
CHUNKONFLYOFFSET |
static java.lang.String |
CHUNKONFLYSIZE |
protected java.lang.String |
chunkratioStr |
static java.lang.String |
DELETEAFTERUPLOAD |
static java.lang.String |
DYNAMICAUTH |
static java.lang.String |
EMPTYDIRECTORY |
static java.lang.String |
FILENAMEASHTMLENTITIES |
static java.lang.String |
FILETIMESTAMP |
protected java.io.FileOutputStream |
fout |
static java.lang.String |
FULLFILENAME |
static java.lang.String |
HEADEXTRAPARAMETERS |
static java.lang.String |
HTTPMETHOD |
static java.lang.String |
MKCOL |
static java.lang.String |
NOTIFYRELATIVEFILENAME |
static java.lang.String |
ONFLYRANGE |
static java.lang.String |
OVERWRITEWARNFORWARDFILE |
protected CustomFilePart |
param |
protected java.io.FileInputStream |
pfin |
protected java.io.File |
processed |
static java.lang.String |
RELATIVEFILENAME |
static java.lang.String |
RESUMEHEADER |
static java.lang.String |
RETRYERRORHEADER |
protected java.lang.String |
rfilename |
static java.lang.String |
SELECTEDFULLFILENAME |
protected java.lang.String |
sfullfilename |
protected boolean |
skipResume |
protected CustomFilePartSource |
source |
protected java.util.ArrayList |
uploadedfiles |
protected java.lang.String |
uploadurl |
protected java.io.File |
zip |
CONTENTRANGE, COOKIECLEAR, COOKIEHEADER, COOKIENAME, COOKIEOVERWRITE, COOKIEPATH, COOKIESOURCE, COOKIEVALUE, DEPRECATEDURL, ERRORHEADER, HTTPAUTHMETHOD, HTTPNTLMDOMAIN, HTTPNTLMHOST, HTTPPROXYHOST, HTTPPROXYNTLMDOMAIN, HTTPPROXYNTLMHOST, HTTPPROXYPASSWORD, HTTPPROXYPORT, HTTPPROXYUSERNAME, MIMETYPES, STATUSCODEKEY, WEAKSSLBUFFERSIZE, GZIPEXTENSION, ZIPEXTENSIONCOMPLETED_STATUS, MAX_AUTH_ATTEMPTS, PREPROCESSING_FILTER, RUNNING_STATUS, WAITING_STATUS| Constructor and Description |
|---|
HTTPUploadTransfer()
HTTP upload implementation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
begin()
Start upload thread.
|
void |
cancel()
Cancel current upload.
|
java.lang.Object |
execute()
NOT IMPLEMENTED for HTTP UPLOAD transfer.
|
protected AbstractTransferController.HeadInfo |
getHeadInfo(java.lang.String checksumOption,
java.io.File file,
java.lang.String name,
java.lang.String extraName,
java.lang.String extraValue) |
java.util.HashMap |
getParameters(java.lang.String section) |
protected java.lang.String |
getRelativeFilename(java.io.File cfile,
java.lang.String cname) |
java.lang.String |
getUploadurl() |
void |
init()
Initialization.
|
boolean |
isCancelled() |
protected void |
process(java.io.File current)
Process upload tasks including filtering.
|
protected void |
processFile(java.io.File current)
Process basic upload tasks.
|
protected void |
recurseProcess(java.io.File dir,
long level,
long depth)
Recurse folders (and sub folders) and process upload tasks.
|
void |
run()
Main upload loop.
|
void |
setUploadurl(java.lang.String uploadurl) |
protected void |
splitAndTransfer(java.io.File currentfile)
Split file (if needed) and transfer each chunk with meta data (chunkid, chunkamount, chunkabase).
|
protected void |
transfer(java.io.File currentfile,
java.util.HashMap meta)
Upload current file with optional additional HTTP parameters.
|
protected void |
transferAndRetry(java.io.File current,
java.util.HashMap meta)
Upload file with optional retry attempts if it fails.
|
authenticate, autoDetectProxy, getClient, getCustomFilenameMap, getCustomParameters, getHostname, headInfo, loadCookie, loadCookiesFromHandler, parseAuthenticateHeader, registerSSLSocketFactory, setProxyAuthentication, setupCookies, setWWWAuthenticationaddChecksumListener, addCompressListener, addFilterListener, addProtocolListener, addSplitListener, addTransferListener, authenticate, checksumCompletedNotification, checksumFailedNotification, checksummingNotification, checksumStartedNotification, checkZipMaxSize, cleanFilter, cleanFilter, compress, compress, compressFolder, compressingNotification, compressionFailedNotification, computeChecksum, executeFilter, executeFilter, getAllowedSourceFiles, getAuthentication, getBlackList, getChecksumListeners, getChunks, getChunkSize, getCompressListeners, getCRC32, getEncoding, getExt, getFilter, getFilter, getFilterChain, getFilterIDs, getFilterImpl, getFilterImpl, getFilterListeners, getFullMaxSize, getHidden, getLastChunkSize, getLong, getMaxDepth, getMaxFiles, getMaxSize, getMD5, getMetaProperties, getMetaScope, getMinSize, getOverwrite, getOverwriteWarn, getParamFile, getParentContainer, getPassword, getPolicy, getPreemptiveAuth, getPreProcessingFilter, getPreProcessingFilterImpl, getProtocolListeners, getRawConf, getResume, getResumeOffset, getRetry, getRetryDelay, getRootDir, getServerUrl, getSource, getSplitListeners, getStatus, getTarget, getTemplate, getTemplateScope, getTimeOut, getTmpDir, getTmpFolder, getTransferFileFilter, getTransferListeners, getUsername, getWhiteList, getZipFolder, getZipIgnoreList, getZipMaxSize, getZipOnFly, hexDump, isAllowed, isThreaded, recurse, recursiveCompress, removeChecksumListener, removeCompressListener, removeFilterListener, removeProtocolListener, removeSplitListener, removeTransferListener, rename, setAuthentication, setBlackList, setChunkSize, setEncoding, setExt, setFilter, setFilter, setFilterChain, setFilterIDs, setFilterImpl, setFilterImpl, setFullMaxSize, setHidden, setMaxDepth, setMaxFiles, setMaxSize, setMetaProperties, setMetaScope, setMinSize, setOverwrite, setOverwriteWarn, setParameters, setParamFile, setParentContainer, setPassword, setPolicy, setPreemptiveAuth, setPreProcessingFilter, setPreProcessingFilterImpl, setRawConf, setResume, setResumeOffset, setRetry, setRetryDelay, setRootDir, setServerUrl, setSource, setStatus, setTarget, setTemplate, setTemplateScope, setThreaded, setTimeOut, setTmpDir, setUsername, setWhiteList, setZipFolder, setZipIgnoreList, setZipMaxSize, setZipOnFly, warnOverwritepublic static java.lang.String RELATIVEFILENAME
public static java.lang.String NOTIFYRELATIVEFILENAME
public static java.lang.String FULLFILENAME
public static java.lang.String SELECTEDFULLFILENAME
public static java.lang.String FILETIMESTAMP
public static java.lang.String EMPTYDIRECTORY
public static java.lang.String CHUNKID
public static java.lang.String CHUNKAMOUNT
public static java.lang.String CHUNKBASE
public static java.lang.String CHUNKBASESIZE
public static java.lang.String CHUNKONFLY
public static java.lang.String ONFLYRANGE
public static java.lang.String CHUNKONFLYOFFSET
public static java.lang.String CHUNKONFLYSIZE
public static java.lang.String CHUNKEXTENSION
public static java.lang.String ALTCHUNKBASE
public static java.lang.String CHUNKACTION
public static java.lang.String HTTPMETHOD
public static java.lang.String ACCOUNT
public static java.lang.String RETRYERRORHEADER
public static java.lang.String RESUMEHEADER
public static java.lang.String HEADEXTRAPARAMETERS
public static java.lang.String DELETEAFTERUPLOAD
public static java.lang.String DYNAMICAUTH
public static java.lang.String MKCOL
public static java.lang.String FILENAMEASHTMLENTITIES
public static java.lang.String OVERWRITEWARNFORWARDFILE
protected boolean cancelled
protected CustomFilePartSource source
protected CustomFilePart param
protected java.io.FileOutputStream fout
protected java.io.FileInputStream pfin
protected java.lang.String uploadurl
protected java.lang.String sfullfilename
protected java.lang.String rfilename
protected java.util.ArrayList uploadedfiles
protected java.io.File zip
protected java.io.File processed
protected java.lang.String chunkratioStr
protected boolean skipResume
public void init()
throws ClientException
init in interface TransferControllerinit in class HTTPTransferClientExceptionpublic void begin()
begin in interface TransferControllerbegin in class HTTPTransferpublic void run()
run in interface java.lang.Runnableprotected void process(java.io.File current)
throws ClientException
current - ClientExceptionprotected void processFile(java.io.File current)
throws ClientException
current - ClientExceptionprotected void recurseProcess(java.io.File dir,
long level,
long depth)
throws ClientException
dir - directorylevel - current depthdepth - ax depth allowedClientExceptionprotected void splitAndTransfer(java.io.File currentfile)
throws ClientException
currentfile - ClientExceptionprotected void transferAndRetry(java.io.File current,
java.util.HashMap meta)
throws ClientException
current - meta - ClientExceptionprotected void transfer(java.io.File currentfile,
java.util.HashMap meta)
throws ClientException
currentfile - meta - HTTP parametersClientExceptionpublic void cancel()
cancel in interface TransferControllercancel in class HTTPTransferpublic boolean isCancelled()
protected java.lang.String getRelativeFilename(java.io.File cfile,
java.lang.String cname)
protected AbstractTransferController.HeadInfo getHeadInfo(java.lang.String checksumOption, java.io.File file, java.lang.String name, java.lang.String extraName, java.lang.String extraValue) throws ClientException
ClientExceptionpublic java.lang.Object execute()
throws ClientException
execute in interface TransferControllerexecute in class HTTPTransferClientExceptionpublic java.lang.String getUploadurl()
public void setUploadurl(java.lang.String uploadurl)
uploadurl - The uploadurl to set.public java.util.HashMap getParameters(java.lang.String section)
getParameters in interface TransferControllergetParameters in class AbstractTransferController