XBT_LOG_NEW_DEFAULT_CATEGORY(can, "Messages specific to this example");
// struct of a "nuke" message, when a node send a nuke to (xId;yId).
-GRAS_DEFINE_TYPE(s_nuke, struct s_nuke {
+XBT_DEFINE_TYPE(s_nuke, struct s_nuke {
int xId; int yId; char host[1024]; // original expeditor..
int port; // ..and his port.
int version; // fun.
int start_war(int argc, char **argv);
int start_war(int argc, char **argv)
{
- gras_socket_t temp_sock = NULL;
+ xbt_socket_t temp_sock = NULL;
nuke_t nuke_msg;
- xbt_ex_t e; // the error variable used in TRY.. CATCH tokens.
//return 0; // in order to inhibit the War of the Nodes
gras_init(&argc, argv);
gras_os_sleep((15 - gras_os_getpid()) * 20 + 200); // wait a bit.
TRY { // contacting the bad guy that will launch the War.
temp_sock = gras_socket_client(gras_os_myname(), atoi(argv[1]));
- } CATCH(e) {
+ }
+ CATCH_ANONYMOUS {
RETHROWF("Unable to connect known host so as to declare WAR!: %s");
}
TRY {
gras_msg_send(temp_sock, "can_nuke", &nuke_msg);
- } CATCH(e) {
+ }
+ CATCH_ANONYMOUS {
gras_socket_close(temp_sock);
RETHROWF
("Unable to contact known host so as to declare WAR!!!!!!!!!!!!!!!!!!!!!: %s");
static int send_nuke(nuke_t * msg, int xId, int yId)
{
node_data_t *globals = (node_data_t *) gras_userdata_get();
- gras_socket_t temp_sock = NULL;
- xbt_ex_t e; // the error variable used in TRY.. CATCH tokens.
+ xbt_socket_t temp_sock = NULL;
if (xId >= globals->x1 && xId <= globals->x2 && yId >= globals->y1
&& yId <= globals->y2) {
TRY { // sending the nuke.
temp_sock = gras_socket_client(host, port);
}
- CATCH(e) {
+ CATCH_ANONYMOUS {
RETHROWF("Unable to connect the nuke!: %s");
}
//XBT_INFO("%s ON %s %d %d <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<",globals->host,host,xId,yId);
TRY {
gras_msg_send(temp_sock, "can_nuke", msg);
}
- CATCH(e) {
+ CATCH_ANONYMOUS {
RETHROWF("Unable to send the nuke!: %s");
}
gras_socket_close(temp_sock);
static int node_nuke_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
{
- gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
+ xbt_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
nuke_t *incoming = (nuke_t *) payload_data;
node_data_t *globals = (node_data_t *) gras_userdata_get();
int x;
int y;
nuke_t nuke_msg; // writing my name one the nuke.
- gras_socket_t temp_sock = NULL;
+ xbt_socket_t temp_sock = NULL;
xbt_ex_t e; // the error variable used in TRY.. CATCH tokens.
TRY {
temp_sock = gras_socket_client(host, port);
}
- CATCH(e) {
+ CATCH_ANONYMOUS {
RETHROWF("Unable to connect the nuke!: %s");
}
TRY {
gras_msg_send(temp_sock, "can_nuke", incoming);
}
- CATCH(e) {
+ CATCH_ANONYMOUS {
RETHROWF("Unable to send the nuke!: %s");
}
XBT_INFO("Nuke re-aimed by %s to %s for (%d;%d)", globals->host, host,