#include "dapl.h"
#include "dapl_hca_util.h"
#include "dapl_init.h"
#include "dapl_provider.h"
#include "dapl_mr_util.h"
#include "dapl_osd.h"
#include "dapl_adapter_util.h"
#include "dapl_name_service.h"
#include "dapl_vendor.h"
static void dapl_init(void);
static void dapl_fini(void);
#pragma init(dapl_init)
#pragma fini(dapl_fini)
static void
dapl_init(void)
{
DAT_RETURN dat_status;
dapl_dbg_log(DAPL_DBG_TYPE_UTIL, "DAPL: Started (dapl_init)\n");
#if defined(DAPL_DBG)
g_dapl_dbg_type = dapl_os_get_env_val("DAPL_DBG_TYPE",
DAPL_DBG_TYPE_ERR | DAPL_DBG_TYPE_WARN);
g_dapl_dbg_dest = dapl_os_get_env_val("DAPL_DBG_DEST",
DAPL_DBG_DEST_STDOUT);
#endif
g_dapl_loopback_connection = dapl_os_get_env_bool("DAPL_LOOPBACK");
dapl_dbg_log(DAPL_DBG_TYPE_UTIL, "DAPL: %s Setting Loopback\n",
g_dapl_loopback_connection ? "" : "NOT");
dapls_ib_state_init();
dat_status = dapl_provider_list_create();
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dapl_provider_list_create failed %d\n", dat_status);
goto bail;
}
dat_status = dapls_ns_init();
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR, "dapls_ns_init failed %d\n",
dat_status);
goto bail;
}
return;
bail:
dapl_dbg_log(DAPL_DBG_TYPE_ERR, "ERROR: dapl_init failed\n");
dapl_fini();
}
static void
dapl_fini(void)
{
DAT_RETURN dat_status;
dapl_dbg_log(DAPL_DBG_TYPE_UTIL, "DAPL: Stopped (dapl_fini)\n");
dapls_ib_state_fini();
dat_status = dapl_provider_list_destroy();
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dapl_provider_list_destroy failed %d\n", dat_status);
}
}
void
dat_provider_init(
IN const DAT_PROVIDER_INFO *provider_info,
IN const char *instance_data)
{
DAT_PROVIDER *provider;
DAPL_HCA *hca_ptr;
DAT_RETURN dat_status;
provider = NULL;
hca_ptr = NULL;
dat_status = dapl_provider_list_insert(provider_info->ia_name,
&provider);
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dat_provider_list_insert failed: %x\n", dat_status);
goto bail;
}
hca_ptr = dapl_hca_alloc((char *)provider_info->ia_name, 0);
if (NULL == hca_ptr) {
dat_status = DAT_ERROR(DAT_INSUFFICIENT_RESOURCES,
DAT_RESOURCE_MEMORY);
goto bail;
}
provider->extension = hca_ptr;
dat_status = dat_registry_add_provider(provider, provider_info);
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dat_registry_add_provider failed: %x\n", dat_status);
goto bail;
}
bail:
if (DAT_SUCCESS != dat_status) {
if (NULL != provider) {
(void) dapl_provider_list_remove(
provider_info->ia_name);
}
if (NULL != hca_ptr) {
dapl_hca_free(hca_ptr);
}
}
}
void
dat_provider_fini(
IN const DAT_PROVIDER_INFO *provider_info)
{
DAT_PROVIDER *provider;
DAT_RETURN dat_status;
dat_status = dapl_provider_list_search(provider_info->ia_name,
&provider);
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dat_registry_add_provider failed: %x\n", dat_status);
return;
}
dat_status = dat_registry_remove_provider(provider, provider_info);
if (DAT_SUCCESS != dat_status) {
dapl_dbg_log(DAPL_DBG_TYPE_ERR,
"dat_registry_add_provider failed: %x\n", dat_status);
}
(void) dapl_provider_list_remove(provider_info->ia_name);
}