/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies). 
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
* 
* Description:
*
*/
using System;
using System.IO;
using System.Text;
using System.Threading;
using System.Collections;
using SymbianUtils.Tracer;

namespace SymbianUtils
{
	public abstract class AsyncBinaryReaderBase : AsyncReaderBase
	{
		#region Construct & destruct
		protected AsyncBinaryReaderBase()
            : this( null )
		{
		}
        
        protected AsyncBinaryReaderBase( ITracer aTracer )
            : base( aTracer )
        {
        }
        #endregion

		#region Read handlers
		protected virtual bool ContinueProcessing()
		{
			return false;
		}

		protected virtual bool ImmediateAbort()
		{
			return false;
		}

		protected virtual void HandleReadBytes( byte[] aData )
		{
		}
		#endregion

		#region Abstract reading framework
		protected abstract byte[] ProvideReadBytes();
		#endregion

		#region Internal methods
		protected override void PerformOperation()
		{
			bool forcedContinue = false;
			bool immediateAbort = false;
			byte[] bytes;
			//
			lock( this )
			{
				bytes = ProvideReadBytes();
				forcedContinue = ContinueProcessing();
				immediateAbort = ImmediateAbort();
			}

            System.DateTime tenPercentTime = DateTime.Now;

			int oldProgress = 0;
            int newProgress = 0;
			while ( ( bytes != null && bytes.Length > 0 ) || forcedContinue && !immediateAbort )
			{
				lock( this )
				{
					HandleReadBytes( bytes );
				}
				//
				lock( this )
				{
					newProgress = Progress;
					if	( newProgress != oldProgress )
					{
#if DEBUG
                        if ( newProgress > 0 && ( newProgress % 10 ) == 0 )
                        {
                            System.DateTime now = DateTime.Now;
                            long intermediateTickDuration = ( ( now.Ticks - tenPercentTime.Ticks ) / 100 );
                            System.Diagnostics.Debug.WriteLine( newProgress.ToString( "d2" ) + " % COMPLETE - " + intermediateTickDuration.ToString( "d12" ) );
                            tenPercentTime = now;
                        }
#endif
                        NotifyEvent( TEvent.EReadingProgress );
                        oldProgress = newProgress;
					}
					bytes = ProvideReadBytes();
				}
				//
				lock( this )
				{
					forcedContinue = ContinueProcessing();
				}
			}

            System.DateTime endTime = DateTime.Now;
            long tickDuration = ( ( endTime.Ticks - iOperationStartTime.Ticks ) / 100 );
            System.Diagnostics.Debug.WriteLine( "BINARY READ COMPLETE - " + tickDuration.ToString( "d12" ) );
        }

		#endregion
	}
}