Commit 53475954 authored by Shane Snyder's avatar Shane Snyder
Browse files

small tweaks to ssg examples

parent a3e3c57a
......@@ -164,7 +164,7 @@ static void shutdown_forward_recv(hg_handle_t h)
struct server_data* serv_data = (struct server_data *)
margo_registered_data(mid, info->id);
printf("Member %d got shutdown request\n", serv_data->self_rank);
printf("Member %d shutting down\n", serv_data->self_rank);
/* non-zero ranks continue forwarding shutdown request */
if (serv_data->self_rank > 0)
......
......@@ -120,7 +120,11 @@ static void token_forward_recv(hg_handle_t h)
if (serv_data->self_rank > 0)
token_forward(serv_data);
/* XXX initiate shutdown procedure on rank 0 once token has traversed ring */
/* XXX rather than shutting down immediately, send RPCs back through
* the ring to shutdown in reverse order (i.e., 3, 2, 1, 0) */
ssg_group_destroy(serv_data->gid);
ssg_finalize();
margo_finalize(serv_data->mid);
return;
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment