- gras_datadesc_by_symbol(s_rep_suc));
- gras_msgtype_declare("chord_notify", gras_datadesc_by_symbol(s_notify));
+ xbt_datadesc_by_symbol(s_rep_suc));
+ gras_msgtype_declare("chord_notify", xbt_datadesc_by_symbol(s_notify));
int id; /* my id number */
char host[1024]; /* my host name */
int port; /* port on which I'm listening FIXME */
int id; /* my id number */
char host[1024]; /* my host name */
int port; /* port on which I'm listening FIXME */
- XBT_INFO(">>> %d : received %d message from %s to %d <<<",globals->id,pbio_i.type,gras_socket_peer_name(expeditor),pbio_i.dest);
+ XBT_INFO(">>> %d : received %d message from %s to %d <<<",globals->id,pbio_i.type,xbt_socket_peer_name(expeditor),pbio_i.dest);
get_suc_t incoming = *(get_suc_t *) payload_data;
rep_suc_t outgoing;
node_data_t *globals = (node_data_t *) gras_userdata_get();
XBT_INFO("Received a get_successor message from %s for %d",
get_suc_t incoming = *(get_suc_t *) payload_data;
rep_suc_t outgoing;
node_data_t *globals = (node_data_t *) gras_userdata_get();
XBT_INFO("Received a get_successor message from %s for %d",
if ((globals->id == globals->finger[0].id) ||
(incoming.id > globals->id
&& incoming.id <= globals->finger[0].id)) {
if ((globals->id == globals->finger[0].id) ||
(incoming.id > globals->id
&& incoming.id <= globals->finger[0].id)) {
temp_sock = gras_socket_client(globals->finger[contact].host,
globals->finger[contact].port);
}
temp_sock = gras_socket_client(globals->finger[contact].host,
globals->finger[contact].port);
}
}
gras_msg_wait(10., "chord_rep_suc", &temp_sock, &outgoing);
}
}
gras_msg_wait(10., "chord_rep_suc", &temp_sock, &outgoing);
}
gras_msg_send(expeditor, "chord_rep_suc", &outgoing);
XBT_INFO("Successor information sent!");
}
gras_msg_send(expeditor, "chord_rep_suc", &outgoing);
XBT_INFO("Successor information sent!");
}
- CATCH(e) {
- RETHROW2("%s:Timeout sending successor information to %s: %s",
- globals->host, gras_socket_peer_name(expeditor));
+ CATCH_ANONYMOUS {
+ RETHROWF("%s:Timeout sending successor information to %s: %s",
+ globals->host, xbt_socket_peer_name(expeditor));
/*xbt_ex_t e; */
notify_t incoming = *(notify_t *) payload_data;
node_data_t *globals = (node_data_t *) gras_userdata_get();
XBT_INFO("Received a notifying message from %s as %d",
/*xbt_ex_t e; */
notify_t incoming = *(notify_t *) payload_data;
node_data_t *globals = (node_data_t *) gras_userdata_get();
XBT_INFO("Received a notifying message from %s as %d",
if (globals->pre_id == -1 ||
(incoming.id > globals->pre_id && incoming.id < globals->id)) {
globals->pre_id = incoming.id;
if (globals->pre_id == -1 ||
(incoming.id > globals->pre_id && incoming.id < globals->id)) {
globals->pre_id = incoming.id;
rep_suc_t rep_suc_msg;
node_data_t *globals = (node_data_t *) gras_userdata_get();
TRY {
temp_sock = gras_socket_client(globals->host, globals->port);
rep_suc_t rep_suc_msg;
node_data_t *globals = (node_data_t *) gras_userdata_get();
TRY {
temp_sock = gras_socket_client(globals->host, globals->port);
}
get_suc_msg.id = globals->id;
TRY {
gras_msg_send(temp_sock, "chord_get_suc", &get_suc_msg);
}
get_suc_msg.id = globals->id;
TRY {
gras_msg_send(temp_sock, "chord_get_suc", &get_suc_msg);
}
TRY {
XBT_INFO("Waiting for reply!");
gras_msg_wait(6000, "chord_rep_suc", &temp_sock2, &rep_suc_msg);
}
TRY {
XBT_INFO("Waiting for reply!");
gras_msg_wait(6000, "chord_rep_suc", &temp_sock2, &rep_suc_msg);
}
globals->finger[0].id = rep_suc_msg.id;
snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
}
globals->finger[0].id = rep_suc_msg.id;
snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
}
TRY {
gras_msg_wait(60, "chord_pong", &temp_sock, &pong);
}
TRY {
gras_msg_wait(60, "chord_pong", &temp_sock, &pong);
int node(int argc, char **argv)
{
node_data_t *globals = NULL;
int node(int argc, char **argv)
{
node_data_t *globals = NULL;
}
get_suc_msg.id = globals->id;
TRY {
gras_msg_send(temp_sock, "chord_get_suc", &get_suc_msg);
}
}
get_suc_msg.id = globals->id;
TRY {
gras_msg_send(temp_sock, "chord_get_suc", &get_suc_msg);
}
}
TRY {
XBT_INFO("Waiting for reply!");
gras_msg_wait(10., "chord_rep_suc", &temp_sock2, &rep_suc_msg);
}
}
TRY {
XBT_INFO("Waiting for reply!");
gras_msg_wait(10., "chord_rep_suc", &temp_sock2, &rep_suc_msg);
}
}
globals->finger[0].id = rep_suc_msg.id;
snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
}
globals->finger[0].id = rep_suc_msg.id;
snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
temp_sock = gras_socket_client(globals->finger[0].host,
globals->finger[0].port);
}
temp_sock = gras_socket_client(globals->finger[0].host,
globals->finger[0].port);
}