#ifndef CHANNEL_HEADERFILE
#define CHANNEL_HEADERFILE

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

#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