libaitrpc/src/builtin.c - diff

Return to builtin.c CVS log

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

Diff for /libaitrpc/src/builtin.c between versions 1.3 and 1.3.2.9

version 1.3, 2011/08/29 22:37:06	version 1.3.2.9, 2011/09/07 00:30:04
Line 49 SUCH DAMAGE.	Line 49 SUCH DAMAGE.
/* builtin RPC server functions */	/* builtin RPC server functions */

int	int
rpcServerClients(rpc_func_t call, int ic, rpc_val_t iv)	rpcServerClients(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;
rpc_val_t v, vals;	array_t *vals;
rpc_cli_t *cli;	rpc_cli_t *cli;
register int i;	register int i;
	int len;
const char *str = NULL;	const char *str = NULL;
char wrk[INET6_ADDRSTRLEN];	char *val, wrk[INET6_ADDRSTRLEN];
struct sockaddr_in *s;	struct sockaddr_in *s;
struct sockaddr_in6 *s6;	struct sockaddr_in6 *s6;
struct sockaddr_un *su;	struct sockaddr_un *su;
Line 67 rpcServerClients(rpc_func_t call, int ic, rpc_val_t	Line 68 rpcServerClients(rpc_func_t call, int ic, rpc_val_t
else	else
srv = call->func_parent;	srv = call->func_parent;

if (!(vals = rpc_srv_returnVars(call, srv->srv_numcli)))	rpc_srv_getVars(call, &vals);

	len = srv->srv_numcli * STRSIZ;
	if (!(val = malloc(len))) {
	LOGERR;
return -1;	return -1;
	} else
	memset(val, 0, len);

for (i = 0, cli = srv->srv_clients, v = vals; i < srv->srv_numcli; i++, cli++) {	for (i = 0, cli = srv->srv_clients; i < srv->srv_numcli; i++, cli++) {
if (!cli->cli_sa.sa_family) {	if (!cli->cli_sa.sa_family)
RPC_SET_STR(v++, "");
continue;	continue;
}

switch (cli->cli_sa.sa_family) {	switch (cli->cli_sa.sa_family) {
case AF_INET:	case AF_INET:
Line 91 rpcServerClients(rpc_func_t call, int ic, rpc_val_t	Line 96 rpcServerClients(rpc_func_t call, int ic, rpc_val_t
break;	break;
}	}
if (str)	if (str)
RPC_SET_STR(v++, (char*) str);	strlcat(val, (char*) str, len);
else	else
RPC_SET_STR(v++, "0.0.0.0");	strlcat(val, "0.0.0.0", len);
	strlcat(val, " ", len);
}	}

	AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
	free(val);
return 0;	return 0;
}	}

int	int
rpcServerCalls(rpc_func_t call, int ic, rpc_val_t iv)	rpcServerCalls(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;
rpc_val_t v, vals;	array_t *vals;
rpc_func_t *f;	rpc_func_t *f;
register int i;	register int i;
char str[MAXPATHLEN];	int len;
	char *val, str[MAXPATHLEN];

RPC_CALLBACK_CHECK_INPUT(call);	RPC_CALLBACK_CHECK_INPUT(call);
if (!call->func_parent)	if (!call->func_parent)
Line 115 rpcServerCalls(rpc_func_t call, int ic, rpc_val_t iv	Line 124 rpcServerCalls(rpc_func_t call, int ic, rpc_val_t iv
srv = call->func_parent;	srv = call->func_parent;

for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next);	for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next);
if (!(vals = rpc_srv_returnVars(call, i)))	len = i * STRSIZ;

	rpc_srv_getVars(call, &vals);

	if (!(val = malloc(len))) {
	LOGERR;
return -1;	return -1;
	} else
	memset(val, 0, len);

for (f = srv->srv_funcs, v = vals; f; f = f->func_next) {	for (f = srv->srv_funcs, i = 0; f; f = f->func_next) {
if (*f->func_name) {	if (*f->func_name) {
memset(str, 0, sizeof str);	memset(str, 0, sizeof str);
snprintf(str, sizeof str, "/%s/%s()", f->func_file, f->func_name);	snprintf(str, sizeof str, "/%s/%s(%d); ",
RPC_SET_STR(v++, str);	f->func_file, f->func_name, io_arraySize(f->func_vars));
	strlcat(val, str, len);
}	}
}	}

	AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
	free(val);
return 0;	return 0;
}	}

int	int
rpcServerSessions(rpc_func_t call, int ic, rpc_val_t iv)	rpcServerSessions(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;
rpc_val_t *vals;	array_t *vals;
	ait_val_t *v;

RPC_CALLBACK_CHECK_INPUT(call);	RPC_CALLBACK_CHECK_INPUT(call);
if (!call->func_parent)	if (!call->func_parent)
Line 141 rpcServerSessions(rpc_func_t *call, int ic, rpc_val_t	Line 161 rpcServerSessions(rpc_func_t *call, int ic, rpc_val_t
else	else
srv = call->func_parent;	srv = call->func_parent;

if (!(vals = rpc_srv_returnVars(call, 4)))	rpc_srv_getVars(call, &vals);
return -1;

RPC_SET_U8(&vals[0], srv->srv_session.sess_version);	v = io_array(vals, 0, ait_val_t*);
RPC_SET_U32(&vals[1], srv->srv_session.sess_program);	AIT_SET_U8(v, srv->srv_session.sess_version);
RPC_SET_U32(&vals[2], srv->srv_session.sess_process);	v = io_array(vals, 1, ait_val_t*);
RPC_SET_I32(&vals[3], srv->srv_numcli);	AIT_SET_U32(v, srv->srv_session.sess_program);
	v = io_array(vals, 2, ait_val_t*);
	AIT_SET_U32(v, srv->srv_session.sess_process);
	v = io_array(vals, 3, ait_val_t*);
	AIT_SET_I32(v, srv->srv_numcli);

return 0;	return 0;
}	}

int	int
rpcServerShutdown(rpc_func_t call, int ic, rpc_val_t iv)	rpcServerShutdown(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;

Line 173 rpcServerShutdown(rpc_func_t *call, int ic, rpc_val_t	Line 196 rpcServerShutdown(rpc_func_t *call, int ic, rpc_val_t
// ----------------------------------------------------	// ----------------------------------------------------

int	int
rpcBLOBServerShutdown(rpc_func_t call, int ic, rpc_val_t iv)	rpcBLOBServerShutdown(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;

Line 191 rpcBLOBServerShutdown(rpc_func_t *call, int ic, rpc_va	Line 214 rpcBLOBServerShutdown(rpc_func_t *call, int ic, rpc_va
}	}

int	int
rpcBLOBServerVars(rpc_func_t call, int ic, rpc_val_t iv)	rpcBLOBServerVars(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;
rpc_val_t v, vals;	array_t *vals;
rpc_blob_t *b;	rpc_blob_t *b;
register int i;	register int i;
	char *val, str[64];
	int len;

RPC_CALLBACK_CHECK_INPUT(call);	RPC_CALLBACK_CHECK_INPUT(call);
if (!call->func_parent)	if (!call->func_parent)
Line 204 rpcBLOBServerVars(rpc_func_t *call, int ic, rpc_val_t	Line 229 rpcBLOBServerVars(rpc_func_t *call, int ic, rpc_val_t
else	else
srv = call->func_parent;	srv = call->func_parent;

	rpc_srv_getVars(call, &vals);

	if (srv->srv_blob.state == kill) {
	AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed");
	return 1;
	}
	if (srv->srv_blob.state == disable) {
	AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled");
	return 1;
	}

pthread_mutex_lock(&srv->srv_blob.mtx);	pthread_mutex_lock(&srv->srv_blob.mtx);
for (i = 0, b = srv->srv_blob.blobs; b; i++, b = b->blob_next);	for (i = 0, b = srv->srv_blob.blobs; b; i++, b = b->blob_next);
if (!(vals = rpc_srv_returnVars(call, i))) {	len = i * sizeof str;

	if (!(val = malloc(len))) {
	LOGERR;
pthread_mutex_unlock(&srv->srv_blob.mtx);	pthread_mutex_unlock(&srv->srv_blob.mtx);
return 0;	return -1;
	} else
	memset(val, 0, len);

	for (b = srv->srv_blob.blobs, i = 0; b; i++, b = b->blob_next) {
	memset(str, 0, sizeof str);
	snprintf(str, sizeof str, "0x%0X(%lu)=%p ", b->blob_var, b->blob_len, b->blob_data);
	strlcat(val, str, len);
}	}

for (b = srv->srv_blob.blobs, v = vals; b; b = b->blob_next)	AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
RPC_SET_U32(v++, b->blob_var);	free(val);
pthread_mutex_unlock(&srv->srv_blob.mtx);	pthread_mutex_unlock(&srv->srv_blob.mtx);

return 0;	return 0;
}	}

int	int
rpcBLOBServerState(rpc_func_t call, int ic, rpc_val_t iv)	rpcBLOBServerState(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;

Line 229 rpcBLOBServerState(rpc_func_t *call, int ic, rpc_val_t	Line 274 rpcBLOBServerState(rpc_func_t *call, int ic, rpc_val_t
else	else
srv = call->func_parent;	srv = call->func_parent;

if (iv[0].val_type != i32)	if (AIT_TYPE(io_array(iv, 0, ait_val_t*)) != i32)
return -1;	return -1;

srv->srv_blob.state = RPC_GET_I32(&iv[0]);	pthread_mutex_lock(&srv->srv_mtx);
	srv->srv_blob.state = AIT_GET_I32(io_array(iv, 0, ait_val_t*));
	pthread_mutex_unlock(&srv->srv_mtx);
return 0;	return 0;
}	}

int	int
rpcBLOBServerClients(rpc_func_t call, int ic, rpc_val_t iv)	rpcBLOBServerClients(rpc_func_t call, int ic, array_t iv)
{	{
rpc_srv_t *srv;	rpc_srv_t *srv;
rpc_val_t v, vals;	array_t *vals;
rpc_cli_t *cli;	rpc_cli_t *cli;
register int i;	register int i;
	int len;
const char *str = NULL;	const char *str = NULL;
char wrk[INET6_ADDRSTRLEN];	char *val, wrk[INET6_ADDRSTRLEN];
struct sockaddr_in *s;	struct sockaddr_in *s;
struct sockaddr_in6 *s6;	struct sockaddr_in6 *s6;
struct sockaddr_un *su;	struct sockaddr_un *su;
Line 255 rpcBLOBServerClients(rpc_func_t *call, int ic, rpc_val	Line 303 rpcBLOBServerClients(rpc_func_t *call, int ic, rpc_val
else	else
srv = call->func_parent;	srv = call->func_parent;

if (!(vals = rpc_srv_returnVars(call, srv->srv_numcli)))	rpc_srv_getVars(call, &vals);

	if (srv->srv_blob.state == kill) {
	AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed");
	return 1;
	}
	if (srv->srv_blob.state == disable) {
	AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled");
	return 1;
	}

	len = srv->srv_numcli * STRSIZ;
	if (!(val = malloc(len))) {
	LOGERR;
return -1;	return -1;
	} else
	memset(val, 0, len);

for (i = 0, cli = srv->srv_blob.clients, v = vals; i < srv->srv_numcli; i++, cli++) {	for (i = 0, cli = srv->srv_blob.clients; i < srv->srv_numcli; i++, cli++) {
if (!cli->cli_sa.sa_family) {	if (!cli->cli_sa.sa_family)
RPC_SET_STR(v++, "");
continue;	continue;
}

switch (cli->cli_sa.sa_family) {	switch (cli->cli_sa.sa_family) {
case AF_INET:	case AF_INET:
Line 279 rpcBLOBServerClients(rpc_func_t *call, int ic, rpc_val	Line 340 rpcBLOBServerClients(rpc_func_t *call, int ic, rpc_val
break;	break;
}	}
if (str)	if (str)
RPC_SET_STR(v++, (char*) str);	strlcat(val, (char*) str, len);
else	else
RPC_SET_STR(v++, "0.0.0.0");	strlcat(val, "0.0.0.0", len);
	strlcat(val, " ", len);
}	}

	AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
	free(val);
return 0;	return 0;
}	}

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

Removed from v.1.3
changed lines
	Added in v.1.3.2.9