#include "messages.h"
+message::message(message_type t, double a, double c)
+ : type(t), amount(a) , credit(c)
+{
+ // compute message size
+ // arbitrary: 8 for type, and 8 for each double
+ switch (type) {
+ case INFO:
+ size = opt::bookkeeping ? 24 : 16; // type + amount + (credit)?
+ break;
+ case LOAD:
+ size = 16 + opt::comm_cost(amount); // type + amount + data size
+ break;
+ default:
+ size = 8; // type
+ break;
+ }
+}
+
std::string message::to_string()
{
- static const char* str[] = { "INFO", "CREDIT", "LOAD",
- "CTRL_CLOSE", "DATA_CLOSE" };
+ static const char* str[DATA_CLOSE + 1] = { "INFO", "LOAD",
+ "CTRL_CLOSE", "DATA_CLOSE" };
std::ostringstream oss;
oss << str[type] << ": " << amount;
return oss.str();
}
-double message::get_size() const
-{
- // arbitrary: 8 for type, and 8 for amount
- double size = 16;
- if (type == LOAD)
- size += opt::comm_cost(amount);
- return size;
-}
-
void message_queue::push(m_task_t task)
{
if (queue.push(task)) {