Commit 262e79b0 authored by Matthieu Dorier's avatar Matthieu Dorier

sending-side now also using ABT-IO for migration

parent 930beed2
......@@ -238,7 +238,6 @@ extern "C" int sdskv_provider_register(
margo_register_data(mid, rpc_id, (void*)tmp_svr_ctx, NULL);
/* register a REMI client */
// TODO use an ABT-IO instance
ret = remi_client_init(mid, ABT_IO_INSTANCE_NULL, &(tmp_svr_ctx->remi_client));
if(ret != REMI_SUCCESS) {
sdskv_server_finalize_cb(tmp_svr_ctx);
......@@ -246,7 +245,6 @@ extern "C" int sdskv_provider_register(
}
/* register a REMI provider */
// TODO use an ABT-IO instance
ret = remi_provider_register(mid, ABT_IO_INSTANCE_NULL, provider_id, abt_pool, &(tmp_svr_ctx->remi_provider));
if(ret != REMI_SUCCESS) {
sdskv_server_finalize_cb(tmp_svr_ctx);
......@@ -2377,5 +2375,8 @@ extern "C" int sdskv_provider_set_abtio_instance(
remi_provider_set_abt_io_instance(
provider->remi_provider,
abtio);
remi_client_set_abt_io_instance(
provider->remi_client,
abtio);
return SDSKV_SUCCESS;
}
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