Channel.h
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

Channel.h
View Options

	#ifndef CHANNEL_HEADERFILE
	#define CHANNEL_HEADERFILE

	#include <list>
	#include "Message.h"
	#include "Module.h"


	#define MAX_BUFFER_LENGTH 100
	#define OPEN NULL

	using namespace std;

	class Channel : public Module {

	private:

	list<Message*> lInputMsgBufferUp;
	list<Message*> lOutputMsgBufferUp;

	list<Message*> lInputMsgBufferDown;
	list<Message*> lOutputMsgBufferDown;

	unsigned int maxBufferLength;
	unsigned int transferRate;

	void init_channel();

	bool add_msgAtBegin (list<Message> buffer, Message* message);
	bool del_msgAtBegin (list<Message> buffer);

	bool add_msgAtEnd (list<Message> buffer, Message* message);
	bool del_msgAtEnd (list<Message> buffer);

	public:
	Channel();
	Channel(const char* name);

	bool set_maxBufferLength(unsigned int maxBufferLength);
	unsigned int get_maxBufferLength();

	unsigned int get_avlInputBufferUp();
	unsigned int get_avlOutputBufferUp();
	unsigned int get_avlInputBufferDown();
	unsigned int get_avlOutputBufferDown();

	bool set_transferRate(unsigned int transferRate);
	unsigned int get_transferRate();

	bool send_MsgUp(Message* message);
	bool send_MsgUp(float msg);
	bool send_MsgUp(int msg);
	bool get_MsgUp(float* msg);
	bool get_MsgUp(int* msg);
	bool isThereFloatMsgUp();
	bool isThereIntMsgUp();

	bool send_MsgDown(Message* message);
	bool send_MsgDown(float msg);
	bool send_MsgDown(int msg);
	bool get_MsgDown(float* msg);
	bool get_MsgDown(int* msg);
	bool isThereFloatMsgDown();
	bool isThereIntMsgDown();

	bool trigger();
	bool transferMsgs(list<Message> dest_buffer, list<Message> src_buffer);

	};


	#endif