libaitio/src/vars.c - diff

Return to vars.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitio / src

Diff for /libaitio/src/Attic/vars.c between versions 1.4.4.2 and 1.5.2.2

version 1.4.4.2, 2012/03/27 21:37:56	version 1.5.2.2, 2012/03/29 12:23:00
Line 60 io_vars2buffer(u_char buf, int buflen, array_t vars)	Line 60 io_vars2buffer(u_char buf, int buflen, array_t vars)
int Limit = 0;	int Limit = 0;
register int i;	register int i;
ait_val_t v, val;	ait_val_t v, val;
u_char *data;	u_char *dat;

assert(buf);	assert(buf);
assert(vars);	assert(vars);
Line 78 io_vars2buffer(u_char buf, int buflen, array_t vars)	Line 78 io_vars2buffer(u_char buf, int buflen, array_t vars)
memset(buf, 0, buflen);	memset(buf, 0, buflen);

v = (ait_val_t*) buf;	v = (ait_val_t*) buf;
data = buf + Limit;	dat = buf + Limit;
}	}

/* marshaling */	/* marshaling */
Line 86 io_vars2buffer(u_char buf, int buflen, array_t vars)	Line 86 io_vars2buffer(u_char buf, int buflen, array_t vars)
val = io_array(vars, i, ait_val_t*);	val = io_array(vars, i, ait_val_t*);

v[i].val_type = val->val_type;	v[i].val_type = val->val_type;
AIT_HASH(&v[i]) = htobe16(AIT_HASH(val));	AIT_KEY(&v[i]) = htobe16(AIT_KEY(val));
AIT_LEN(&v[i]) = htobe32(AIT_LEN(val));	AIT_LEN(&v[i]) = htobe32(AIT_LEN(val));

