X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/269363f1bc63093972eb06e0537ca5f22ab8a53d..fd9d52c0c7a9c96221fff2013cdeef05b6e979e2:/src/mc/mc_protocol.cpp diff --git a/src/mc/mc_protocol.cpp b/src/mc/mc_protocol.cpp index 027bdda8e1..b420e4448b 100644 --- a/src/mc/mc_protocol.cpp +++ b/src/mc/mc_protocol.cpp @@ -15,43 +15,10 @@ #include #include "src/mc/mc_protocol.h" -#include "src/mc/mc_client.h" - -extern "C" { +#include "src/mc/Client.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_protocol, mc, "Generic MC protocol logic"); -int MC_protocol_send(int socket, const void* message, std::size_t size) -{ - XBT_DEBUG("Protocol [%s] send %s", - MC_mode_name(mc_mode), - MC_message_type_name(*(e_mc_message_type*) message)); - - while (send(socket, message, size, 0) == -1) - if (errno == EINTR) - continue; - else - return errno; - return 0; -} - -int MC_protocol_send_simple_message(int socket, e_mc_message_type type) -{ - s_mc_message_t message; - message.type = type; - return MC_protocol_send(socket, &message, sizeof(message)); -} - -ssize_t MC_receive_message(int socket, void* message, size_t size, int options) -{ - int res = recv(socket, message, size, options); - if (res != -1) - XBT_DEBUG("Protocol [%s] received %s", - MC_mode_name(mc_mode), - MC_message_type_name(*(e_mc_message_type*) message)); - return res; -} - const char* MC_message_type_name(e_mc_message_type type) { switch(type) { @@ -83,19 +50,3 @@ const char* MC_message_type_name(e_mc_message_type type) return "?"; } } - -const char* MC_mode_name(e_mc_mode_t mode) -{ - switch(mode) { - case MC_MODE_NONE: - return "NONE"; - case MC_MODE_CLIENT: - return "CLIENT"; - case MC_MODE_SERVER: - return "SERVER"; - default: - return "?"; - } -} - -}