#include "../inc/CATProcessData.h"

bool CATParseTraceFile::StartParse( const char* pFileName, const char* pOutputFileName, const char* pCleanedTraceFile )

	bool bCreateCleanedTraces = false;

	ofstream cleanedTraces;

	// check is creation of file needed

	if( pCleanedTraceFile != NULL )

	{

		// if yes open file for cleaned traces

	    // (<AT> messages with cleaned timestamps)

		bCreateCleanedTraces = true;

		cleanedTraces.open(pCleanedTraceFile);

		if( !cleanedTraces.good() )

		{

			printf( "Can not open file: %s\n", pCleanedTraceFile );

			return bRet;

		}

	}

			string sTemp("");

			unsigned __int64 iTimeStamp(0);

			string sTime("");

			string sLineStart("");

			// Get part of line before main id. This should contain time info

			sLineStart = GetStringUntilMainId( sRestOfLine );

			// Get message's time stamp in microseconds

			iTimeStamp = ParseTimeStamp( sLineStart );

			// store whole line from MAIN_ID - to be logged to cleaned traces file

		    string sLineToCleanedFile( sRestOfLine );

			// This might be process id, device info message or error message

			if ( sTemp.compare( LABEL_DEVICE_INFO ) == 0 ) 

			{

				if( vProcessList[iProcessIDinList].bProcessOnGoing == false )

				continue;

				// get time string from timestamp

			    sTime = GetTimeFromTimeStamp( iTimeStamp, vProcessList[iProcessIDinList].iTimeSpan );

				// device info line, log it to cleaned file for carbide

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << LABEL_DEVICE_INFO << " "; //add Message type

				cleanedTraces << sRestOfLine << "\n"; //add the rest of the line

				}

				continue;

			}

			// todo to be removed when reallocations are implemented

			string sProcessID = sTemp;

				// remove <processName> <processID> part

				GetStringUntilNextSpace( sRestOfLine );

				GetStringUntilNextSpace( sRestOfLine );

				// get time

				sTemp = GetStringUntilNextSpace( sRestOfLine );

				unsigned __int64 iTemp(0);

				sscanf_s( sTemp.c_str(), "%016I64x", &iTemp);

				//calculate span between PCS time and PCS timestamp

				vProcessList[iProcessIDinList].iTimeSpan = iTemp - iTimeStamp;

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				cleanedTraces << sTemp << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << sWholeTempLine << "\n"; //add the rest of the line

				}

			// get time string from timestamp

			sTime = GetTimeFromTimeStamp( iTimeStamp, vProcessList[iProcessIDinList].iTimeSpan );

			// TODO version with reallocation

			//cleanedTraces << sTime << " "; //add time

			//cleanedTraces << sLineToCleanedFile << "\n"; //add the rest of the line

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << sWholeTempLine << "\n"; //add the rest of the line

				}

				vProcessList[iProcessIDinList].AllocH( sRestOfLine, sTime );

						viSubTestIter->AllocH( sRestOfLine, sTime );

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << sWholeTempLine << "\n"; //add the rest of the line

				}

				vProcessList[iProcessIDinList].AllocF( sRestOfLine, sTime );

						viSubTestIter->AllocF( sRestOfLine, sTime );

					}

					viSubTestIter++;

				}

			}

			else if ( ! _stricmp( pCommand, REALLOCH_ID ) )

			{

				// Add free

				// get 'free' line from realloc line

				string sFreeRestOfLine = sRestOfLine;

				string sFreeLine = "";

				sFreeLine.append( GetStringUntilNextSpace( sFreeRestOfLine, true ) ); //append freed memory address

				sFreeLine.append( " " );

				// next two strings are for 'alloc' (address and size) - lets remove them

				GetStringUntilNextSpace( sFreeRestOfLine, true );

				GetStringUntilNextSpace( sFreeRestOfLine, true );

				// add rest of line to 'free' line

				sFreeLine.append( sFreeRestOfLine );

				//add 'free' line

				vProcessList[iProcessIDinList].FreeH( sFreeLine, sTime );

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				// construct 'free' header trace

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << FREEH_ID << " "; //add FRH

				cleanedTraces << sFreeLine << "\n"; //add the rest of the line

				}

				// Add alloc

				//get 'alloc' line from realloc line

				// only first string is unnecessary, lets remove it

				GetStringUntilNextSpace( sRestOfLine );

     			// add 'alloc' line

				vProcessList[iProcessIDinList].AllocH( sRestOfLine, sTime );

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				// construct 'alloc' header trace

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << ALLOCH_ID << " "; //add FRH

				cleanedTraces << sRestOfLine << "\n"; //add the rest of the line

				}

				// Subtests running?

				vector<CSubTestData>::iterator viSubTestIter = vProcessList[iProcessIDinList].vSubTests.begin();

				while( viSubTestIter != vProcessList[iProcessIDinList].vSubTests.end() )

				{

					if( viSubTestIter->bRunning )

					{

						// Save realloc also to sub test

						// Add free

						// get 'free' line from realloc line

						string sFreeRestOfLine = sRestOfLine;

						string sFreeLine = "";

						sFreeLine.append( GetStringUntilNextSpace( sFreeRestOfLine, true ) ); //append freed memory address

						sFreeLine.append( " " );

						// next two strings are for 'alloc' (address and size) - lets remove them

						GetStringUntilNextSpace( sFreeRestOfLine, true );

						GetStringUntilNextSpace( sFreeRestOfLine, true );

						// add rest of line to 'free' line

						sFreeLine.append( sFreeRestOfLine );

						//add 'free' line

						vProcessList[iProcessIDinList].FreeH( sFreeLine, sTime );

						// Add alloc

						//get 'alloc' line from realloc line

						// only first string is unnecessary, lets remove it

						GetStringUntilNextSpace( sRestOfLine );

     					// add 'alloc' line

						vProcessList[iProcessIDinList].AllocH( sRestOfLine, sTime );

					}

					viSubTestIter++;

				}

			}

			// rellocation fragment (call stack).

			else if ( ! _stricmp( pCommand, REALLOCF_ID ) )

			{

				// Add free fragment 

				// get 'free' line from realloc line

				string sFreeRestOfLine = sRestOfLine;

				string sFreeLine = "";

				sFreeLine.append( GetStringUntilNextSpace( sFreeRestOfLine, true ) ); //append freed memory address

				sFreeLine.append( " " );

				// next string is for 'alloc' (address) - lets remove it

				GetStringUntilNextSpace( sFreeRestOfLine, true );

				// add rest of line to 'free' line

				sFreeLine.append( sFreeRestOfLine );

				//add 'free' line

				vProcessList[iProcessIDinList].FreeH( sFreeLine, sTime );

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				// construct 'free' fragment trace

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << FREEF_ID << " "; //add FRF

				cleanedTraces << sFreeLine << "\n"; //add the rest of the line

				}

				// Add alloc fragment

				// first string is for 'free' (address), lets remove it first

				GetStringUntilNextSpace( sRestOfLine, true );

				//add 'alloc' line

				vProcessList[iProcessIDinList].AllocF( sRestOfLine, sTime );

				if( bCreateCleanedTraces )

				{

				// add message to cleaned traces file

				// construct 'alloc' fragment trace

				cleanedTraces << sTime << " "; //add time

				cleanedTraces << MAIN_ID << " "; //add MAIN_ID

				cleanedTraces << sProcessID << " "; //add process ID

				cleanedTraces << ALLOCF_ID << " "; //add FRF

				cleanedTraces << sRestOfLine << "\n"; //add the rest of the line

				}

				// Subtests running?

				vector<CSubTestData>::iterator viSubTestIter = vProcessList[iProcessIDinList].vSubTests.begin();

				while( viSubTestIter != vProcessList[iProcessIDinList].vSubTests.end() )

				{

					if( viSubTestIter->bRunning )

					{

						// Save alloc fragment also to sub test

						// Add free fragment 

						// get 'free' line from realloc line

						string sFreeRestOfLine = sRestOfLine;

						string sFreeLine = "";

						sFreeLine.append( GetStringUntilNextSpace( sFreeRestOfLine, true ) ); //append freed memory address

						sFreeLine.append( " " );

						// next string is for 'alloc' (address) - lets remove it

						GetStringUntilNextSpace( sFreeRestOfLine, true );

						// add rest of line to 'free' line

						sFreeLine.append( sFreeRestOfLine );

						//add 'free' line

						vProcessList[iProcessIDinList].FreeH( sFreeLine, sTime );

						// Add alloc fragment