X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/6f5ec5fdc42f96a8fe95f4b846b163d4dc92e0c8..e02d85948b5f10d8b37e39ec94d915c48f46a15a:/communicator.h?ds=sidebyside diff --git a/communicator.h b/communicator.h index f1ee1d9..465d0cf 100644 --- a/communicator.h +++ b/communicator.h @@ -4,46 +4,75 @@ #define COMMUNICATOR_H #include - +#include #include -#include -#include "neighbor.h" +#include "hostdata.h" + +class message { +public: + enum message_type { INFO, CREDIT, LOAD, CTRL_CLOSE, DATA_CLOSE }; + + message(message_type t, double a): type(t), amount(a) { } + + message_type get_type() const { return type; } + double get_amount() const { return amount; } + + std::string to_string(); + +private: + message_type type; + double amount; +}; class communicator { public: communicator(); ~communicator(); - void send_info(const neighbor& dest, double amount); - void send_credit(const neighbor& dest, double amount); - void send_load(const neighbor& dest, double amount); + // Start to listen for incoming messages + void listen(); - bool recv_info(double& amount, m_host_t& from); - bool recv_credit(double& amount, m_host_t& from); - bool recv_load(double& amount, m_host_t& from); + // Send a message to the "dest" mailbox + void send(const char* dest, message* msg); - int send_backlog(); + // Try to receive a message. Returns true on success. + // If "wait" is true, blocks until success or error. + bool recv(message*& msg, m_host_t& from, bool wait); + + // Try to flush pending sending communications. + // If "wait" is true, blocks until success. + void flush(bool wait); + + // Advertise that the next "close" message is the last one, and + // that we do not await any message after that, either on the + // control or the data channel. + void next_close_on_ctrl_is_last(); + void next_close_on_data_is_last(); private: - enum message_type { INFO_MSG, CREDIT_MSG }; - class message; + // Myself + const hostdata* host; // List of pending send communications std::list sent_comm; + static const int send_count_before_flush; + int send_counter; // Control channel for receiving - char* ctrl_mbox; - msg_comm_t ctrl_comm; - m_task_t ctrl_task; + m_task_t ctrl_task; // receive buffer + msg_comm_t ctrl_comm; // receive communication + bool ctrl_close_is_last; // do not rearm comm after next close // Data channel for receiving - char* data_mbox; - msg_comm_t data_comm; - m_task_t data_task; + m_task_t data_task; // receive buffer + msg_comm_t data_comm; // receive communication + bool data_close_is_last; // do not rearm comm after next close + + const char* get_ctrl_mbox() const { return host->get_ctrl_mbox(); } + const char* get_data_mbox() const { return host->get_data_mbox(); } - bool recv_ctrl(message_type type, double& amount, m_host_t& from); - void send(const char* dest, m_task_t task); - void flush_sent(); + // Used to test if a communication is over, and to destroy it if it is. + static bool comm_test_n_destroy(msg_comm_t comm); }; #endif // !COMMUNICATOR_H