com.alibaba.sdk.android.oss.internal

类 BaseMultipartUploadTask<Request extends MultipartUploadRequest,Result extends CompleteMultipartUploadResult>

java.lang.Object

com.alibaba.sdk.android.oss.internal.BaseMultipartUploadTask<Request,Result>

所有已实现的接口:

java.util.concurrent.Callable<Result>

直接已知子类:

MultipartUploadTask, ResumableUploadTask, SequenceUploadTask

public abstract class BaseMultipartUploadTask<Request extends MultipartUploadRequest,Result extends CompleteMultipartUploadResult>
extends java.lang.Object
implements java.util.concurrent.Callable<Result>

Created by jingdan on 2017/10/30. multipart base task

字段概要

字段

限定符和类型	字段和说明
protected int	CPU_SIZE
protected int	KEEP_ALIVE_TIME
protected InternalRequestOperation	mApiOperation
protected int	MAX_CORE_POOL_SIZE
protected int	MAX_IMUM_POOL_SIZE
protected int	MAX_QUEUE_SIZE
protected boolean	mCheckCRC64
protected OSSCompletedCallback<Request,Result>	mCompletedCallback
protected ExecutionContext	mContext
protected long	mFileLength
protected boolean	mIsCancel
protected long	mLastPartSize
protected java.lang.Object	mLock
protected int[]	mPartAttr
protected java.util.List<PartETag>	mPartETags
protected int	mPartExceptionCount
protected java.util.concurrent.ThreadPoolExecutor	mPoolExecutor
protected OSSProgressCallback<Request>	mProgressCallback
protected Request	mRequest
protected int	mRunPartTaskCount
protected long	mUploadedLength
protected java.lang.Exception	mUploadException
protected java.io.File	mUploadFile
protected java.lang.String	mUploadFilePath
protected java.lang.String	mUploadId
protected Uri	mUploadUri
protected int	PART_SIZE_ALIGN_NUM

构造器概要

构造器

构造器和说明
BaseMultipartUploadTask(InternalRequestOperation operation, Request request, OSSCompletedCallback<Request,Result> completedCallback, ExecutionContext context)

方法概要

限定符和类型	方法和说明
protected abstract void	abortThisUpload() abort upload
Result	call()
protected long	ceilPartSize(long partSize)
protected void	checkCancel() check is or not cancel
protected void	checkException()
protected void	checkInitData()
protected void	checkPartSize(int[] partAttr) check part size
protected boolean	checkWaitCondition(int partNum)
protected CompleteMultipartUploadResult	completeMultipartUploadResult() complete multipart upload
protected abstract Result	doMultipartUpload() do multipart upload task
protected abstract void	initMultipartUploadId() init multipart upload id
protected void	notifyMultipartThread() notify wait thread
protected void	onProgressCallback(Request request, long currentSize, long totalSize) progress callback
protected void	preUploadPart(int readIndex, int byteCount, int partNumber)
protected abstract void	processException(java.lang.Exception e)
protected void	releasePool()
protected void	uploadPart(int readIndex, int byteCount, int partNumber)
protected void	uploadPartFinish(PartETag partETag)

从类继承的方法 java.lang.Object

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

字段详细资料

CPU_SIZE

protected final int CPU_SIZE

MAX_CORE_POOL_SIZE

protected final int MAX_CORE_POOL_SIZE

MAX_IMUM_POOL_SIZE

protected final int MAX_IMUM_POOL_SIZE

KEEP_ALIVE_TIME

protected final int KEEP_ALIVE_TIME

另请参阅:

常量字段值

MAX_QUEUE_SIZE

protected final int MAX_QUEUE_SIZE

另请参阅:

常量字段值

PART_SIZE_ALIGN_NUM

protected final int PART_SIZE_ALIGN_NUM

另请参阅:

常量字段值

mPoolExecutor

protected java.util.concurrent.ThreadPoolExecutor mPoolExecutor

