C / C++ / MFC

#ifndef _HEADER_FILE_H_
#define _HEADER_FILE_H_

#pragma once // sometimes with this line
...
#endif

#pragma once

UINT CVarFileEvent::MultiFileProcessThread( LPVOID lpParam )
{
	// This is the threaded multi-file processor. It 
	//	searches for and processes all VAR files in the
	//	Inbox or until it is cancelled by a call from
	//	DataMovement due to a Cancel message from PC-GBS.
	CVarFileEvent* pEvent = (CVarFileEvent*)lpParam;
	TRACE( "> > > > Entering CVarFileEvent::MultiFileProcessThread()\n" );

	// We must call ::CoInitialize() each time the database is accessed
	HRESULT hRes = ::CoInitialize(NULL);
	try
	{
		vector<cstring> vecVarFiles = UtilK::findAllFiles( "*.var", 
						pDataMovement->getInboxPath(), 
						false );
		TRACE( "> > > > > Beginning processing of %d VAR files\n", 
						(int)vecVarFiles.size() );

		CDataMovement* pDataMovement = pEvent->getDataMovementParent();
		CFlightDataHandler FlightDataHandler( pDataMovement->getLogWriter() );
		// run until we are cancelled or all files processed
		for( vector<cstring>::iterator iterFile = vecVarFiles.begin();
				iterFile != vecVarFiles.end()  &&  m_bIsThreadRunning;
				iterFile++ )
		{
            			FlightDataHandler.importVARFile( *iterFile );
			// now delete the input file and remove the event 
			//	for this file from the queue if it exists
			::DeleteFile( *iterFile );
			pDataMovement->deleteFileEvent( *iterFile );
		}
	}
	catch(...)
	{
		CString strMsg( "importVARFile() failed with unexpected exception" );
		TRACE( "> > > > CVarFileEvent::MultiFileProcessThread() exception < %s >\n", strMsg );
		CLogWriter* pLogWriter = pDataMovement->getLogWriter();
		pLogWriter->writeEntry( "CVarFileEvent", CLogWriter::LE_OPERATION_FAILED, strMsg );
	}

	// Cleanup
	::CoUninitialize();
	// the main thread is waiting so indicate we have stopped processing
	pDataMovement->setInboxProcessEndEvent();
	m_bIsThreadRunning = false;
	return 1;
}</cstring></cstring>