Commit 3171e59e authored by Philip Carns's avatar Philip Carns

get manual eager write path working

parent 97421e01
......@@ -131,7 +131,16 @@ static inline hg_return_t hg_proc_bake_bulk_eager_write_in_t(hg_proc_t proc, voi
hg_proc_bake_bulk_region_id_t(proc, &in->rid);
hg_proc_uint64_t(proc, &in->region_offset);
hg_proc_uint32_t(proc, &in->size);
if(hg_proc_get_op(proc) == HG_DECODE)
{
in->buffer = malloc(in->size);
}
hg_proc_memcpy(proc, in->buffer, in->size);
if(hg_proc_get_op(proc) == HG_FREE)
{
if(in->buffer)
free(in->buffer);
}
return(HG_SUCCESS);
}
......
......@@ -127,6 +127,9 @@ int main(int argc, char **argv)
MERCURY_REGISTER(hg_class, "bake_bulk_write_rpc", bake_bulk_write_in_t,
bake_bulk_write_out_t,
bake_bulk_write_ult_handler);
MERCURY_REGISTER(hg_class, "bake_bulk_eager_write_rpc", bake_bulk_eager_write_in_t,
bake_bulk_eager_write_out_t,
bake_bulk_eager_write_ult_handler);
MERCURY_REGISTER(hg_class, "bake_bulk_persist_rpc", bake_bulk_persist_in_t,
bake_bulk_persist_out_t,
bake_bulk_persist_ult_handler);
......
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