mPartETags

protected java.util.List<PartETag> mPartETags

mLock

protected java.lang.Object mLock

mApiOperation

protected InternalRequestOperation mApiOperation

mContext

protected ExecutionContext mContext

mUploadException

protected java.lang.Exception mUploadException

mIsCancel

protected boolean mIsCancel

mUploadFile

protected java.io.File mUploadFile

mUploadId

protected java.lang.String mUploadId

mFileLength

protected long mFileLength

mPartExceptionCount

protected int mPartExceptionCount

mRunPartTaskCount

protected int mRunPartTaskCount

mUploadedLength

protected long mUploadedLength

mCheckCRC64

protected boolean mCheckCRC64

mRequest

protected Request extends MultipartUploadRequest mRequest

mCompletedCallback

protected OSSCompletedCallback<Request extends MultipartUploadRequest,Result extends CompleteMultipartUploadResult> mCompletedCallback

mProgressCallback

protected OSSProgressCallback<Request extends MultipartUploadRequest> mProgressCallback

mPartAttr

protected int[] mPartAttr

mUploadFilePath

protected java.lang.String mUploadFilePath

mLastPartSize

protected long mLastPartSize

mUploadUri

protected Uri mUploadUri

构造器详细资料

BaseMultipartUploadTask

public BaseMultipartUploadTask(InternalRequestOperation operation,
                               Request request,
                               OSSCompletedCallback<Request,Result> completedCallback,
                               ExecutionContext context)

方法详细资料

abortThisUpload

protected abstract void abortThisUpload()

abort upload

initMultipartUploadId

protected abstract void initMultipartUploadId()
                                       throws java.io.IOException,
                                              ClientException,
                                              ServiceException

init multipart upload id

抛出:

java.io.IOException

ClientException

ServiceException

doMultipartUpload

protected abstract Result doMultipartUpload()
                                     throws java.io.IOException,
                                            ServiceException,
                                            ClientException,
                                            java.lang.InterruptedException

do multipart upload task

返回:

抛出:

java.io.IOException

ServiceException

ClientException

java.lang.InterruptedException

checkCancel

protected void checkCancel()
                    throws ClientException

check is or not cancel

抛出:

ClientException

preUploadPart

protected void preUploadPart(int readIndex,
                             int byteCount,
                             int partNumber)
                      throws java.lang.Exception

抛出:

java.lang.Exception

uploadPartFinish

protected void uploadPartFinish(PartETag partETag)
                         throws java.lang.Exception

抛出:

java.lang.Exception

call

public Result call()
            throws java.lang.Exception

指定者:

call 在接口中 java.util.concurrent.Callable<Result extends CompleteMultipartUploadResult>

抛出:

java.lang.Exception

checkInitData

protected void checkInitData()
                      throws ClientException

抛出:

ClientException

uploadPart

protected void uploadPart(int readIndex,
                          int byteCount,
                          int partNumber)

processException

protected abstract void processException(java.lang.Exception e)

completeMultipartUploadResult

protected CompleteMultipartUploadResult completeMultipartUploadResult()
                                                               throws ClientException,
                                                                      ServiceException

complete multipart upload

返回:

抛出:

ClientException

ServiceException

releasePool

protected void releasePool()

checkException

protected void checkException()
                       throws java.io.IOException,
                              ServiceException,
                              ClientException

抛出:

java.io.IOException

ServiceException

ClientException

checkWaitCondition

protected boolean checkWaitCondition(int partNum)

notifyMultipartThread

protected void notifyMultipartThread()

notify wait thread

checkPartSize

protected void checkPartSize(int[] partAttr)

check part size

参数:

partAttr -

ceilPartSize

protected long ceilPartSize(long partSize)

onProgressCallback

protected void onProgressCallback(Request request,
                                  long currentSize,
                                  long totalSize)

progress callback

参数:

request -

currentSize -

totalSize -