// Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "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:

//

/**

 @file

 @internalComponent

*/

#ifndef BULKBEARERINTERFACE_H

#define BULKBEARERINTERFACE_H

#include <e32base.h>

#include <e32hashtab.h>

#include <remcon/remconbearerbulkobserver.h>

#include "bearermanager.h"

class CRemConBulkServer;

class CRemConMessage;

class TBearerSecurity;

class MRemConBearerBulkInterface;

class TClientInfo;

NONSHARABLE_CLASS(CBulkBearerInterface) : public CBase, public MRemConBearerBulkObserver

	{

public:

	/** 

	Bearer manager construction.

	@return Ownership of a new CBulkBearerInterface object

	*/

	static CBulkBearerInterface* NewL(CRemConBulkServer& aServer, CBearerManager& aBearerManager);

	~CBulkBearerInterface();

public:

	void BulkClientAvailable(const TRemConClientId& aClient);

	void BulkClientRemoved(const TRemConClientId& aClient);

	/** Send a message over a specific connection and return the result 

	immediately. */

	TInt Send(CRemConMessage& aMsg);

	/**

	@param aBearerUid The bearer with which to check the security policy with.

	@param aMessage The message to check the policy against.

	@return non-zero if the security check passes, zero otherwise.

	*/

	TBool CheckPolicy(TUid aBearerUid, const TClientInfo& aClientInfo);

private:

	CBulkBearerInterface(CRemConBulkServer& aServer, CBearerManager& aBearerManager);

	void ConstructL(CBearerManager& aBearerManager);

	void StopBearers();

private: // from MRemConBearerBulkObserver

	TInt MrcbboDoNewCommand(const TRemConAddress& aAddr);

	TInt MrcbboDoNewCommand(const TRemConAddress& aAddr, const TRemConClientId& aClient);

	TUint MrcbboDoNewTransactionId();

	void MrcbboDoCommandExpired(TUint aTransactionId);

	TInt MrcbboDoSetAddressedClient(const TRemConAddress& aAddr, const TRemConClientId& aClient);

	TInt MrcbboDoRemoveAddressing(const TRemConAddress& aAddr);

private: // utility

#ifdef __FLOG_ACTIVE

	void LogBearers() const;

#endif

	void NewCommandL(const TRemConAddress& aAddr, const TRemConClientId& aClient);

	MRemConBearerBulkInterface* BearerIf(TUid aUid) const;

private: // unowned	

	RArray<CBearerManager::TBulkInterfaceInfo> iBearerIfs;

	RHashMap<TRemConAddress, TRemConClientId> iAddressedClients; // Stores client id by RemCon addr

private: // owned

	TUint iRunningTransactionId;

	TSglQueIter<TBearerSecurity> iSecurityPoliciesIter;

private: // unowned

	CRemConBulkServer& iServer;

	};

#endif // BULKBEARERINTERFACE_H