in sdk/Commands/AppendObjectCommand.cs [88:130]
public static AppendObjectCommand Create(IServiceClient client, Uri endpoint, ExecutionContext context,
AppendObjectRequest request)
{
OssUtils.CheckBucketName(request.BucketName);
OssUtils.CheckObjectKey(request.Key);
if (request.Content == null)
throw new ArgumentNullException("request.Content");
request.ObjectMetadata = request.ObjectMetadata ?? new ObjectMetadata();
if (request.ObjectMetadata.ContentType == null)
request.ObjectMetadata.ContentType = HttpUtils.GetContentType(request.Key, null);
var conf = OssUtils.GetClientConfiguration(client);
var originalStream = request.Content;
var streamLength = request.Content.Length;
// setup progress
var callback = request.StreamTransferProgress;
if (callback != null)
{
originalStream = OssUtils.SetupProgressListeners(originalStream, conf.ProgressUpdateInterval, client, callback);
request.Content = originalStream;
}
// wrap input stream in MD5Stream
if (conf.EnalbeMD5Check)
{
var hashStream = new MD5Stream(originalStream, null, streamLength);
request.Content = hashStream;
context.ResponseHandlers.Add(new MD5DigestCheckHandler(hashStream));
}
else if (conf.EnableCrcCheck && request.InitCrc != null)
{
var hashStream = new Crc64Stream(originalStream, null, streamLength, request.InitCrc.Value);
request.Content = hashStream;
context.ResponseHandlers.Add(new Crc64CheckHandler(hashStream));
}
return new AppendObjectCommand(client, endpoint, context,
DeserializerFactory.GetFactory().CreateAppendObjectResultDeserializer(),
request);
}