tranbase.cs

破解的飞信源代码

namespace Imps.Client.Core.P2P.AsyncTransportor
{
    using Imps.Client.Core;
    using Imps.Client.Core.P2P.FileTransportor;
    using Imps.Client.Core.P2P.ICE;
    using NCindy.Session.AIO;
    using System;
    using System.Diagnostics;

    public class TranBase : AbstractFileTransportor
    {
        protected Peer remotePeer;
        protected PunchingResult result;
        protected AsyncUDTSession session;
        private Stopwatch timeUsed;
        protected FileTransportorBase tranportor;

        public TranBase(PunchingResult result, Peer remotePeer, TransportingFile file)
        {
            this.result = result;
            this.remotePeer = remotePeer;
            base.targetFile = file;
        }

        private void OnBlockTransported(object sender, IntEventArgs e)
        {
            base.transportedBytes = base.targetFile.CompletedSize;
            base.FireBlockTransported(new BlockTranEventArgs(base.targetFile.CompletedSize, base.targetFile.FileSize, this.timeUsed.get_ElapsedMilliseconds()));
        }

        private void OnTransportCompleted(object sender, EventArgs e)
        {
            base.FireTransportCompleted();
        }

        private void OnTransportFailed(object sender, EventArgs e)
        {
            base.FireTransportFailed(new TranFailedEventArgs(null));
        }

        public override void Start()
        {
            this.timeUsed = Stopwatch.StartNew();
            this.tranportor.BlockTransported += new EventHandler<IntEventArgs>(this, (IntPtr) this.OnBlockTransported);
            this.tranportor.TransportCompleted += new EventHandler(this.OnTransportCompleted);
            this.tranportor.TransportFailed += new EventHandler(this.OnTransportFailed);
            this.tranportor.AsyncStart();
            base.Start();
        }

        public override void Stop()
        {
            this.tranportor.AsyncCancel();
            base.Stop();
        }

        public override int Rate
        {
            get
            {
                if (this.timeUsed.get_ElapsedMilliseconds() == 0)
                {
                    return 0;
                }
                return (int) ((0x3e8 * base.targetFile.CompletedSize) / this.timeUsed.get_ElapsedMilliseconds());
            }
        }
    }
}