State::State(RemoteApp& remote_app, std::shared_ptr<State> parent_state)
: num_(++expended_states_), parent_state_(parent_state)
{
-
if (_sg_mc_strategy == "none")
strategy_ = std::make_shared<BasicStrategy>();
if (_sg_mc_strategy == "nb_wait")
auto checker = static_cast<simgrid::mc::CheckerSide*>(arg);
if (events == EV_READ) {
do {
-
std::array<char, MC_MESSAGE_LENGTH> buffer;
ssize_t size = checker->get_channel().receive(buffer.data(), buffer.size(), MSG_DONTWAIT);
if (size == -1) {
}
} else { // Ask our proxy to wait for us
-
s_mc_message_int_t request = {};
request.type = MessageType::WAIT_CHILD;
request.value = pid_;