Return to builtin.c CVS log

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

added new functions & server

    1: /*************************************************************************
    2: * (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com>
    3: *  by Michael Pounov <misho@openbsd-bg.org>
    4: *
    5: * $Author: misho $
    6: * $Id: builtin.c,v 1.1.1.1.2.2 2010/06/23 11:33:38 misho Exp $
    7: *
    8: *************************************************************************/
    9: #include "global.h"
   10: 
   11: 
   12: /* builtin RPC server functions */
   13: 
   14: int
   15: rpcServerClients(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
   16: {
   17: 	rpc_val_t *v, *vals = NULL;
   18: 	rpc_cli_t *cli;
   19: 	register int i;
   20: 	const char *str;
   21: 	char wrk[INET6_ADDRSTRLEN];
   22: 	struct sockaddr_in *s;
   23: 	struct sockaddr_in6 *s6;
   24: 
   25: 	RPC_CALLBACK_CHECK_INPUT(srv, call);
   26: 
   27: 	if (rpc_srv_declValsCall(call, srv->srv_numcli) == -1)
   28: 		return -1;
   29: 	else
   30: 		rpc_srv_delValsCall(call);
   31: 	if (rpc_srv_getValsCall(call, &vals) == -1)
   32: 		return -1;
   33: 
   34: 	for (i = 0, cli = srv->srv_clients, v = vals; i < srv->srv_numcli; cli++) {
   35: 		if (!cli->cli_sa.sa_family)
   36: 			continue;
   37: 
   38: 		if (AF_INET == cli->cli_sa.sa_family) {
   39: 			s = (struct sockaddr_in*) &cli->cli_sa;
   40: 			str = inet_ntop(cli->cli_sa.sa_family, &s->sin_addr, wrk, sizeof wrk);
   41: 		} else {
   42: 			s6 = (struct sockaddr_in6*) &cli->cli_sa;
   43: 			str = inet_ntop(cli->cli_sa.sa_family, &s6->sin6_addr, wrk, sizeof wrk);
   44: 		}
   45: 		if (str) {
   46: 			RPC_SET_STR(v++, (char*) str);
   47: 			i++;
   48: 		}
   49: 	}
   50: 
   51: 	return 0;
   52: }
   53: 
   54: int
   55: rpcServerCalls(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
   56: {
   57: 	rpc_val_t *v, *vals = NULL;
   58: 	rpc_func_t *f;
   59: 	register int i;
   60: 	char str[MAXPATHLEN];
   61: 
   62: 	RPC_CALLBACK_CHECK_INPUT(srv, call);
   63: 
   64: 	for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next);
   65: 
   66: 	if (rpc_srv_declValsCall(call, i) == -1)
   67: 		return -1;
   68: 	else
   69: 		rpc_srv_delValsCall(call);
   70: 	if (rpc_srv_getValsCall(call, &vals) == -1)
   71: 		return -1;
   72: 
   73: 	for (f = srv->srv_funcs, v = vals; f; f = f->func_next) {
   74: 		if (*f->func_name) {
   75: 			memset(str, 0, MAXPATHLEN);
   76: 			snprintf(str, MAXPATHLEN, "/%s/%s()", f->func_file, f->func_name);
   77: 			RPC_SET_STR(v++, str);
   78: 		}
   79: 	}
   80: 
   81: 	return 0;
   82: }
   83: 
   84: int
   85: rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
   86: {
   87: 	rpc_val_t *vals = NULL;
   88: 
   89: 	RPC_CALLBACK_CHECK_INPUT(srv, call);
   90: 
   91: 	if (rpc_srv_declValsCall(call, 4) == -1)
   92: 		return -1;
   93: 	else
   94: 		rpc_srv_delValsCall(call);
   95: 	if (rpc_srv_getValsCall(call, &vals) == -1)
   96: 		return -1;
   97: 
   98: 	RPC_SET_U8(&vals[0], srv->srv_session.sess_version);
   99: 	RPC_SET_U32(&vals[1], srv->srv_session.sess_program);
  100: 	RPC_SET_U32(&vals[2], srv->srv_session.sess_process);
  101: 	RPC_SET_I32(&vals[3], srv->srv_numcli);
  102: 
  103: 	return 0;
  104: }
  105: 
  106: int
  107: rpcServerShutdown(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
  108: {
  109: 	RPC_CALLBACK_CHECK_INPUT(srv, call);
  110: 
  111: 	pthread_mutex_lock(&srv->srv_mtx);
  112: 	rpc_Kill = 1;
  113: 	pthread_mutex_unlock(&srv->srv_mtx);
  114: 
  115: 	return 0;
  116: }