Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
b368eafc3c4073f2fc13d7b6bbd3d9d47340fca8
[simgrid.git] / src / mc / Channel.cpp
1 /* Copyright (c) 2015-2016. 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 <unistd.h>
9
10 #include <sys/types.h>
11 #include <sys/socket.h>
12
13 #include <xbt/log.h>
14
15 #include "src/mc/Channel.hpp"
16
17 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_Channel, mc, "MC interprocess communication");
18
19 namespace simgrid {
20 namespace mc {
21
22 Channel::~Channel()
23 {
24   if (this->socket_ >=0)
25     close(this->socket_);
26 }
27
28 int Channel::send(const void* message, size_t size) const
29 {
30   XBT_DEBUG("Protocol [%s] send %s",
31     MC_mode_name(mc_mode),
32     MC_message_type_name(*(e_mc_message_type*) message));
33
34   while (::send(this->socket_, message, size, 0) == -1)
35     if (errno == EINTR)
36       continue;
37     else
38       return errno;
39   return 0;
40 }
41
42 ssize_t Channel::receive(void* message, size_t size, bool block) const
43 {
44   int res = recv(this->socket_, message, size, block ? 0 : MSG_DONTWAIT);
45   if (res != -1)
46     XBT_DEBUG("Protocol [%s] received %s",
47       MC_mode_name(mc_mode),
48       MC_message_type_name(*(e_mc_message_type*) message));
49   return res;
50 }
51
52 }
53 }