DriverPlatform-V3.1/eBus/ClientsThreadMap.h

#pragma once

#include <map>
#include "CcosLock.h"

using namespace std;

/// <summary>
/// eBus BLOBStreamClient 对象
/// </summary>
class BusClientWrapper
{
	bool m_IsConnected;
	BUSC::BLOBStreamClient* m_pClient;

public:
	BusClientWrapper();
	~BusClientWrapper();

	bool IsConnected();
	void SetConnection(bool Flag);
	BUSC::BLOBStreamClient* GetBusClient();
};

/// <summary>
/// 为每一个线程自动分配一个 eBus StreamClient
/// </summary>
class ClientsThreadMap : public CcosLock
{
	map<DWORD, BusClientWrapper*> m_ThreadMap;

public:
	ClientsThreadMap();
	virtual ~ClientsThreadMap();

	//bool RegistThread(PVOID pCcosThread);
	BusClientWrapper* operator [](DWORD Tid);

	void UnRegistThread(DWORD Tid);

	void Disconnected();

	void Clear();
};