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, WEAKSSL
BUFFERSIZE, GZIPEXTENSION, ZIPEXTENSION
COMPLETED_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, setWWWAuthentication
addChecksumListener, 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, warnOverwrite
public 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 TransferController
init
in class HTTPTransfer
ClientException
public void begin()
begin
in interface TransferController
begin
in class HTTPTransfer
public void run()
run
in interface java.lang.Runnable
protected void process(java.io.File current) throws ClientException
current
- ClientException
protected void processFile(java.io.File current) throws ClientException
current
- ClientException
protected void recurseProcess(java.io.File dir, long level, long depth) throws ClientException
dir
- directorylevel
- current depthdepth
- ax depth allowedClientException
protected void splitAndTransfer(java.io.File currentfile) throws ClientException
currentfile
- ClientException
protected void transferAndRetry(java.io.File current, java.util.HashMap meta) throws ClientException
current
- meta
- ClientException
protected void transfer(java.io.File currentfile, java.util.HashMap meta) throws ClientException
currentfile
- meta
- HTTP parametersClientException
public void cancel()
cancel
in interface TransferController
cancel
in class HTTPTransfer
public 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
ClientException
public java.lang.Object execute() throws ClientException
execute
in interface TransferController
execute
in class HTTPTransfer
ClientException
public 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 TransferController
getParameters
in class AbstractTransferController