--- libaitrpc/src/srv.c	2012/05/17 16:47:35	1.9.2.28
+++ libaitrpc/src/srv.c	2012/05/18 15:24:33	1.9.2.29
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: srv.c,v 1.9.2.28 2012/05/17 16:47:35 misho Exp $
+* $Id: srv.c,v 1.9.2.29 2012/05/18 15:24:33 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -89,11 +89,11 @@ txPacket(sched_task_t *task)
 			rpc->call_rep.ret = RPC_ERROR(-1);
 			rpc->call_rep.eno = RPC_ERROR(rpc_Errno);
 		} else {
-			rpc->call_argc = htons(io_arraySize(f->func_vars));
+			rpc->call_argc = htons(io_arraySize(RPC_RETVARS(c)));
 			/* Go Encapsulate variables */
-			ret = io_vars2buffer(buf + wlen, sizeof buf - wlen, f->func_vars);
+			ret = io_vars2buffer(buf + wlen, sizeof buf - wlen, RPC_RETVARS(c));
 			/* Free return values */
-			io_clrVars(f->func_vars);
+			io_freeVars(&c->cli_vars);
 			if (ret == -1) {
 				rpc_SetErr(EBADRPC, "Prepare RPC packet failed");
 				rpc->call_argc ^= rpc->call_argc;
@@ -153,8 +153,8 @@ execCall(sched_task_t *task)
 		rpc->call_rep.eno = RPC_ERROR(rpc_Errno);
 	} else {
 		/* if client doesn't want reply */
-		argc = rpc->call_req.flags & RPC_NOREPLY;
-		rpc->call_rep.ret = RPC_ERROR(rpc_srv_execCall(f, rpc, arr));
+		argc = RPC_CHK_NOREPLY(rpc);
+		rpc->call_rep.ret = RPC_ERROR(rpc_srv_execCall(c, rpc, f->func_name, arr));
 		if (rpc->call_rep.ret == htonl(-1)) {
 			rpc->call_rep.eno = RPC_ERROR(errno);
 			rpc->call_argc ^= rpc->call_argc;
@@ -162,11 +162,11 @@ execCall(sched_task_t *task)
 			rpc->call_rep.eno ^= rpc->call_rep.eno;
 			if (argc) {
 				/* without reply */
-				io_clrVars(f->func_vars);
+				io_freeVars(&c->cli_vars);
 				rpc->call_argc ^= rpc->call_argc;
 			} else {
 				/* reply */
-				rpc->call_argc = htons(io_arraySize(f->func_vars));
+				rpc->call_argc = htons(io_arraySize(RPC_RETVARS(c)));
 			}
 		}
 	}
@@ -229,7 +229,7 @@ rxPacket(sched_task_t *task)
 			continue;
 		}
 
-		noreply = rpc->call_req.flags & RPC_NOREPLY;
+		noreply = RPC_CHK_NOREPLY(rpc);
 
 		/* check RPC packet session info */
 		if (rpc_chkPktSession(&rpc->call_session, &s->srv_session)) {
@@ -853,6 +853,7 @@ rpc_srv_loopServer(rpc_srv_t * __restrict srv)
 			close(c->cli_sock);
 
 			schedCancelby(srv->srv_root, taskMAX, CRITERIA_ARG, c, NULL);
+			io_freeVars(&RPC_RETVARS(c));
 			AIT_FREE_VAL(&c->cli_buf);
 		}
 		io_arrayDel(srv->srv_clients, i, 42);
@@ -865,7 +866,6 @@ rpc_srv_loopServer(rpc_srv_t * __restrict srv)
 	TAILQ_FOREACH_SAFE(f, &srv->srv_funcs, func_node, tmp) {
 		TAILQ_REMOVE(&srv->srv_funcs, f, func_node);
 
-		io_freeVars(&f->func_vars);
 		AIT_FREE_VAL(&f->func_name);
 		free(f);
 	}
@@ -878,22 +878,23 @@ rpc_srv_loopServer(rpc_srv_t * __restrict srv)
 /*
  * rpc_srv_execCall() Execute registered call from RPC server
  *
- * @call = Register RPC call
+ * @cli = RPC client
  * @rpc = IN RPC call structure
+ * @funcname = Execute RPC function
  * @args = IN RPC calling arguments from RPC client
  * return: -1 error, !=-1 ok
  */
 int
-rpc_srv_execCall(rpc_func_t * __restrict call, struct tagRPCCall * __restrict rpc, 
-		array_t * __restrict args)
+rpc_srv_execCall(rpc_cli_t * __restrict cli, struct tagRPCCall * __restrict rpc, 
+		ait_val_t funcname, array_t * __restrict args)
 {
 	rpc_callback_t func;
 
-	if (!call || !rpc || !call->func_parent || !AIT_ADDR(&call->func_name)) {
+	if (!cli || !rpc || !AIT_ADDR(&funcname)) {
 		rpc_SetErr(EINVAL, "Invalid parameter can`t exec function");
 		return -1;
 	}
 
-	func = AIT_GET_LIKE(&call->func_name, rpc_callback_t);
-	return func(call, rpc, args);
+	func = AIT_GET_LIKE(&funcname, rpc_callback_t);
+	return func(cli, rpc, args);
 }