dss_open_close.c

MPI stands for the Message Passing Interface. Written by the MPI Forum (a large committee comprising

                                          (orte_dss_print_fn_t)orte_dss_print_int,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_INT", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_UINT;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int,
                                          orte_dss_unpack_int,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_uint,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_uint,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_UINT", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_INT8;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_byte,
                                          orte_dss_unpack_byte,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_int8,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_int8,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_INT8", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_UINT8;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_byte,
                                          orte_dss_unpack_byte,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_uint8,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_uint8,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_UINT8", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_INT16;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int16,
                                          orte_dss_unpack_int16,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_int16,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_int16,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_INT16", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_UINT16;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int16,
                                          orte_dss_unpack_int16,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_uint16,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_uint16,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_UINT16", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_INT32;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int32,
                                          orte_dss_unpack_int32,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_int32,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_int32,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_INT32", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_UINT32;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int32,
                                          orte_dss_unpack_int32,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_uint32,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_uint32,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_UINT32", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_INT64;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int64,
                                          orte_dss_unpack_int64,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_int64,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_int64,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_INT64", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_UINT64;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_int64,
                                          orte_dss_unpack_int64,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_uint64,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_uint64,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_UINT64", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_SIZE;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_sizet,
                                          orte_dss_unpack_sizet,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_size,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_size,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_SIZE", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_PID;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_pid,
                                          orte_dss_unpack_pid,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_pid,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_pid,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_PID", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_STRING;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_string,
                                          orte_dss_unpack_string,
                                          (orte_dss_copy_fn_t)orte_dss_copy_string,
                                          (orte_dss_compare_fn_t)orte_dss_compare_string,
                                          (orte_dss_size_fn_t)orte_dss_size_string,
                                          (orte_dss_print_fn_t)orte_dss_print_string,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_STRUCTURED,
                                          "ORTE_STRING", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_STD_CNTR;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_std_cntr,
                                          orte_dss_unpack_std_cntr,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_std_cntr,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_std_cntr,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_STD_CNTR", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_DATA_TYPE;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_data_type,
                                          orte_dss_unpack_data_type,
                                          (orte_dss_copy_fn_t)orte_dss_std_copy,
                                          (orte_dss_compare_fn_t)orte_dss_compare_dt,
                                          (orte_dss_size_fn_t)orte_dss_std_size,
                                          (orte_dss_print_fn_t)orte_dss_print_data_type,
                                          (orte_dss_release_fn_t)orte_dss_std_release,
                                          ORTE_DSS_UNSTRUCTURED,
                                          "ORTE_DATA_TYPE", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_DATA_VALUE;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_data_value,
                                          orte_dss_unpack_data_value,
                                          (orte_dss_copy_fn_t)orte_dss_copy_data_value,
                                          (orte_dss_compare_fn_t)orte_dss_compare_data_value,
                                          (orte_dss_size_fn_t)orte_dss_size_data_value,
                                          (orte_dss_print_fn_t)orte_dss_print_data_value,
                                          (orte_dss_release_fn_t)orte_dss_std_obj_release,
                                          ORTE_DSS_STRUCTURED,
                                          "ORTE_DATA_VALUE", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }
    tmp = ORTE_BYTE_OBJECT;
    if (ORTE_SUCCESS != (rc = orte_dss.register_type(orte_dss_pack_byte_object,
                                          orte_dss_unpack_byte_object,
                                          (orte_dss_copy_fn_t)orte_dss_copy_byte_object,
                                          (orte_dss_compare_fn_t)orte_dss_compare_byte_object,
                                          (orte_dss_size_fn_t)orte_dss_size_byte_object,
                                          (orte_dss_print_fn_t)orte_dss_print_byte_object,
                                          (orte_dss_release_fn_t)orte_dss_release_byte_object,
                                          ORTE_DSS_STRUCTURED,
                                          "ORTE_BYTE_OBJECT", &tmp))) {
        ORTE_ERROR_LOG(rc);
        return rc;
    }

    /* All done */

    return ORTE_SUCCESS;
}


int orte_dss_close(void)
{
    orte_std_cntr_t i;

    orte_dss_initialized = false;

    for (i = 0 ; i < orte_pointer_array_get_size(orte_dss_types) ; ++i) {
        orte_dss_type_info_t *info = (orte_dss_type_info_t*)orte_pointer_array_get_item(orte_dss_types, i);
        if (NULL != info) {
            OBJ_RELEASE(info);
        }
    }

    OBJ_RELEASE(orte_dss_types);

    return ORTE_SUCCESS;
}