#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <pool.h>
#include "pool_internal.h"
int
pool_value_get_uint64(const pool_value_t *pv, uint64_t *result)
{
if (pv->pv_class != POC_UINT) {
pool_seterror(POE_BAD_PROP_TYPE);
return (PO_FAIL);
}
*result = pv->pv_u.u;
return (PO_SUCCESS);
}
int
pool_value_get_int64(const pool_value_t *pv, int64_t *result)
{
if (pv->pv_class != POC_INT) {
pool_seterror(POE_BAD_PROP_TYPE);
return (PO_FAIL);
}
*result = pv->pv_u.i;
return (PO_SUCCESS);
}
int
pool_value_get_double(const pool_value_t *pv, double *result)
{
if (pv->pv_class != POC_DOUBLE) {
pool_seterror(POE_BAD_PROP_TYPE);
return (PO_FAIL);
}
*result = pv->pv_u.d;
return (PO_SUCCESS);
}
int
pool_value_get_bool(const pool_value_t *pv, uchar_t *result)
{
if (pv->pv_class != POC_BOOL) {
pool_seterror(POE_BAD_PROP_TYPE);
return (PO_FAIL);
}
*result = pv->pv_u.b;
return (PO_SUCCESS);
}
int
pool_value_get_string(const pool_value_t *pv, const char **result)
{
if (pv->pv_class != POC_STRING) {
pool_seterror(POE_BAD_PROP_TYPE);
return (PO_FAIL);
}
*result = pv->pv_u.s;
return (PO_SUCCESS);
}
pool_value_class_t
pool_value_get_type(const pool_value_t *pv)
{
return (pv->pv_class);
}
void
pool_value_set_uint64(pool_value_t *pv, uint64_t val)
{
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
pv->pv_class = POC_UINT;
pv->pv_u.u = val;
}
void
pool_value_set_int64(pool_value_t *pv, int64_t val)
{
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
pv->pv_class = POC_INT;
pv->pv_u.i = val;
}
void
pool_value_set_double(pool_value_t *pv, double val)
{
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
pv->pv_class = POC_DOUBLE;
pv->pv_u.d = val;
}
void
pool_value_set_bool(pool_value_t *pv, uchar_t val)
{
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
pv->pv_class = POC_BOOL;
pv->pv_u.b = !!val;
}
int
pool_value_set_string(pool_value_t *pv, const char *val)
{
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
pv->pv_class = POC_STRING;
if (val == NULL || strlen(val) >= PV_VALUE_MAX_LEN) {
pool_seterror(POE_BADPARAM);
return (PO_FAIL);
} else {
if ((pv->pv_u.s = atom_string(val)) == NULL)
return (PO_FAIL);
}
return (PO_SUCCESS);
}
pool_value_t *
pool_value_alloc(void)
{
pool_value_t *val;
if ((val = malloc(sizeof (pool_value_t))) == NULL) {
pool_seterror(POE_SYSTEM);
return (NULL);
}
(void) memset(val, 0, sizeof (pool_value_t));
val->pv_class = POC_INVAL;
return (val);
}
void
pool_value_free(pool_value_t *pv)
{
if (pv->pv_name)
atom_free(pv->pv_name);
if (pv->pv_class == POC_STRING)
atom_free(pv->pv_u.s);
free(pv);
}
const char *
pool_value_get_name(const pool_value_t *pv)
{
return (pv->pv_name);
}
int
pool_value_set_name(pool_value_t *pv, const char *name)
{
if (name == NULL || strlen(name) >= PV_NAME_MAX_LEN) {
pool_seterror(POE_BADPARAM);
return (PO_FAIL);
} else {
if (pv->pv_name)
atom_free(pv->pv_name);
if ((pv->pv_name = atom_string(name)) == NULL)
return (PO_FAIL);
}
return (PO_SUCCESS);
}
int
pool_value_from_nvpair(pool_value_t *pv, nvpair_t *pn)
{
uchar_t bval;
uint64_t uval;
int64_t ival;
double dval;
uint_t nelem;
uchar_t *dval_b;
char *sval;
if (pool_value_set_name(pv, nvpair_name(pn)) != PO_SUCCESS)
return (PO_FAIL);
switch (nvpair_type(pn)) {
case DATA_TYPE_BYTE:
if (nvpair_value_byte(pn, &bval) != 0) {
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
pool_value_set_bool(pv, bval);
break;
case DATA_TYPE_BYTE_ARRAY:
if (nvpair_value_byte_array(pn, &dval_b, &nelem) != 0) {
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
(void) memcpy(&dval, dval_b, sizeof (double));
pool_value_set_double(pv, dval);
break;
case DATA_TYPE_INT64:
if (nvpair_value_int64(pn, &ival) != 0) {
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
pool_value_set_int64(pv, ival);
break;
case DATA_TYPE_UINT64:
if (nvpair_value_uint64(pn, &uval) != 0) {
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
pool_value_set_uint64(pv, uval);
break;
case DATA_TYPE_STRING:
if (nvpair_value_string(pn, &sval) != 0) {
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
if (pool_value_set_string(pv, sval) != PO_SUCCESS)
return (PO_FAIL);
break;
default:
pool_seterror(POE_SYSTEM);
return (PO_FAIL);
}
return (PO_SUCCESS);
}
int
pool_value_equal(pool_value_t *pv1, pool_value_t *pv2)
{
uint64_t uval1, uval2;
int64_t ival1, ival2;
double dval1, dval2;
uchar_t bval1, bval2;
const char *sval1, *sval2;
pool_value_class_t type;
if (pv1 == pv2)
return (PO_TRUE);
type = pool_value_get_type(pv1);
if (type != pool_value_get_type(pv2))
return (PO_FALSE);
switch (type) {
case POC_UINT:
(void) pool_value_get_uint64(pv1, &uval1);
(void) pool_value_get_uint64(pv2, &uval2);
if (uval1 == uval2)
return (PO_TRUE);
break;
case POC_INT:
(void) pool_value_get_int64(pv1, &ival1);
(void) pool_value_get_int64(pv2, &ival2);
if (ival1 == ival2)
return (PO_TRUE);
break;
case POC_DOUBLE:
(void) pool_value_get_double(pv1, &dval1);
(void) pool_value_get_double(pv2, &dval2);
if (dval1 == dval2)
return (PO_TRUE);
break;
case POC_BOOL:
(void) pool_value_get_bool(pv1, &bval1);
(void) pool_value_get_bool(pv2, &bval2);
if (bval1 == bval2)
return (PO_TRUE);
break;
case POC_STRING:
(void) pool_value_get_string(pv1, &sval1);
(void) pool_value_get_string(pv2, &sval2);
if (strcmp(sval1, sval2) == 0)
return (PO_TRUE);
break;
}
return (PO_FALSE);
}
#ifdef DEBUG
void
pool_value_dprintf(const pool_value_t *pv)
{
const char *class_name[] = {
"POC_UINT",
"POC_INT",
"POC_DOUBLE",
"POC_BOOL",
"POC_STRING"
};
pool_dprintf("name: %s\n", pv->pv_name ? pv->pv_name : "NULL");
if (pv->pv_class >= POC_UINT && pv->pv_class <= POC_STRING)
pool_dprintf("type: %s\n", class_name[pv->pv_class]);
else
pool_dprintf("type: POC_INVAL\n");
switch (pv->pv_class) {
case POC_UINT:
pool_dprintf("value: %llu\n", pv->pv_u.u);
break;
case POC_INT:
pool_dprintf("value: %lld\n", pv->pv_u.i);
break;
case POC_DOUBLE:
pool_dprintf("value: %f\n", pv->pv_u.d);
break;
case POC_BOOL:
pool_dprintf("value: %s\n", pv->pv_u.b ? "true" : "false");
break;
case POC_STRING:
pool_dprintf("value: %s\n", pv->pv_u.s);
break;
default:
pool_dprintf("value: invalid\n");
break;
}
}
#endif