Commit 5bc4d532 authored by Philip Carns's avatar Philip Carns
Browse files

update to match new margo handler conventions

parent 2efabaa9
Pipeline #238 skipped
...@@ -8,24 +8,22 @@ ...@@ -8,24 +8,22 @@
#include "bake-bulk-rpc.h" #include "bake-bulk-rpc.h"
/* service a remote RPC that instructs the server daemon to shut down */ /* service a remote RPC that instructs the server daemon to shut down */
static void bake_bulk_shutdown_ult(void *_arg) static void bake_bulk_shutdown_ult(hg_handle_t handle)
{ {
hg_handle_t *handle = _arg;
hg_return_t hret; hg_return_t hret;
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
printf("Got RPC request to shutdown\n"); printf("Got RPC request to shutdown\n");
hgi = HG_Get_info(*handle); hgi = HG_Get_info(handle);
assert(hgi); assert(hgi);
mid = margo_hg_class_to_instance(hgi->hg_class); mid = margo_hg_class_to_instance(hgi->hg_class);
hret = margo_respond(mid, *handle, NULL); hret = margo_respond(mid, handle, NULL);
assert(hret == HG_SUCCESS); assert(hret == HG_SUCCESS);
HG_Destroy(*handle); HG_Destroy(handle);
/* NOTE: we assume that the server daemon is using /* NOTE: we assume that the server daemon is using
* margo_wait_for_finalize() to suspend until this RPC executes, so there * margo_wait_for_finalize() to suspend until this RPC executes, so there
......
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