/*
* Copyright (C) 2015 - 2016 Red Hat, Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* Author: Gris Ge <fge@redhat.com>
* Todd Gill <tgill@redhat.com>
*/
#include <stdlib.h>
#include <stdint.h>
#include <inttypes.h>
#include <string.h>
#include <assert.h>
#include <json.h>
#include "libdmmp/libdmmp.h"
#include "libdmmp_private.h"
#define _DMMP_SHOW_PGS_CMD "show groups raw format %w|%g|%p|%t|%s"
#define _DMMP_SHOW_PG_INDEX_WWID 0
#define _DMMP_SHOW_PG_INDEX_PG_ID 1
#define _DMMP_SHOW_PG_INDEX_PRI 2
#define _DMMP_SHOW_PG_INDEX_STATUS 3
#define _DMMP_SHOW_PG_INDEX_SELECTOR 4
struct dmmp_path_group {
uint32_t id;
/* ^ pgindex of struct path, will be used for path group switch */
uint32_t status;
uint32_t priority;
char *selector;
uint32_t dmmp_p_count;
struct dmmp_path **dmmp_ps;
};
static const struct _num_str_conv _DMMP_PATH_GROUP_STATUS_CONV[] = {
{DMMP_PATH_GROUP_STATUS_UNKNOWN, "undef"},
{DMMP_PATH_GROUP_STATUS_ACTIVE, "active"},
{DMMP_PATH_GROUP_STATUS_DISABLED, "disabled"},
{DMMP_PATH_GROUP_STATUS_ENABLED, "enabled"},
};
_dmmp_str_func_gen(dmmp_path_group_status_str, uint32_t, pg_status,
_DMMP_PATH_GROUP_STATUS_CONV);
_dmmp_str_conv_func_gen(_dmmp_path_group_status_str_conv, ctx, pg_status_str,
uint32_t, DMMP_PATH_GROUP_STATUS_UNKNOWN,
_DMMP_PATH_GROUP_STATUS_CONV);
_dmmp_getter_func_gen(dmmp_path_group_id_get, struct dmmp_path_group, dmmp_pg,
id, uint32_t);
_dmmp_getter_func_gen(dmmp_path_group_status_get, struct dmmp_path_group,
dmmp_pg, status, uint32_t);
_dmmp_getter_func_gen(dmmp_path_group_priority_get, struct dmmp_path_group,
dmmp_pg, priority, uint32_t);
_dmmp_getter_func_gen(dmmp_path_group_selector_get, struct dmmp_path_group,
dmmp_pg, selector, const char *);
_dmmp_array_free_func_gen(_dmmp_path_group_array_free, struct dmmp_path_group,
_dmmp_path_group_free);
struct dmmp_path_group *_dmmp_path_group_new(void)
{
struct dmmp_path_group *dmmp_pg = NULL;
dmmp_pg = (struct dmmp_path_group *)
malloc(sizeof(struct dmmp_path_group));
if (dmmp_pg != NULL) {
dmmp_pg->id = _DMMP_PATH_GROUP_ID_UNKNOWN;
dmmp_pg->status = DMMP_PATH_GROUP_STATUS_UNKNOWN;
dmmp_pg->priority = 0;
dmmp_pg->selector = NULL;
dmmp_pg->dmmp_p_count = 0;
dmmp_pg->dmmp_ps = NULL;
}
return dmmp_pg;
}
int _dmmp_path_group_update(struct dmmp_context *ctx,
struct dmmp_path_group *dmmp_pg,
json_object *j_obj_pg)
{
int rc = DMMP_OK;
uint32_t id = 0;
int priority_int = -1 ;
const char *status_str = NULL;
const char *selector = NULL;
struct array_list *ar_ps = NULL;
int ar_ps_len = -1;
uint32_t i = 0;
struct dmmp_path *dmmp_p = NULL;
assert(ctx != NULL);
assert(dmmp_pg != NULL);
assert(j_obj_pg != NULL);
_json_obj_get_value(ctx, j_obj_pg, status_str, "dm_st",
json_type_string, json_object_get_string, rc, out);
_json_obj_get_value(ctx, j_obj_pg, selector, "selector",
json_type_string, json_object_get_string, rc, out);
_json_obj_get_value(ctx, j_obj_pg, priority_int, "pri",
json_type_int, json_object_get_int, rc, out);
_json_obj_get_value(ctx, j_obj_pg, id, "group",
json_type_int, json_object_get_int, rc, out);
dmmp_pg->priority = (priority_int <= 0) ? 0 : priority_int & UINT32_MAX;
_dmmp_null_or_empty_str_check(ctx, status_str, rc, out);
_dmmp_null_or_empty_str_check(ctx, selector, rc, out);
dmmp_pg->selector = strdup(selector);
_dmmp_alloc_null_check(ctx, dmmp_pg->selector, rc, out);
dmmp_pg->id = id;
if (dmmp_pg->id == _DMMP_PATH_GROUP_ID_UNKNOWN) {
rc = DMMP_ERR_BUG;
_error(ctx, "BUG: Got unknown(%d) path group ID",
_DMMP_PATH_GROUP_ID_UNKNOWN);
goto out;
}
dmmp_pg->status = _dmmp_path_group_status_str_conv(ctx, status_str);
_json_obj_get_value(ctx, j_obj_pg, ar_ps, "paths",
json_type_array, json_object_get_array, rc, out);
ar_ps_len = array_list_length(ar_ps);
if (ar_ps_len < 0) {
rc = DMMP_ERR_BUG;
_error(ctx, "BUG: Got negative length for ar_ps");
goto out;
}
else if (ar_ps_len == 0)
goto out;
else
dmmp_pg->dmmp_p_count = ar_ps_len & UINT32_MAX;
dmmp_pg->dmmp_ps = (struct dmmp_path **)
malloc(sizeof(struct dmmp_path *) * dmmp_pg->dmmp_p_count);
_dmmp_alloc_null_check(ctx, dmmp_pg->dmmp_ps, rc, out);
for (; i < dmmp_pg->dmmp_p_count; ++i)
dmmp_pg->dmmp_ps[i] = NULL;
for (i = 0; i < dmmp_pg->dmmp_p_count; ++i) {
dmmp_p = _dmmp_path_new();
_dmmp_alloc_null_check(ctx, dmmp_p, rc, out);
dmmp_pg->dmmp_ps[i] = dmmp_p;
_good(_dmmp_path_update(ctx, dmmp_p,
array_list_get_idx(ar_ps, i)),
rc, out);
}
_debug(ctx, "Got path group id: %" PRIu32 "", dmmp_pg->id);
_debug(ctx, "Got path group priority: %" PRIu32 "", dmmp_pg->priority);
_debug(ctx, "Got path group status: %s(%" PRIu32 ")",
dmmp_path_group_status_str(dmmp_pg->status), dmmp_pg->status);
_debug(ctx, "Got path group selector: '%s'", dmmp_pg->selector);
out:
if (rc != DMMP_OK)
_dmmp_path_group_free(dmmp_pg);
return rc;
}
void _dmmp_path_group_free(struct dmmp_path_group *dmmp_pg)
{
uint32_t i = 0;
if (dmmp_pg == NULL)
return;
free((char *) dmmp_pg->selector);
if (dmmp_pg->dmmp_ps != NULL) {
for (i = 0; i < dmmp_pg->dmmp_p_count; ++i) {
_dmmp_path_free(dmmp_pg->dmmp_ps[i]);
}
free(dmmp_pg->dmmp_ps);
}
free(dmmp_pg);
}
void dmmp_path_array_get(struct dmmp_path_group *mp_pg,
struct dmmp_path ***mp_paths,
uint32_t *dmmp_p_count)
{
assert(mp_pg != NULL);
assert(mp_paths != NULL);
assert(dmmp_p_count != NULL);
*mp_paths = mp_pg->dmmp_ps;
*dmmp_p_count = mp_pg->dmmp_p_count;
}