Commit e6cabd10 authored by Philip Carns's avatar Philip Carns

stub eager write rpc structs

parent f6411a44
...@@ -13,7 +13,6 @@ ...@@ -13,7 +13,6 @@
/* encoders for bake-specific types */ /* encoders for bake-specific types */
static inline hg_return_t hg_proc_bake_target_id_t(hg_proc_t proc, bake_target_id_t *bti); static inline hg_return_t hg_proc_bake_target_id_t(hg_proc_t proc, bake_target_id_t *bti);
static inline hg_return_t hg_proc_bake_bulk_region_id_t(hg_proc_t proc, bake_bulk_region_id_t *rid); static inline hg_return_t hg_proc_bake_bulk_region_id_t(hg_proc_t proc, bake_bulk_region_id_t *rid);
/* shutdown */ /* shutdown */
DECLARE_MARGO_RPC_HANDLER(bake_bulk_shutdown_ult) DECLARE_MARGO_RPC_HANDLER(bake_bulk_shutdown_ult)
...@@ -36,6 +35,21 @@ MERCURY_GEN_PROC(bake_bulk_write_out_t, ...@@ -36,6 +35,21 @@ MERCURY_GEN_PROC(bake_bulk_write_out_t,
((int32_t)(ret))) ((int32_t)(ret)))
DECLARE_MARGO_RPC_HANDLER(bake_bulk_write_ult) DECLARE_MARGO_RPC_HANDLER(bake_bulk_write_ult)
/* bulk eager write */
typedef struct
{
bake_target_id_t bti;
bake_bulk_region_id_t rid;
uint64_t region_offset;
uint32_t size;
char * buffer;
} bake_bulk_eager_write_in_t;
static inline hg_return_t hg_proc_bake_bulk_eager_write_in_t(hg_proc_t proc, bake_bulk_eager_write_in_t *in);
MERCURY_GEN_PROC(bake_bulk_eager_write_out_t,
((int32_t)(ret)))
DECLARE_MARGO_RPC_HANDLER(bake_bulk_eager_write_ult)
/* bulk persist */ /* bulk persist */
MERCURY_GEN_PROC(bake_bulk_persist_in_t, MERCURY_GEN_PROC(bake_bulk_persist_in_t,
((bake_target_id_t)(bti))\ ((bake_target_id_t)(bti))\
...@@ -108,4 +122,10 @@ static inline hg_return_t hg_proc_bake_target_id_t(hg_proc_t proc, bake_target_i ...@@ -108,4 +122,10 @@ static inline hg_return_t hg_proc_bake_target_id_t(hg_proc_t proc, bake_target_i
return(hg_proc_raw(proc, bti->id, sizeof(bti->id))); return(hg_proc_raw(proc, bti->id, sizeof(bti->id)));
} }
static inline hg_return_t hg_proc_bake_bulk_eager_write_in_t(hg_proc_t proc, bake_bulk_eager_write_in_t *in)
{
/* TODO: implement */
return(HG_SUCCESS);
}
#endif /* __BAKE_BULK_RPC */ #endif /* __BAKE_BULK_RPC */
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