--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/crashanalysercmd/Libraries/File Formats/Plugins/DExcPlugin/Reader/DExcReader.cs	Thu Feb 11 15:50:58 2010 +0200
@@ -0,0 +1,119 @@
+/*
+* 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.Text;
+using System.IO;
+using System.Collections.Generic;
+using CrashItemLib.Crash.Container;
+using CrashItemLib.PluginAPI;
+using SymbianUtils.DataBuffer;
+using SymbianUtils.DataBuffer.Primer;
+using SymbianUtils;
+using DExcPlugin.Extractor;
+using DExcPlugin.Descriptor;
+using DExcPlugin.Plugin;
+using DExcPlugin.Transformer;
+
+namespace DExcPlugin.Reader
+{
+    internal class DExcReader : CFFReader
+	{
+		#region Constructors
+        public DExcReader( DExcPluginImp aEngine, DExcDescriptor aDescriptor )
+		:   base( aEngine, aDescriptor )
+		{
+            iTraceExtractor.StateChanged += new DExcExtractor.EventHandler( TraceExtractor_StateChanged );
+        }
+        #endregion
+
+        #region From CFFReader
+        public override void NativeReadInit()
+        {
+            throw new NotSupportedException();
+        }
+
+        public override void TraceReadInit()
+        {
+            // Check if there is an stk file with the same name
+            string stackFile = DExcDescriptor.StackFileName;
+            if ( File.Exists( stackFile ) )
+            {
+                iTraceExtractor.Init( stackFile );
+            }
+            else
+            {
+                iTraceExtractor.Init();
+            }
+        }
+
+        public override bool TraceReadOffer( CFFTraceLine aLine )
+        {
+            bool consumed = iTraceExtractor.Offer( aLine, aLine.LineNumber );
+            return consumed;
+        }
+
+        public override void TraceReadComplete()
+        {
+            // This flushes any pending raw data items in the interpreter.
+            iTraceExtractor.Finialize();
+            
+            base.NotifyEvent( TEvent.EReadingComplete );
+        }
+        #endregion
+
+        #region Properties
+        public DExcPluginImp DExcEngine
+        {
+            get { return base.Plugin as DExcPluginImp; }
+        }
+
+        public DExcDescriptor DExcDescriptor
+        {
+            get { return base.Descriptor as DExcDescriptor; }
+        }
+        #endregion
+
+        #region Observer - Trace interpreter
+        private void TraceExtractor_StateChanged( DExcExtractor.TEvent aEvent, DExcExtractor aExtractor )
+        {
+            // This event is notified when the extractor has obtained one entire D_EXC crash
+            if ( aEvent == DExcExtractor.TEvent.EEventExtractedAllData )
+            {
+                DExcExtractedData data = aExtractor.CurrentData;
+                DExcTransformer transformer = new DExcTransformer( DExcDescriptor, base.Plugin.DataProvider, data );
+
+                // Transform into crash container
+                CIContainer container = transformer.Transform();
+                if ( container != null )
+                {
+                    base.NotifyEvent( TEvent.EReadingContainerCreated, container );
+                }
+
+                // Get extractor ready for next file
+                iTraceExtractor.Init();
+            }
+        }
+        #endregion
+
+        #region Internal methods
+        #endregion
+
+        #region Data members
+        private DExcExtractor iTraceExtractor = new DExcExtractor();
+        #endregion
+    }
+}