/*
* 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: 
*
*/
// Connection.h: interface for the CConnection class.
// Implemented by CConnectionImpl
//
// one of these per connection
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_CONNECTION_H__C7E97807_97B0_4BF7_AEC7_FA246A751509__INCLUDED_)
#define AFX_CONNECTION_H__C7E97807_97B0_4BF7_AEC7_FA246A751509__INCLUDED_

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

#include "ServerClient.h"
#include "TCErrorConstants.h"
#include "Client.h"
#include "Registry.h"
#include "BaseCom.h"
#include <vector>
#include <time.h>

// basename is suffixed with connection ID to make it unique per CConnection
#define MESSAGEPROCESSOR_EXITEVENT_BASENAME	"TCFServerMessageProcessorExittedEvent"
#define MESSAGEPROCESSOR_STOPEVENT_BASENAME	"TCFServerMessageProcessorStoppedEvent"
#define MESSAGEPROCESSOR_STARTEVENT_BASENAME	"TCFServerMessageProcessorStartedEvent"
#define MESSAGEPROCESSOR_EVENTWAIT_TIMEOUT	60000L

typedef std::vector<CClient*> ClientList;

// m_MessageProcessorState states
#define MP_NONE (0)
#define MP_EXIT (1)
#define MP_START (2)
#define MP_PAUSE (3)
#define MP_PROCESSING (4)


#define FLUSH_TIME		(100)		// 100 ms
class CConnection  
{
public:
	CConnection();
	CConnection(ConnectData conData, DWORD connectionId);
	virtual ~CConnection();

	virtual BOOL IsEqual(CConnection* connection)=0;
	virtual BOOL IsEqual(pConnectData pConData)=0;
	virtual long GetConnectionId() { return m_ConnectionID; }
	virtual BOOL ExitProcessing()=0;				// exit processing thread
	virtual long DoDisconnect()=0;
	virtual void NotifyClientsCommError(long tcfError, bool passOsError=false, DWORD osError=0)=0;
	long m_ConnectionID;			// id for this connection

	ConnectData* m_ConnectSettings;	// connection settings
};

#endif // !defined(AFX_CONNECTION_H__C7E97807_97B0_4BF7_AEC7_FA246A751509__INCLUDED_)