X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9782799d931fd74cdcc7832681b4684aa145a50f..63c371bbca5afccc4708761d83af6fc2443ca553:/src/mc/Channel.cpp diff --git a/src/mc/Channel.cpp b/src/mc/Channel.cpp deleted file mode 100644 index 69024972d9..0000000000 --- a/src/mc/Channel.cpp +++ /dev/null @@ -1,50 +0,0 @@ -/* Copyright (c) 2015-2016. The SimGrid Team. - * All rights reserved. */ - -/* This program is free software; you can redistribute it and/or modify it - * under the terms of the license (GNU LGPL) which comes with this package. */ - -#include -#include - -#include -#include - -#include - -#include "src/mc/Channel.hpp" - -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_Channel, mc, "MC interprocess communication"); - -namespace simgrid { -namespace mc { - -Channel::~Channel() -{ - if (this->socket_ >=0) - close(this->socket_); -} - -int Channel::send(const void* message, size_t size) const -{ - XBT_DEBUG("Send %s", - MC_message_type_name(*(e_mc_message_type*) message)); - while (::send(this->socket_, message, size, 0) == -1) - if (errno == EINTR) - continue; - else - return errno; - return 0; -} - -ssize_t Channel::receive(void* message, size_t size, bool block) const -{ - int res = recv(this->socket_, message, size, block ? 0 : MSG_DONTWAIT); - if (res != -1) - XBT_DEBUG("Receive %s", - MC_message_type_name(*(e_mc_message_type*) message)); - return res; -} - -} -}