Subversion Repositories DevTools

//## begin module%1.7%.codegen_version preserve=yes

//   Read the documentation to learn more about C++ code generator

//   versioning.

//## end module%1.7%.codegen_version

//## begin module%425A0C2601FD.cm preserve=no

//## end module%425A0C2601FD.cm

//## begin module%425A0C2601FD.cp preserve=no

//	C O P Y R I G H T   N O T I C E

//	This material is confidential to ERG and may not be disclosed in whole

//	or in part to any third party nor used in any manner whatsoever other

//	than for the purposes expressly consented to by ERG in writing.

//

//	This material is also copyright and may not be reproduced, stored in a

//	retrieval system or transmitted in any form or by any means in whole or

//	in part without the express written consent of ERG.

//## end module%425A0C2601FD.cp

//## Module: UdDrainFile%425A0C2601FD; Pseudo Package body

//## Subsystem: MASS::Dev::Tools::TxnTestManager::src%41F5A79001E4

//## Source file: Z:\MASS_Dev\Tools\TxnTestManager\src\UdDrainFile.cpp

//## begin module%425A0C2601FD.additionalIncludes preserve=no

//## end module%425A0C2601FD.additionalIncludes

//## begin module%425A0C2601FD.includes preserve=yes

#pragma warn -com

#include <LoggingMacros.h>

#pragma warn +com

//## end module%425A0C2601FD.includes

// IXmlSchemaWrapperElement

#include "IXmlSchemaWrapperElement.h"

// IXmlSchemaWrapperHandle

#include "IXmlSchemaWrapperHandle.h"

// IXmlSchemaWrapperFactory

#include "IXmlSchemaWrapperFactory.h"

// IXmlSchemaWrapperSchema

#include "IXmlSchemaWrapperSchema.h"

// UdDrainFile

#include "UdDrainFile.h"

//## begin module%425A0C2601FD.additionalDeclarations preserve=yes

//## end module%425A0C2601FD.additionalDeclarations

// Class UdDrainFile 

//## Operation: UdDrainFile%425A132E0282

UdDrainFile::UdDrainFile (XMLSchema::IXmlSchemaWrapperFactory &schemaFactory, XMLSchema::IXmlSchemaWrapperSchema &schema)

  //## begin UdDrainFile::UdDrainFile%425A132E0282.hasinit preserve=no

      : m_headed(false),

        m_schemaFactory(&schemaFactory),

        m_schema(&schema),

        m_structureHandle(0),

        m_structure(0)

  //## end UdDrainFile::UdDrainFile%425A132E0282.hasinit

  //## begin UdDrainFile::UdDrainFile%425A132E0282.initialization preserve=yes

  //## end UdDrainFile::UdDrainFile%425A132E0282.initialization

{

  //## begin UdDrainFile::UdDrainFile%425A132E0282.body preserve=yes

  //## end UdDrainFile::UdDrainFile%425A132E0282.body

}

UdDrainFile::~UdDrainFile()

{

  //## begin UdDrainFile::~UdDrainFile%425A0C2601FD_dest.body preserve=yes

	if ( m_structure )

	{

		m_schema->destroySchemaElement( *m_structure );

		m_structure = 0;

	}

	if ( m_structureHandle )

	{

		m_schema->destroyStructure( m_structureHandle->c_str() );

		m_schemaFactory->destroyHandle( *m_structureHandle );

		m_structureHandle = 0;

	}

	m_schemaFactory = 0;	// We don't own this object.

	m_schema = 0;			// We don't own this object.

  //## end UdDrainFile::~UdDrainFile%425A0C2601FD_dest.body

}

//## Other Operations (implementation)

//## Operation: getTransactionCount%425A1A1901D3

const unsigned int UdDrainFile::getTransactionCount () const

{

  //## begin UdDrainFile::getTransactionCount%425A1A1901D3.body preserve=yes

	unsigned int count = 0;

	if ( m_structure )

	{

		XMLSchema::IXmlSchemaWrapperElement * attribute = 0;

		try

		{

			if ( m_headed )

			{

				attribute = m_structure->createSchemaElement( "NoOfItems" );

			}

			else

			{

				attribute = m_structure->createSchemaElement( "NoOfItems" );

			}

			if ( attribute )

			{

				if ( !attribute->getUnsignedInteger32( count ) )

				{

					MTHROW( std::runtime_error, \

						"Cannot read the number of transactions in drain file." );

				}

			}

		}

		__finally

		{

			m_structure->destroySchemaElement( *attribute );

			attribute = 0;

		}

	}

	return ( count );

  //## end UdDrainFile::getTransactionCount%425A1A1901D3.body

}

//## Operation: read%425A1133022E

const bool UdDrainFile::read (const bool &hasHeader, const int &iteration, const char *fileName)

{

  //## begin UdDrainFile::read%425A1133022E.body preserve=yes

	XMLSchema::IXmlSchemaWrapperStream * stream = 0;

	try

	{

		m_structureHandle = &m_schemaFactory->createHandle();

		m_headed = hasHeader;

		if ( m_schema->createStructure(

				( m_headed ? "Mass_BatchUsageData_t" : "Mass_UDRecords_t" ),

				iteration,

				*m_structureHandle ) )

		{

			if ( ( m_structure = m_schema->createSchemaElement(

						m_structureHandle->c_str(),

						"" ) ) != 0 )

			{

				stream = &m_schemaFactory->createXdrStream();

				if ( !m_schema->deserialise(

						m_structureHandle->c_str(),

						*stream ) )

				{

					MERROR( "Cannot serialise \"" << fileName << "\"." )

					return ( false );

				}

				return ( true );

			}

		}

		else

		{

			m_schemaFactory->destroyHandle( *m_structureHandle );

			m_structureHandle = 0;

		}

	}

	__finally

	{

		if ( stream )

		{

			m_schemaFactory->destroyStream( *stream );

			stream = 0;

		}

	}

	return ( false );

  //## end UdDrainFile::read%425A1133022E.body

}

// Additional Declarations

  //## begin UdDrainFile%425A0C2601FD.declarations preserve=yes

  //## end UdDrainFile%425A0C2601FD.declarations

//## begin module%425A0C2601FD.epilog preserve=yes

//## end module%425A0C2601FD.epilog