in sdk/Commands/UploadPartCommand.cs [87:139]
public static UploadPartCommand Create(IServiceClient client, Uri endpoint, ExecutionContext context,
UploadPartRequest uploadPartRequest)
{
OssUtils.CheckBucketName(uploadPartRequest.BucketName);
OssUtils.CheckObjectKey(uploadPartRequest.Key);
if (string.IsNullOrEmpty(uploadPartRequest.UploadId))
throw new ArgumentException("uploadId should be specified");
if (!uploadPartRequest.PartNumber.HasValue)
throw new ArgumentException("partNumber should be specified");
if (!uploadPartRequest.PartSize.HasValue)
throw new ArgumentException("partSize should be specified");
if (uploadPartRequest.InputStream == null)
throw new ArgumentException("inputStream should be specified");
if (uploadPartRequest.PartSize < 0 || uploadPartRequest.PartSize > OssUtils.MaxFileSize)
throw new ArgumentException("partSize not live in valid range");
if (!OssUtils.IsPartNumberInRange(uploadPartRequest.PartNumber))
throw new ArgumentException("partNumber not live in valid range");
var conf = OssUtils.GetClientConfiguration(client);
var originalStream = uploadPartRequest.InputStream;
var streamLength = uploadPartRequest.PartSize.Value;
// wrap input stream in PartialWrapperStream
originalStream = new PartialWrapperStream(originalStream, streamLength);
// setup progress
var callback = uploadPartRequest.StreamTransferProgress;
if (callback != null)
{
originalStream = OssUtils.SetupProgressListeners(originalStream, conf.ProgressUpdateInterval, client, callback);
uploadPartRequest.InputStream = originalStream;
}
// wrap input stream in MD5Stream
if (conf.EnalbeMD5Check)
{
var hashStream = new MD5Stream(originalStream, null, streamLength);
uploadPartRequest.InputStream = hashStream;
context.ResponseHandlers.Add(new MD5DigestCheckHandler(hashStream));
}
else if (conf.EnableCrcCheck)
{
var hashStream = new Crc64Stream(originalStream, null, streamLength);
uploadPartRequest.InputStream = hashStream;
context.ResponseHandlers.Add(new Crc64CheckHandler(hashStream));
}
return new UploadPartCommand(client, endpoint, context,
DeserializerFactory.GetFactory().CreateUploadPartResultDeserializer(uploadPartRequest.PartNumber.Value, streamLength),
uploadPartRequest);
}