/*
* 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 the License "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: 
*
*/
// MessageFile.h: interface for the CMessageFile class.
//
// One per client
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_MESSAGEFILE_H__1049F760_2A8A_491F_A868_B063D52B18E8__INCLUDED_)
#define AFX_MESSAGEFILE_H__1049F760_2A8A_491F_A868_B063D52B18E8__INCLUDED_

#include <share.h>
#include "stdio.h"
#include "mutex.h"
//#include "ServerClient.h"

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000


//----------------------------------
// Message File Mutex
//----------------------------------
// Mutex name is basename + clientID
#define MESSAGEFILE_MUTEX_BASENAME		"TCFMessageFileMutex"
#define MESSAGEFILE_MUTEX_TIMEOUT		(60000L)

class CMessageFile  
{
public:
	CMessageFile(CHAR* pFilePath, long inClientID);
	virtual ~CMessageFile();


	long Open();
	long Close();
	long AddMessage(DWORD inLength, BYTE* inMessage);
	void UnLockMessageFile() { ReleaseAccess(); }

	BOOL WaitForAccess() { if (m_FileLocked) return TRUE; else { m_FileLocked = TRUE; return m_Mutex.Wait();} };
	BOOL ReleaseAccess() { if (m_FileLocked) { m_FileLocked = FALSE; return m_Mutex.Release();} else return TRUE; };
	BOOL isOpen() { return m_Open; }
	long ClearFile();
	void FlushFile(BOOL numberTimeOut = FALSE);

	long m_ClientID;
	BOOL m_Open;
	Mutex m_Mutex;
	CHAR m_FilePath[MAX_FILEPATH];
	BOOL m_FileLocked;
	FILE* m_hFile;
	DWORD m_numWritten;		// total number written
	DWORD m_numWrittenSinceLastFlush;	// number written and not flushed yet

	// logging performance
// for performance - independent of debug logging
//#define LOG_FILE_PERFORMANCE
#ifdef LOG_FILE_PERFORMANCE
	char* perfFileName;
	FILE *fpLog;
	int numLogged;
	void logPerf(char* msg);
	void openPerf();
	void closePerf();
#define OPENFILEPERF() openPerf()
#define LOGFILEPERF(s) logPerf(s)
#define CLOSEFILEPERF() closePerf()
#else
#define OPENFILEPERF()
#define LOGFILEPERF(s)
#define CLOSEFILEPERF()
#endif



};

#endif // !defined(AFX_MESSAGEFILE_H__1049F760_2A8A_491F_A868_B063D52B18E8__INCLUDED_)