Synnefo » Pithos MS Client

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.IO;

using System.Linq;

using System.Net;

using System.Net.Http;

using System.Text;

using System.Threading.Tasks;

namespace Pithos.Network

{

    public class ByteArrayContentWithProgress : ByteArrayContent

    {

        private IProgress<UploadArgs> _progress;

        private readonly byte[] _content;

        private readonly int _offset;

        private readonly int _count;

        public ByteArrayContentWithProgress(byte[] content,IProgress<UploadArgs> progress )

            : this(content,0,content.Length,progress)

        {

        }

        /// <summary>

        /// Initializes a new instance of the <see cref="T:System.Net.Http.ByteArrayContent"/> class.

        /// </summary>

        /// <param name="content">The content used to initialize the <see cref="T:System.Net.Http.ByteArrayContent"/>.</param><param name="offset">The offset, in bytes, in the <paramref name="content"/>  parameter used to initialize the <see cref="T:System.Net.Http.ByteArrayContent"/>.</param><param name="count">The number of bytes in the <paramref name="content"/> starting from the <paramref name="offset"/> parameter used to initialize the <see cref="T:System.Net.Http.ByteArrayContent"/>.</param><exception cref="T:System.ArgumentNullException">The <paramref name="content"/> parameter is null. </exception><exception cref="T:System.ArgumentOutOfRangeException">The <paramref name="offset"/> parameter is less than zero.-or-The <paramref name="offset"/> parameter is greater than the length of content specified by the <paramref name="content"/> parameter.-or-The <paramref name="count "/> parameter is less than zero.-or-The <paramref name="count"/> parameter is greater than the length of content specified by the <paramref name="content"/> parameter - minus the <paramref name="offset"/> parameter.</exception>

        public ByteArrayContentWithProgress(byte[] content, int offset, int count, IProgress<UploadArgs> progress)

            : base(content, offset, count)

        {

            if (progress== null)

                throw new ArgumentNullException("progress");

            _progress = progress;

            _content = content;

            _offset = offset;

            _count = count;

        }

        public ByteArrayContentWithProgress Clone()

        {

            return new ByteArrayContentWithProgress(_content,_offset,_count,_progress);

        }

        /// <summary>

        /// Serialize and write the byte array provided in the constructor to an HTTP content stream as an asynchronous operation.

        /// </summary>

        /// 

        /// <returns>

        /// Returns <see cref="T:System.Threading.Tasks.Task"/>. The task object representing the asynchronous operation.

        /// </returns>

        /// <param name="stream">The target stream.</param><param name="context">Information about the transport, like channel binding token. This parameter may be null.</param>

        protected override async Task SerializeToStreamAsync(Stream stream, TransportContext context)

        {

            const int block_size = 65536;

            var watch = new Stopwatch();

            var end = _offset + _count;

            for (var idx = _offset; idx < end; idx += block_size)

            {

                var size = (idx > end - block_size)

                    ? end - idx

                    : block_size;

                var total = idx + size-_offset;

                watch.Start();

                await stream.WriteAsync(_content, idx, size).ConfigureAwait(false);

                watch.Stop();

                var speed = 1000 * size / watch.ElapsedMilliseconds;

                var percentage = Convert.ToInt32(100 * total / (double)_count);

                _progress.Report(new UploadArgs(percentage, null, total, _count, 0, 0,speed));

                watch.Restart();

            }

            //await Task.Factory.FromAsync(stream.BeginWrite, stream.EndWrite, _content, _offset, _count, null);

        }

    }

}