summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
1e97527)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@1585
48e7efb5-ca39-0410-a469-
dd3cf9ba447f
reused by our predecessor.
Closing this side would thus create troubles */
reused by our predecessor.
Closing this side would thus create troubles */
- /* 9. Decrease the remaining_loop integer. */
+ /* 8. Decrease the remaining_loop integer. */
globals->remaining_loop -= 1;
globals->remaining_loop -= 1;
- /* 10. Repport the hop number to the user at the end */
+ /* 9. Repport the hop number to the user at the end */
if (globals->remaining_loop == -1 && globals->create) {
INFO1("Shut down the token-ring. There was %d hops.",msg);
}
if (globals->remaining_loop == -1 && globals->create) {
INFO1("Shut down the token-ring. There was %d hops.",msg);
}
- /* 11. Tell GRAS that we consummed this message */
+ /* 10. Tell GRAS that we consummed this message */
return 1;
} /* end_of_node_cb_stoken_handler */
return 1;
} /* end_of_node_cb_stoken_handler */
INFO3("Create the token (with value %d) and send it to %s:%d",
token, host, peerport);
INFO3("Create the token (with value %d) and send it to %s:%d",
token, host, peerport);
- gras_msg_send(globals->tosuccessor,
- gras_msgtype_by_name("stoken"), &token);
+ TRY {
+ gras_msg_send(globals->tosuccessor,
+ gras_msgtype_by_name("stoken"), &token);
+ } CATCH(e) {
+ RETHROW0("Unable to send the freshly created token: %s");
+ }
}
/* 8. Wait up to 10 seconds for an incomming message to handle */
}
/* 8. Wait up to 10 seconds for an incomming message to handle */