switch (AIT_TYPE(val)) {	switch (AIT_TYPE(val)) {
Line 103 io_vars2buffer(u_char buf, int buflen, array_t vars)	Line 103 io_vars2buffer(u_char buf, int buflen, array_t vars)
case u64:	case u64:
v[i].val.net = htobe64(val->val.net);	v[i].val.net = htobe64(val->val.net);
break;	break;
	case data:
	if (AIT_LEN(val) > buflen - Limit) {
	io_SetErr(EMSGSIZE, "Error:: too short buffer buflen=%d "
	"needed min %d ...\n", buflen, Limit + AIT_LEN(val));
	return -1;
	} else
	Limit += AIT_LEN(val);

	memcpy(dat, val->val_data, AIT_LEN(val));
	/* Debug:: data offset in packet, not matter for anything! */
	v[i].val.net = dat - buf;
	dat += AIT_LEN(val);
	break;
case buffer:	case buffer:
case string:	case string:
if (AIT_LEN(val) > buflen - Limit) {	if (AIT_LEN(val) > buflen - Limit) {
Line 112 io_vars2buffer(u_char buf, int buflen, array_t vars)	Line 125 io_vars2buffer(u_char buf, int buflen, array_t vars)
} else	} else
Limit += AIT_LEN(val);	Limit += AIT_LEN(val);

memcpy(data, val->val.buffer, AIT_LEN(val));	memcpy(dat, val->val.buffer, AIT_LEN(val));
/* Debug:: data offset in packet, not matter for anything! */	/* Debug:: data offset in packet, not matter for anything! */
v[i].val.net = data - buf;	v[i].val.net = dat - buf;
data += AIT_LEN(val);	dat += AIT_LEN(val);
break;	break;
default:	default:
io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",	io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",
Line 144 io_buffer2vars(u_char *buf, int buflen, int vnum, int	Line 157 io_buffer2vars(u_char *buf, int buflen, int vnum, int
int Limit = 0;	int Limit = 0;
register int i;	register int i;
ait_val_t v, val;	ait_val_t v, val;
u_char *data;	u_char *dat;

assert(buf);	assert(buf);
if (!buf \|\| !buflen \|\| !vnum)	if (!buf \|\| !buflen \|\| !vnum)
Line 160 io_buffer2vars(u_char *buf, int buflen, int vnum, int	Line 173 io_buffer2vars(u_char *buf, int buflen, int vnum, int
return NULL;	return NULL;

v = (ait_val_t*) buf;	v = (ait_val_t*) buf;
data = buf + Limit;	dat = buf + Limit;
}	}

/* de-marshaling */	/* de-marshaling */
Line 180 io_buffer2vars(u_char *buf, int buflen, int vnum, int	Line 193 io_buffer2vars(u_char *buf, int buflen, int vnum, int
val->val_type = v[i].val_type;	val->val_type = v[i].val_type;
#if defined(__OpenBSD__)	#if defined(__OpenBSD__)
AIT_LEN(val) = betoh32(AIT_LEN(&v[i]));	AIT_LEN(val) = betoh32(AIT_LEN(&v[i]));
AIT_HASH(val) = betoh16(AIT_HASH(&v[i]));	AIT_KEY(val) = betoh16(AIT_KEY(&v[i]));
#else	#else
AIT_LEN(val) = be32toh(AIT_LEN(&v[i]));	AIT_LEN(val) = be32toh(AIT_LEN(&v[i]));
AIT_HASH(val) = be16toh(AIT_HASH(&v[i]));	AIT_KEY(val) = be16toh(AIT_KEY(&v[i]));
#endif	#endif

switch (AIT_TYPE(val)) {	switch (AIT_TYPE(val)) {
Line 204 io_buffer2vars(u_char *buf, int buflen, int vnum, int	Line 217 io_buffer2vars(u_char *buf, int buflen, int vnum, int
val->val.net = be64toh(v[i].val.net);	val->val.net = be64toh(v[i].val.net);
#endif	#endif
break;	break;
	case data:
	/* WARNING:: remap data type to buffer */
	val->val_type = buffer;
case buffer:	case buffer:
case string:	case string:
if (AIT_LEN(val) > buflen - Limit) {	if (AIT_LEN(val) > buflen - Limit) {
Line 224 io_buffer2vars(u_char *buf, int buflen, int vnum, int	Line 240 io_buffer2vars(u_char *buf, int buflen, int vnum, int
io_arrayDestroy(&vars);	io_arrayDestroy(&vars);
return NULL;	return NULL;
} else	} else
memcpy(val->val.buffer, data, AIT_LEN(val));	memcpy(val->val.buffer, dat, AIT_LEN(val));
} else	} else
val->val.buffer = data;	val->val.buffer = dat;
data += AIT_LEN(val);	dat += AIT_LEN(val);
break;	break;
default:	default:
io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",	io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",
Line 258 io_vars2map(u_char buf, int buflen, array_t vars)	Line 274 io_vars2map(u_char buf, int buflen, array_t vars)
int Limit = 0;	int Limit = 0;
register int i;	register int i;
ait_val_t v, val;	ait_val_t v, val;
u_char *data;	u_char *dat;

assert(buf);	assert(buf);
assert(vars);	assert(vars);
Line 276 io_vars2map(u_char buf, int buflen, array_t vars)	Line 292 io_vars2map(u_char buf, int buflen, array_t vars)
memset(buf, 0, buflen);	memset(buf, 0, buflen);

v = (ait_val_t*) buf;	v = (ait_val_t*) buf;
data = buf + Limit;	dat = buf + Limit;
}	}

/* marshaling */	/* marshaling */
Line 284 io_vars2map(u_char buf, int buflen, array_t vars)	Line 300 io_vars2map(u_char buf, int buflen, array_t vars)
val = io_array(vars, i, ait_val_t*);	val = io_array(vars, i, ait_val_t*);

v[i].val_type = val->val_type;	v[i].val_type = val->val_type;
AIT_HASH(&v[i]) = AIT_HASH(val);	AIT_KEY(&v[i]) = AIT_KEY(val);
AIT_LEN(&v[i]) = AIT_LEN(val);	AIT_LEN(&v[i]) = AIT_LEN(val);

switch (AIT_TYPE(val)) {	switch (AIT_TYPE(val)) {
Line 301 io_vars2map(u_char buf, int buflen, array_t vars)	Line 317 io_vars2map(u_char buf, int buflen, array_t vars)
case u64:	case u64:
v[i].val.net = val->val.net;	v[i].val.net = val->val.net;
break;	break;
	case data:
	if (AIT_LEN(val) > buflen - Limit) {
	io_SetErr(EMSGSIZE, "Error:: too short buffer buflen=%d "
	"needed min %d ...\n", buflen, Limit + AIT_LEN(val));
	return -1;
	} else
	Limit += AIT_LEN(val);

	memcpy(dat, val->val_data, AIT_LEN(val));
	/* Debug:: data offset in packet, not matter for anything! */
	v[i].val.net = dat - buf;
	dat += AIT_LEN(val);
	break;
case buffer:	case buffer:
case string:	case string:
if (AIT_LEN(val) > buflen - Limit) {	if (AIT_LEN(val) > buflen - Limit) {
Line 310 io_vars2map(u_char buf, int buflen, array_t vars)	Line 339 io_vars2map(u_char buf, int buflen, array_t vars)
} else	} else
Limit += AIT_LEN(val);	Limit += AIT_LEN(val);

memcpy(data, val->val.buffer, AIT_LEN(val));	memcpy(dat, val->val.buffer, AIT_LEN(val));
/* Debug:: data offset in packet, not matter for anything! */	/* Debug:: data offset in packet, not matter for anything! */
v[i].val.net = data - buf;	v[i].val.net = dat - buf;
data += AIT_LEN(val);	dat += AIT_LEN(val);
break;	break;
default:	default:
io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",	io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",
Line 342 io_map2vars(u_char *buf, int buflen, int vnum, int zcp	Line 371 io_map2vars(u_char *buf, int buflen, int vnum, int zcp
int Limit = 0;	int Limit = 0;
register int i;	register int i;
ait_val_t v, val;	ait_val_t v, val;
u_char *data;	u_char *dat;

assert(buf);	assert(buf);
if (!buf \|\| !buflen \|\| !vnum)	if (!buf \|\| !buflen \|\| !vnum)
Line 358 io_map2vars(u_char *buf, int buflen, int vnum, int zcp	Line 387 io_map2vars(u_char *buf, int buflen, int vnum, int zcp
return NULL;	return NULL;

v = (ait_val_t*) buf;	v = (ait_val_t*) buf;
data = buf + Limit;	dat = buf + Limit;
}	}

/* de-marshaling */	/* de-marshaling */
Line 376 io_map2vars(u_char *buf, int buflen, int vnum, int zcp	Line 405 io_map2vars(u_char *buf, int buflen, int vnum, int zcp
io_arraySet(vars, i, val);	io_arraySet(vars, i, val);

val->val_type = v[i].val_type;	val->val_type = v[i].val_type;
AIT_HASH(val) = AIT_HASH(&v[i]);	AIT_KEY(val) = AIT_KEY(&v[i]);
AIT_LEN(val) = AIT_LEN(&v[i]);	AIT_LEN(val) = AIT_LEN(&v[i]);

switch (AIT_TYPE(val)) {	switch (AIT_TYPE(val)) {
Line 393 io_map2vars(u_char *buf, int buflen, int vnum, int zcp	Line 422 io_map2vars(u_char *buf, int buflen, int vnum, int zcp
case u64:	case u64:
val->val.net = v[i].val.net;	val->val.net = v[i].val.net;
break;	break;
	case data:
	/* WARNING:: remap data type to buffer */
	val->val_type = buffer;
case buffer:	case buffer:
case string:	case string:
if (AIT_LEN(val) > buflen - Limit) {	if (AIT_LEN(val) > buflen - Limit) {
Line 413 io_map2vars(u_char *buf, int buflen, int vnum, int zcp	Line 445 io_map2vars(u_char *buf, int buflen, int vnum, int zcp
io_arrayDestroy(&vars);	io_arrayDestroy(&vars);
return NULL;	return NULL;
} else	} else
memcpy(val->val.buffer, data, AIT_LEN(val));	memcpy(val->val.buffer, dat, AIT_LEN(val));
} else	} else
val->val.buffer = data;	val->val.buffer = dat;
data += AIT_LEN(val);	dat += AIT_LEN(val);
break;	break;
default:	default:
io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",	io_SetErr(EINVAL, "Error:: unsupported variable type=%d at element #%d ...\n",
Line 473 inline int	Line 505 inline int
io_clrVars(array_t * __restrict vars)	io_clrVars(array_t * __restrict vars)
{	{
register int i;	register int i;
	ait_val_t *v;

if (!vars)	if (!vars)
return -1;	return -1;

for (i = 0; i < io_arraySize(vars); i++)	for (i = 0; i < io_arraySize(vars); i++)
if (io_arrayGet(vars, i))	if ((v = io_array(vars, i, ait_val_t*)))
AIT_FREE_VAL(io_array(vars, i, ait_val_t*));	AIT_FREE_VAL(v);

return io_arraySize(vars);	return io_arraySize(vars);
}	}
Line 536 io_freeVar(ait_val_t * __restrict val)	Line 569 io_freeVar(ait_val_t * __restrict val)
free(val);	free(val);
val = NULL;	val = NULL;
}	}
	}

	static int
	_cmp_arr_key_asc(const void a, const void b)
	{
	return AIT_KEY((ait_val_t) a) - AIT_KEY((ait_val_t**) b);
	}

	static int
	_cmp_arr_key_desc(const void a, const void b)
	{
	return AIT_KEY((ait_val_t) b) - AIT_KEY((ait_val_t**) a);
	}

	/*
	* io_sortVars() Sorting array with variables
	*
	* @vars = Variable array
	* @order = Sort order. If =0 ascend or !=0 descend
	* @cmp = Compare function for sorting. If =NULL compare by key
	* return: none
	*/
	inline void
	io_sortVars(array_t * __restrict vars, int order, int (cmp)(const void, const void*))
	{
	if (!vars)
	return;

	if (cmp)
	qsort(vars->arr_data, vars->arr_num, sizeof(void*), cmp);
	else if (order)
	qsort(vars->arr_data, vars->arr_num, sizeof(void*), _cmp_arr_key_desc);
	else
	qsort(vars->arr_data, vars->arr_num, sizeof(void*), _cmp_arr_key_asc);
	}

	/*
	* io_findKeyVars() Find variable by key from array
	*
	* @vars = Variables
	* @key = Search key
	* return: NULL error or not found, !=NULL valid element
	*/
	ait_val_t *
	io_findKeyVars(array_t * __restrict vars, u_short key)
	{
	array_t *tmp;
	ait_val_t **v = NULL;
	register int i;
	const u_char *p;

	if (!vars)
	return NULL;

	if (io_arrayCopy(&tmp, vars) == -1)
	return NULL;
	else
	qsort(tmp->arr_data, tmp->arr_num, sizeof(void*), _cmp_arr_key_asc);

	/* binary search */
	for (p = (const u_char*) tmp->arr_data, i = io_arraySize(tmp); i; i >>= 1) {
	v = (ait_val_t*) (p + (i >> 1) sizeof(void*));
	if (!(key - AIT_KEY(v))) { / found! */
	io_arrayDestroy(&tmp);
	return *v;
	}
	if ((key - AIT_KEY(v)) > 0) { / move right key > current */
	p = (const u_char) v + sizeof(void);
	i--;
	} /* else move left */
	}

	io_arrayDestroy(&tmp);
	return NULL;
}	}

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.4.4.2
changed lines
	Added in v.1.5.2.2