/*

* 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: 

*

*/

// Client.cpp: implementation of the CClient class.

//

//////////////////////////////////////////////////////////////////////

#include "stdafx.h"

#include "Client.h"

#include "ServerManager.h"

extern CServerManager* gManager;

#ifdef _DEBUG

extern BOOL gDoLogging;

#endif

//#define LOG_CLIENT

#if defined(LOG_CLIENT) && defined(_DEBUG)

extern char TCDebugMsg[];

#define TCDEBUGOPEN() if (gDoLogging) { gManager->m_DebugLog->WaitForAccess(); }

#define TCDEBUGLOGS(s) if (gDoLogging) { sprintf(TCDebugMsg,"%s", s); gManager->m_DebugLog->log(TCDebugMsg); }

#define TCDEBUGLOGA1(s, a1) if (gDoLogging) { sprintf(TCDebugMsg, s, a1); gManager->m_DebugLog->log(TCDebugMsg); }

#define TCDEBUGLOGA2(s, a1, a2) if (gDoLogging) { sprintf(TCDebugMsg, s, a1, a2); gManager->m_DebugLog->log(TCDebugMsg); }

#define TCDEBUGLOGA3(s, a1, a2, a3) if (gDoLogging) { sprintf(TCDebugMsg, s, a1, a2, a3); gManager->m_DebugLog->log(TCDebugMsg); }

#define TCDEBUGCLOSE() if (gDoLogging) { gManager->m_DebugLog->ReleaseAccess(); }

#else

#define TCDEBUGOPEN()

#define TCDEBUGLOGS(s)

#define TCDEBUGLOGA1(s, a1)

#define TCDEBUGLOGA2(s, a1, a2)

#define TCDEBUGLOGA3(s, a1, a2, a3)

#define TCDEBUGCLOSE()

#endif

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

CClient::CClient()

{

	TCDEBUGOPEN();

	TCDEBUGLOGS("CClient::CClient\n");

	m_InputStream = NULL;

	m_MessageFile = NULL;

	m_ErrorMonitor = NULL;

	m_Connection = NULL;

	m_Status = eStopped;

	m_ClientId = -1;

	m_Options.ostVersion = 1;

	m_Options.unWrapFormat = DEFAULT_UNWRAP_OPTION;

	m_MessageDestination = eDestinationInputStream;	// default - changed later

	TCDEBUGCLOSE();

}

CClient::CClient(CConnection* connection, ClientOptions& options, DWORD clientId)

{

	TCDEBUGOPEN();

	TCDEBUGLOGS("CClient::CClient\n");

	m_Connection = connection;

	m_Options.ostVersion = options.ostVersion;

	m_Options.unWrapFormat = options.unWrapFormat;

	m_ClientId = clientId;

	m_Status = eStopped;

	m_ErrorMonitor = new CErrorMonitor(m_ClientId);

	m_ErrorMonitor->CreateData();

	m_InputStream = NULL; // created on open instead

	m_MessageFile = NULL;

	m_MessageDestination = eDestinationInputStream;	// default - changed later

	TCDEBUGCLOSE();

}

CClient::~CClient()

{

	TCDEBUGOPEN();

	TCDEBUGLOGS("CClient::~CClient\n");

	if (m_ErrorMonitor)

		delete m_ErrorMonitor;

	if (m_InputStream)

		delete m_InputStream;

	if (m_MessageFile)

		delete m_MessageFile;

	TCDEBUGCLOSE();

}

BOOL CClient::OpenStream(DestinationOptions* streamOptions)

{

	TCDEBUGOPEN();

	TCDEBUGLOGS("CClient::OpenStream\n");

	BOOL done = TRUE;

	if (m_InputStream == NULL)

	{

		m_InputStream = new CInputStream(streamOptions->destinationFile, streamOptions->streamSize, streamOptions->overFlowToFile, m_ClientId);

		m_InputStream->CreateStream();

	}

	TCDEBUGCLOSE();

	return done;

}

BOOL CClient::CloseStream()

{

	TCDEBUGOPEN();

	TCDEBUGLOGS("CClient::CloseStream\n");

	BOOL done = TRUE;

	if (m_InputStream)

	{

		delete m_InputStream;

		m_InputStream = NULL;

	}

	TCDEBUGCLOSE();

	return done;

}

BOOL CClient::OpenMessageFile(DestinationOptions *messageFileOptions)

{

	BOOL done = TRUE;

	if (m_MessageFile == NULL)

	{

		m_MessageFile = new CMessageFile(messageFileOptions->destinationFile, m_ClientId);

		m_MessageFile->Open();

	}

	return done;

}

BOOL CClient::CloseMessageFile()

{

	BOOL done = TRUE;

	if (m_MessageFile)

	{

		delete m_MessageFile;

		m_MessageFile = NULL;

	}

	return done;

}

BOOL CClient::ClearMessageFile()

{

	BOOL done = TRUE;

	if (m_MessageFile)

	{

		m_MessageFile->ClearFile();

	}

	return done;

}