#include "trick/MonteCarlo.hh"
#include "trick/message_proto.h"
#include "trick/message_type.h"
#include "trick/tc_proto.h"
/** @par Detailed Design: */
int Trick::MonteCarlo::slave() {
/**
Forever: */
while (true) {
if (verbosity >= ALL) {
message_publish(MSG_INFO, "Monte [%s:%d] : Waiting for new run.\n",
machine_name.c_str(), slave_id) ;
}
/** - On a blocking read, wait for a MonteSlave::Command from the master. */
if (tc_accept(&listen_device, &connection_device) != TC_SUCCESS) {
if (verbosity >= ERROR) {
message_publish(MSG_ERROR, "Monte [%s:%d] : Lost connection to Master.\nShutting down.\n",
machine_name.c_str(), slave_id) ;
}
slave_shutdown();
}
int command;
if (tc_read(&connection_device, (char *)&command, (int)sizeof(command)) != (int)sizeof(command)) {
if (verbosity >= ERROR) {
message_publish(MSG_ERROR, "Monte [%s:%d] : Lost connection to Master while receiving instructions.\nShutting down.\n",
machine_name.c_str(), slave_id) ;
}
slave_shutdown();
}
switch (command = ntohl(command)) {
int return_value;
case MonteSlave::PROCESS_RUN:
/**
*
- MonteSlave::PROCESS_RUN: Call #slave_process_run. This will return a non-zero value when run in a
* child process to indicate that this function should return so that the sim can complete.
*/
return_value = slave_process_run();
if (return_value != 0) {
return return_value;
}
break;
case MonteSlave::SHUTDOWN:
/**
- MonteSlave::SHUTDOWN: Call #slave_shutdown. */
if (verbosity >= INFORMATIONAL) {
message_publish(MSG_INFO, "Monte [%s:%d] : Shutdown command received from Master.\nShutting down.\n",
machine_name.c_str(), slave_id) ;
}
slave_shutdown();
break;
case MonteSlave::DIE:
/**
- MonteSlave::DIE: Call #slave_die. */
if (verbosity >= INFORMATIONAL) {
message_publish(MSG_INFO, "Monte [%s:%d] : Killed by Master.\n",
machine_name.c_str(), slave_id) ;
}
slave_die();
break;
default:
/**
- default: Call #slave_shutdown. */
if (verbosity >= ERROR) {
message_publish(MSG_ERROR, "Monte [%s:%d] : Unrecognized command %d received from Master.\nShutting down.\n",
machine_name.c_str(), slave_id, command) ;
}
slave_shutdown();
break;
}
}
}