src/mc/mc_protocol.cpp

   1 /* Copyright (c) 2015. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 #include <errno.h>
   8 #include <string.h>
   9 #include <stdio.h> // perror
  10
  11 #include <sys/types.h>
  12 #include <sys/socket.h>
  13
  14 #include <xbt/log.h>
  15
  16 #include "src/mc/mc_protocol.h"
  17 #include "src/mc/mc_client.h"
  18
  19 extern "C" {
  20
  21 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_protocol, mc, "Generic MC protocol logic");
  22
  23 int MC_protocol_send(int socket, const void* message, std::size_t size)
  24 {
  25   XBT_DEBUG("Protocol [%s] send %s",
  26     MC_mode_name(mc_mode),
  27     MC_message_type_name(*(e_mc_message_type*) message));
  28
  29   while (send(socket, message, size, 0) == -1) {
  30     if (errno == EINTR)
  31       continue;
  32     else
  33       return errno;
  34   }
  35   return 0;
  36 }
  37
  38 int MC_protocol_send_simple_message(int socket, e_mc_message_type type)
  39 {
  40   s_mc_message_t message;
  41   message.type = type;
  42   return MC_protocol_send(socket, &message, sizeof(message));
  43 }
  44
  45 ssize_t MC_receive_message(int socket, void* message, size_t size, int options)
  46 {
  47   int res = recv(socket, message, size, options);
  48   if (res != -1) {
  49     XBT_DEBUG("Protocol [%s] received %s",
  50       MC_mode_name(mc_mode),
  51       MC_message_type_name(*(e_mc_message_type*) message));
  52   }
  53   return res;
  54 }
  55
  56 const char* MC_message_type_name(e_mc_message_type type)
  57 {
  58   switch(type) {
  59   case MC_MESSAGE_NONE:
  60     return "NONE";
  61   case MC_MESSAGE_CONTINUE:
  62     return "CONTINUE";
  63   case MC_MESSAGE_IGNORE_HEAP:
  64     return "IGNORE_HEAP";
  65   case MC_MESSAGE_UNIGNORE_HEAP:
  66     return "UNIGNORE_HEAP";
  67   case MC_MESSAGE_IGNORE_MEMORY:
  68     return "IGNORE_MEMORY";
  69   case MC_MESSAGE_STACK_REGION:
  70     return "STACK_REGION";
  71   case MC_MESSAGE_REGISTER_SYMBOL:
  72     return "REGISTER_SYMBOL";
  73   case MC_MESSAGE_DEADLOCK_CHECK:
  74     return "DEADLOCK_CHECK";
  75   case MC_MESSAGE_DEADLOCK_CHECK_REPLY:
  76     return "DEADLOCK_CHECK_REPLY";
  77   case MC_MESSAGE_WAITING:
  78     return "WAITING";
  79   case MC_MESSAGE_SIMCALL_HANDLE:
  80     return "SIMCALL_HANDLE";
  81   case MC_MESSAGE_ASSERTION_FAILED:
  82     return "ASSERTION_FAILED";
  83   default:
  84     return "?";
  85   }
  86 }
  87
  88 const char* MC_mode_name(e_mc_mode_t mode)
  89 {
  90   switch(mode) {
  91   case MC_MODE_NONE:
  92     return "NONE";
  93   case MC_MODE_CLIENT:
  94     return "CLIENT";
  95   case MC_MODE_SERVER:
  96     return "SERVER";
  97   default:
  98     return "?";
  99   }
 100 }
 101
 102 }