X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/80a1fe1a200a4309c36598571b1f4ccb76a8788f..6f21403d553131b282aeff52a2c496d71d05c97e:/messages.cpp?ds=sidebyside diff --git a/messages.cpp b/messages.cpp index fd19f6b..e9fbced 100644 --- a/messages.cpp +++ b/messages.cpp @@ -28,10 +28,26 @@ message::message(message_type t, double a, double c) std::string message::to_string() { - static const char* str[DATA_CLOSE + 1] = { "CTRL", "DATA", - "CTRL_CLOSE", "DATA_CLOSE" }; std::ostringstream oss; - oss << str[type] << ": " << amount; + switch (type) { + case CTRL: + oss << "CTRL: " << amount << " (info)"; + if (opt::bookkeeping) + oss << "; " << credit << " (credit)"; + break; + case DATA: + oss << "DATA: " << amount << " (load)"; + break; + case CTRL_CLOSE: + oss << "CTRL_CLOSE"; + break; + case DATA_CLOSE: + oss << "DATA_CLOSE"; + break; + default: + oss << "UNKNOWN MESSAGE TYPE: " << type; + break; + } return oss.str(); } @@ -56,7 +72,7 @@ bool message_queue::pop(message*& msg, m_host_t& from, double timeout) if (!queue.try_pop(task)) { xbt_ex_t e; XBT_DEBUG("waiting for a message to come"); - TRY { + TRY_FAST { if (timeout > 0) cond.timedwait(mutex, timeout); else