DriverPlatform-V3.1/DeviceBus/DeviceBus.h

#pragma once

#define DEVICEBUS_API 

#include "CcosThread.h"
#include "ResDataObject.h"
//#include "ErrorInfoObject.h"
#include "CcosFileHandle.h"

#define CCOS_HW_CHANNEL (80000)

#define CCOS_HW_COM_BUSID ("Ccos.Hw.Dev.Bus")



/*
class DEVICEBUS_API DeviceBUS // : public ErrorInfoObject
{
protected:
	bool m_Connected;
	Work_Thread *m_pPacketReceiveThread;//for receive packet

public:
	PVOID m_pP2PModule;
	DeviceBUS(void);
	virtual ~DeviceBUS(void);

	void SetReceiveThread(Work_Thread *pThread);

	virtual bool Connect(ResDataObject &connection);//assume there will be a lots various connections
	virtual void DisConnect();
	virtual bool IsConnected();

	virtual void Quit();
	virtual void SetLogPath(const char *pPath);

	virtual bool SendSMPacket(const char *pTargetID, const char *pContext, unsigned long long nShareMemID);

	virtual bool SendRawPacket(const char *pTargetID, const char *pContext, DWORD ChannelId);

	virtual bool SendPacket(const char *pTargetID, const char *pContext, const char *pBlock = NULL, DWORD BlockSize = 0);

	virtual void PacketArrived(ResDataObject &packet);

	virtual void BlobDataArrived(const char *pMsg, unsigned char *pBlockData, DWORD BlockDataLen);

	virtual void InitP2P(const char *pszIp, const char *pszLocalBusId, bool AsServer);

	virtual void UnRegistThread(DWORD Tid);

};*/

DEVICEBUS_API bool LoadBusDrv();
DEVICEBUS_API bool UnloadBusDrv();
DEVICEBUS_API void BusUnRegistThread(DWORD tid);
DEVICEBUS_API bool BusSendSMPacket(ResDataObject& packet, bool Local, string& TargetbusId, unsigned long long nShareMemID);
DEVICEBUS_API bool BusSendPacket(ResDataObject& packet, bool Local, string& TargetbusId, char* pBlockData = NULL, DWORD Size = 0);
DEVICEBUS_API CCOS_PACKET_ROUTE GetBusIdDirection(string& BusId);